Repository: ignite Updated Branches: refs/heads/ignite-1758 893054d11 -> b56ed725e
ignite-1758 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b56ed725 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b56ed725 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b56ed725 Branch: refs/heads/ignite-1758 Commit: b56ed725e8602ee8458917df28dfdc8bc4fdf231 Parents: 893054d Author: sboikov <[email protected]> Authored: Mon Oct 26 14:37:11 2015 +0300 Committer: sboikov <[email protected]> Committed: Mon Oct 26 14:37:11 2015 +0300 ---------------------------------------------------------------------- .../spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b56ed725/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java index ea22c8c..7c6a960 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoveryMultiThreadedTest.java @@ -26,11 +26,12 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import org.apache.ignite.Ignite; -import org.apache.ignite.IgniteClientDisconnectedException; import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgniteClientDisconnectedCheckedException; import org.apache.ignite.internal.IgniteInternalFuture; import org.apache.ignite.internal.IgniteKernal; import org.apache.ignite.internal.util.typedef.G; +import org.apache.ignite.internal.util.typedef.X; import org.apache.ignite.internal.util.typedef.internal.U; import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; @@ -186,8 +187,11 @@ public class TcpDiscoveryMultiThreadedTest extends GridCommonAbstractTest { try { startGrid(idx); } - catch (IgniteClientDisconnectedException e) { - log.info("Client disconnected: " + e); + catch (Exception e) { + if (X.hasCause(e, IgniteClientDisconnectedCheckedException.class)) + log.info("Client disconnected: " + e); + else + throw e; } } }
