You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@thrift.apache.org by br...@apache.org on 2011/09/27 19:07:20 UTC
svn commit: r1176472 -
/thrift/trunk/lib/java/src/org/apache/thrift/transport/TSocket.java
Author: bryanduxbury
Date: Tue Sep 27 17:07:19 2011
New Revision: 1176472
URL: http://svn.apache.org/viewvc?rev=1176472&view=rev
Log:
revert THRIFT-959
Modified:
thrift/trunk/lib/java/src/org/apache/thrift/transport/TSocket.java
Modified: thrift/trunk/lib/java/src/org/apache/thrift/transport/TSocket.java
URL: http://svn.apache.org/viewvc/thrift/trunk/lib/java/src/org/apache/thrift/transport/TSocket.java?rev=1176472&r1=1176471&r2=1176472&view=diff
==============================================================================
--- thrift/trunk/lib/java/src/org/apache/thrift/transport/TSocket.java (original)
+++ thrift/trunk/lib/java/src/org/apache/thrift/transport/TSocket.java Tue Sep 27 17:07:19 2011
@@ -19,14 +19,16 @@
package org.apache.thrift.transport;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.BufferedInputStream;
+import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketException;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
/**
* Socket implementation of the TTransport interface. To be commented soon!
*
@@ -72,8 +74,8 @@ public class TSocket extends TIOStreamTr
if (isOpen()) {
try {
- inputStream_ = socket_.getInputStream();
- outputStream_ = socket_.getOutputStream();
+ inputStream_ = new BufferedInputStream(socket_.getInputStream(), 1024);
+ outputStream_ = new BufferedOutputStream(socket_.getOutputStream(), 1024);
} catch (IOException iox) {
close();
throw new TTransportException(TTransportException.NOT_OPEN, iox);
@@ -176,8 +178,8 @@ public class TSocket extends TIOStreamTr
try {
socket_.connect(new InetSocketAddress(host_, port_), timeout_);
- inputStream_ = socket_.getInputStream();
- outputStream_ = socket_.getOutputStream();
+ inputStream_ = new BufferedInputStream(socket_.getInputStream(), 1024);
+ outputStream_ = new BufferedOutputStream(socket_.getOutputStream(), 1024);
} catch (IOException iox) {
close();
throw new TTransportException(TTransportException.NOT_OPEN, iox);