IGNITE-709 Bug fix: ping should return 'false' instead of throwing exception if thread was interrupted.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/f0b6b6e3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/f0b6b6e3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/f0b6b6e3 Branch: refs/heads/ignite-23 Commit: f0b6b6e3d36b117e94e8e901bf77d350551cfe57 Parents: db0179d Author: sevdokimov <sevdoki...@gridgain.com> Authored: Fri May 22 13:59:53 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Fri May 22 13:59:53 2015 +0300 ---------------------------------------------------------------------- .../apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f0b6b6e3/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java index 54efb44..f28422f 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java @@ -20,6 +20,7 @@ package org.apache.ignite.spi.discovery.tcp; import org.apache.ignite.*; import org.apache.ignite.cache.*; import org.apache.ignite.cluster.*; +import org.apache.ignite.internal.*; import org.apache.ignite.internal.util.future.*; import org.apache.ignite.internal.util.typedef.*; import org.apache.ignite.internal.util.typedef.internal.*; @@ -407,6 +408,9 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp try { return fut.get(); } + catch (IgniteInterruptedCheckedException ignored) { + return false; + } catch (IgniteCheckedException e) { throw new IgniteSpiException(e); // Should newer occur }
