ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # ignite-901
Date Mon, 13 Jul 2015 09:11:27 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-901 8da39243b -> ee6eea710


# ignite-901


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

Branch: refs/heads/ignite-901
Commit: ee6eea71058bbbbd7347e85bfc037868620c3476
Parents: 8da3924
Author: sboikov <sboikov@gridgain.com>
Authored: Mon Jul 13 11:41:17 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Mon Jul 13 12:11:19 2015 +0300

----------------------------------------------------------------------
 .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java     | 14 ++++++++++++++
 .../IgniteClientReconnectContinuousProcessorTest.java |  2 +-
 2 files changed, 15 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ee6eea71/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 3995207..1f5852c 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
@@ -419,10 +419,24 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter implements DiscoverySpi,
T
         return this;
     }
 
+    /**
+     * If {@code true} client does not try to reconnect after
+     * server detected client node failure.
+     *
+     * @return Client reconnect disabled flag.
+     */
     public boolean isClientReconnectDisabled() {
         return clientReconnectDisabled;
     }
 
+    /**
+     * Sets client reconnect disabled flag.
+     * <p>
+     * If {@code true} client does not try to reconnect after
+     * server detected client node failure.
+     *
+     * @param clientReconnectDisabled Client reconnect disabled flag.
+     */
     @IgniteSpiConfiguration(optional = true)
     public void setClientReconnectDisabled(boolean clientReconnectDisabled) {
         this.clientReconnectDisabled = clientReconnectDisabled;

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/ee6eea71/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectContinuousProcessorTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectContinuousProcessorTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectContinuousProcessorTest.java
index 4a7e3c6..c63d9a8 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectContinuousProcessorTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectContinuousProcessorTest.java
@@ -244,7 +244,7 @@ public class IgniteClientReconnectContinuousProcessorTest extends IgniteClientRe
 
         srvSpi.failNode(client.cluster().localNode().id(), null);
 
-        assertTrue(reconnectLatch.await(50000000, MILLISECONDS));
+        assertTrue(reconnectLatch.await(5000, MILLISECONDS));
 
         client.events().stopLocalListen(p);
 


Mime
View raw message