From 44b2bb6bb591ee106f1bcbbea328a736a70fdc91 Mon Sep 17 00:00:00 2001 From: Bryan Duxbury Date: Tue, 27 Sep 2011 17:07:19 +0000 Subject: [PATCH] revert THRIFT-959 git-svn-id: https://svn.apache.org/repos/asf/thrift/trunk@1176472 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/org/apache/thrift/transport/TSocket.java | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) 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); -- 2.17.1