You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2016/06/15 12:05:53 UTC
[06/16] ignite git commit: Tcp discovery minor: create buffered input
stream with size = socket receiveBufferSize. (cherry picked from commit
54425bf)
Tcp discovery minor: create buffered input stream with size = socket receiveBufferSize.
(cherry picked from commit 54425bf)
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3a4f587b
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3a4f587b
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3a4f587b
Branch: refs/heads/master
Commit: 3a4f587b457bd1bb86665bf51757a2aa3f986f07
Parents: c88ce20
Author: sboikov <sb...@gridgain.com>
Authored: Tue Jun 14 11:42:52 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Tue Jun 14 11:50:51 2016 +0300
----------------------------------------------------------------------
.../java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/3a4f587b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
index a9a86bc..37a1539 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java
@@ -5206,7 +5206,9 @@ class ServerImpl extends TcpDiscoveryImpl {
for (IgniteInClosure<Socket> connLsnr : spi.incomeConnLsnrs)
connLsnr.apply(sock);
- in = new BufferedInputStream(sock.getInputStream());
+ int rcvBufSize = sock.getReceiveBufferSize();
+
+ in = new BufferedInputStream(sock.getInputStream(), rcvBufSize > 0 ? rcvBufSize : 8192);
byte[] buf = new byte[4];
int read = 0;