Repository: ignite
Updated Branches:
  refs/heads/ignite-comm-opts2 831aa16dc -> 8d2174135


conn


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

Branch: refs/heads/ignite-comm-opts2
Commit: 8d2174135a5fb5fffe6d7e695228862241b4fcef
Parents: 831aa16
Author: sboikov <sboi...@gridgain.com>
Authored: Thu Sep 22 14:41:01 2016 +0300
Committer: sboikov <sboi...@gridgain.com>
Committed: Thu Sep 22 15:28:23 2016 +0300

----------------------------------------------------------------------
 .../apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java | 2 ++
 .../ignite/internal/IgniteSlowClientDetectionSelfTest.java       | 1 +
 .../communication/IgniteVariousConnectionNumberTest.java         | 4 ++++
 3 files changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/8d217413/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
 
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
index 639e23d..784b081 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java
@@ -3947,6 +3947,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
     /**
      *
      */
+    @SuppressWarnings("PublicInnerClass")
     public static class HandshakeMessage2 extends HandshakeMessage {
         /** */
         private static final long serialVersionUID = 0L;
@@ -3969,6 +3970,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter
          */
         HandshakeMessage2(UUID nodeId, long connectCnt, long rcvCnt, int 
connIdx) {
             super(nodeId, connectCnt, rcvCnt);
+
             this.connIdx = connIdx;
         }
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/8d217413/modules/core/src/test/java/org/apache/ignite/internal/IgniteSlowClientDetectionSelfTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/IgniteSlowClientDetectionSelfTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/IgniteSlowClientDetectionSelfTest.java
index 760313b..5721887 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/IgniteSlowClientDetectionSelfTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/IgniteSlowClientDetectionSelfTest.java
@@ -75,6 +75,7 @@ public class IgniteSlowClientDetectionSelfTest extends 
GridCommonAbstractTest {
         commSpi.setSlowClientQueueLimit(50);
         commSpi.setSharedMemoryPort(-1);
         commSpi.setIdleConnectionTimeout(300_000);
+        commSpi.setConnectionsPerNode(1);
 
         cfg.setCommunicationSpi(commSpi);
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/8d217413/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteVariousConnectionNumberTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteVariousConnectionNumberTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteVariousConnectionNumberTest.java
index 360eb8d..00a25d1 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteVariousConnectionNumberTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/managers/communication/IgniteVariousConnectionNumberTest.java
@@ -115,6 +115,10 @@ public class IgniteVariousConnectionNumberTest extends 
GridCommonAbstractTest {
 
             int idx = ThreadLocalRandom.current().nextInt(NODES);
 
+            Ignite node = ignite(idx);
+
+            client = node.configuration().isClientMode();
+
             stopGrid(idx);
 
             startGrid(idx);

Reply via email to