You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@thrift.apache.org by jk...@apache.org on 2018/10/05 21:05:44 UTC
[thrift] branch master updated: THRIFT-4494: Increase Java Socket
Buffer Size (#1608)
This is an automated email from the ASF dual-hosted git repository.
jking pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/thrift.git
The following commit(s) were added to refs/heads/master by this push:
new d566da7 THRIFT-4494: Increase Java Socket Buffer Size (#1608)
d566da7 is described below
commit d566da7739c9aae63fe7fc9d267887fa73e5dda7
Author: Naveen Gangam <ng...@cloudera.com>
AuthorDate: Fri Oct 5 14:05:40 2018 -0700
THRIFT-4494: Increase Java Socket Buffer Size (#1608)
---
lib/java/src/org/apache/thrift/transport/TSocket.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/lib/java/src/org/apache/thrift/transport/TSocket.java b/lib/java/src/org/apache/thrift/transport/TSocket.java
index 148122f..b20b32b 100644
--- a/lib/java/src/org/apache/thrift/transport/TSocket.java
+++ b/lib/java/src/org/apache/thrift/transport/TSocket.java
@@ -80,8 +80,8 @@ public class TSocket extends TIOStreamTransport {
if (isOpen()) {
try {
- inputStream_ = new BufferedInputStream(socket_.getInputStream(), 1024);
- outputStream_ = new BufferedOutputStream(socket_.getOutputStream(), 1024);
+ inputStream_ = new BufferedInputStream(socket_.getInputStream());
+ outputStream_ = new BufferedOutputStream(socket_.getOutputStream());
} catch (IOException iox) {
close();
throw new TTransportException(TTransportException.NOT_OPEN, iox);
@@ -219,8 +219,8 @@ public class TSocket extends TIOStreamTransport {
try {
socket_.connect(new InetSocketAddress(host_, port_), connectTimeout_);
- inputStream_ = new BufferedInputStream(socket_.getInputStream(), 1024);
- outputStream_ = new BufferedOutputStream(socket_.getOutputStream(), 1024);
+ inputStream_ = new BufferedInputStream(socket_.getInputStream());
+ outputStream_ = new BufferedOutputStream(socket_.getOutputStream());
} catch (IOException iox) {
close();
throw new TTransportException(TTransportException.NOT_OPEN, iox);