ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: debug
Date Wed, 26 Jul 2017 16:14:56 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-5569-debug 00d307d05 -> e40e79928


debug


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/e40e7992
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/e40e7992
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/e40e7992

Branch: refs/heads/ignite-5569-debug
Commit: e40e799289eb130421811b5349871e7369168821
Parents: 00d307d
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Jul 26 19:14:49 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Jul 26 19:14:49 2017 +0300

----------------------------------------------------------------------
 .../main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java | 3 +++
 .../java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 3 +++
 2 files changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/e40e7992/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 9085937..3ea144d 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
@@ -5676,6 +5676,9 @@ class ServerImpl extends TcpDiscoveryImpl {
                         log.info("TCP discovery accepted incoming connection " +
                             "[rmtAddr=" + sock.getInetAddress() + ", rmtPort=" + sock.getPort()
+ ']');
 
+                    sock.setSendBufferSize(5 * 65536);
+                    sock.setReceiveBufferSize(5 * 65536);
+
                     SocketReader reader = new SocketReader(sock);
 
                     synchronized (mux) {

http://git-wip-us.apache.org/repos/asf/ignite/blob/e40e7992/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
index c988d7e..0ba4894 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java
@@ -1394,6 +1394,9 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter implements DiscoverySpi
{
         else
             sock = new Socket();
 
+        sock.setSendBufferSize(5 * 65536);
+        sock.setReceiveBufferSize(5 * 65536);
+
         sock.bind(new InetSocketAddress(locHost, 0));
 
         sock.setTcpNoDelay(true);


Mime
View raw message