# IGNITE-709 Bug fix: waiting for dead worker.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/aaa74250 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/aaa74250 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/aaa74250 Branch: refs/heads/ignite-709_3 Commit: aaa742508f7d256d11df22005b1948eaff721cf4 Parents: defc8b0 Author: sevdokimov <sevdoki...@gridgain.com> Authored: Fri May 15 20:27:52 2015 +0300 Committer: sevdokimov <sevdoki...@gridgain.com> Committed: Fri May 15 20:27:52 2015 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/aaa74250/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 bd7528a..7925de6 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 @@ -675,7 +675,7 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp public void waitForMessagePrecessed() { Object last = msgWorker.queue.peekLast(); - while (last != null && msgWorker.queue.contains(last)) { + while (last != null && msgWorker.isAlive() && msgWorker.queue.contains(last)) { try { Thread.sleep(10); }
