revert THRIFT-959
git-svn-id: https://svn.apache.org/repos/asf/thrift/trunk@1176472 13f79535-47bb-0310-9956-ffa450edef68
diff --git a/lib/java/src/org/apache/thrift/transport/TSocket.java b/lib/java/src/org/apache/thrift/transport/TSocket.java
index 6dd9efa..606e8a9 100644
--- a/lib/java/src/org/apache/thrift/transport/TSocket.java
+++ b/lib/java/src/org/apache/thrift/transport/TSocket.java
@@ -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 @@
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 @@
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);