Return-Path: <commits-return-94432-archive-asf-public=cust-asf.ponee.io@ignite.apache.org>
X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io
Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io
Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183])
	by cust-asf2.ponee.io (Postfix) with ESMTP id A9D82200B0F
	for <archive-asf-public-internal@cust-asf2.ponee.io>; Thu,  2 Jun 2016 13:18:22 +0200 (CEST)
Received: by cust-asf.ponee.io (Postfix)
	id A891C160A16; Thu,  2 Jun 2016 11:18:22 +0000 (UTC)
Delivered-To: archive-asf-public@cust-asf.ponee.io
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by cust-asf.ponee.io (Postfix) with SMTP id 0414A160A3F
	for <archive-asf-public@cust-asf.ponee.io>; Thu,  2 Jun 2016 13:18:21 +0200 (CEST)
Received: (qmail 10766 invoked by uid 500); 2 Jun 2016 11:18:21 -0000
Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:commits-help@ignite.apache.org>
List-Unsubscribe: <mailto:commits-unsubscribe@ignite.apache.org>
List-Post: <mailto:commits@ignite.apache.org>
List-Id: <commits.ignite.apache.org>
Reply-To: dev@ignite.apache.org
Delivered-To: mailing list commits@ignite.apache.org
Received: (qmail 10750 invoked by uid 99); 2 Jun 2016 11:18:21 -0000
Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23)
    by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 02 Jun 2016 11:18:21 +0000
Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33)
	id 1C727E0105; Thu,  2 Jun 2016 11:18:21 +0000 (UTC)
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: sboikov@apache.org
To: commits@ignite.apache.org
Date: Thu, 02 Jun 2016 11:18:22 -0000
Message-Id: <90a6bbb6e381449d869614579c4ba8c0@git.apache.org>
In-Reply-To: <d4a09ffcc4264a1a898e27583fe211f7@git.apache.org>
References: <d4a09ffcc4264a1a898e27583fe211f7@git.apache.org>
X-Mailer: ASF-Git Admin Mailer
Subject: [2/2] ignite git commit: ignite-3212 Fixed issue with message send
 failure and late discovery event.
archived-at: Thu, 02 Jun 2016 11:18:22 -0000

ignite-3212 Fixed issue with message send failure and late discovery event.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6c06bd82
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6c06bd82
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6c06bd82

Branch: refs/heads/ignite-3212
Commit: 6c06bd822cf1c6247aaf0adcfc7962ebfa16152e
Parents: 548ea43
Author: sboikov <sboikov@gridgain.com>
Authored: Thu Jun 2 14:18:06 2016 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Thu Jun 2 14:18:06 2016 +0300

----------------------------------------------------------------------
 .../distributed/GridCacheTxRecoveryFuture.java      | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/6c06bd82/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryFuture.java
index 9fba6cd..b1f1e19 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheTxRecoveryFuture.java
@@ -399,14 +399,20 @@ public class GridCacheTxRecoveryFuture extends GridCompoundIdentityFuture<Boolea
     }
 
     /** {@inheritDoc} */
-    @Override public boolean onNodeLeft(UUID nodeId) {
-        for (IgniteInternalFuture<?> fut : futures())
+    @Override public boolean onNodeLeft(final UUID nodeId) {
+        for (IgniteInternalFuture<?> fut : futures()) {
             if (isMini(fut)) {
-                MiniFuture f = (MiniFuture)fut;
+                final MiniFuture f = (MiniFuture) fut;
 
-                if (f.nodeId().equals(nodeId))
-                    f.onNodeLeft(nodeId);
+                if (f.nodeId().equals(nodeId)) {
+                    cctx.kernalContext().closure().runLocalSafe(new Runnable() {
+                        @Override public void run() {
+                            f.onNodeLeft(nodeId);
+                        }
+                    });
+                }
             }
+        }
 
         return true;
     }