From: Bryan Duxbury <bryanduxbury@apache.org>
Date: Tue, 27 Sep 2011 17:07:19 +0000 (+0000)
Subject: revert THRIFT-959
X-Git-Tag: 0.8.0~69
X-Git-Url: https://source.supwisdom.com/gerrit/gitweb?a=commitdiff_plain;h=44b2bb6bb591ee106f1bcbbea328a736a70fdc91;p=common%2Fthrift.git

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 6dd9efae..606e8a90 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 @@ public class TSocket extends TIOStreamTransport {
 
     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 TIOStreamTransport {
 
     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);