ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [3/5] incubator-ignite git commit: # IGNITE-709 Bug fix: waiting for dead worker.
Date Fri, 15 May 2015 17:53:01 GMT
# 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 <sevdokimov@gridgain.com>
Authored: Fri May 15 20:27:52 2015 +0300
Committer: sevdokimov <sevdokimov@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);
             }


Mime
View raw message