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 <sboi...@gridgain.com> Authored: Mon Jul 13 11:41:17 2015 +0300 Committer: sboikov <sboi...@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);
