ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yzhda...@apache.org
Subject ignite git commit: review
Date Wed, 18 Nov 2015 21:52:44 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-638 8d7567eeb -> 14198abcd


review


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

Branch: refs/heads/ignite-638
Commit: 14198abcdc1ea3fd88e37f97f3b75cdc258ecd3f
Parents: 8d7567e
Author: Yakov Zhdanov <yzhdanov@gridgain.com>
Authored: Thu Nov 19 00:52:34 2015 +0300
Committer: Yakov Zhdanov <yzhdanov@gridgain.com>
Committed: Thu Nov 19 00:52:34 2015 +0300

----------------------------------------------------------------------
 .../datastructures/DataStructuresProcessor.java | 22 +++++++++++++-------
 1 file changed, 15 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/14198abc/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
index 5a19ae7..fe00f5e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastructures/DataStructuresProcessor.java
@@ -182,15 +182,23 @@ public final class DataStructuresProcessor extends GridProcessorAdapter
{
 
         ctx.event().addLocalEventListener(
             new GridLocalEventListener() {
-                @Override public void onEvent(Event evt) {
-                    DiscoveryEvent discoEvt = (DiscoveryEvent)evt;
+                @Override public void onEvent(final Event evt) {
+                    ctx.closure().callLocalSafe(
+                        new Callable<Object>() {
+                            @Override public Object call() throws Exception {
+                                DiscoveryEvent discoEvt = (DiscoveryEvent)evt;
 
-                    UUID leftNodeId = discoEvt.eventNode().id();
+                                UUID leftNodeId = discoEvt.eventNode().id();
 
-                    for (GridCacheRemovable ds : dsMap.values()) {
-                        if (ds instanceof GridCacheSemaphoreEx)
-                            ((GridCacheSemaphoreEx)ds).onNodeRemoved(leftNodeId);
-                    }
+                                for (GridCacheRemovable ds : dsMap.values()) {
+                                    if (ds instanceof GridCacheSemaphoreEx)
+                                        ((GridCacheSemaphoreEx)ds).onNodeRemoved(leftNodeId);
+                                }
+
+                                return null;
+                            }
+                        },
+                        false);
                 }
             },
             EVT_NODE_LEFT,


Mime
View raw message