ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [4/4] ignite git commit: 1093
Date Mon, 02 Nov 2015 08:57:36 GMT
1093


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

Branch: refs/heads/ignite-1093-3
Commit: a9dbe85c546682295a5d40f29c923ecbfb4467f1
Parents: aa9674b
Author: Anton Vinogradov <av@apache.org>
Authored: Mon Nov 2 11:57:10 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Mon Nov 2 11:57:10 2015 +0300

----------------------------------------------------------------------
 .../distributed/dht/preloader/GridDhtPartitionDemander.java    | 6 ++++++
 1 file changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/a9dbe85c/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
index 0c5ff26..0c41b8b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemander.java
@@ -872,6 +872,9 @@ public class GridDhtPartitionDemander {
             }
         }
 
+        /**
+         * @param nodeId Node id.
+         */
         private void cleanupRemoteContexts(UUID nodeId) {
             ClusterNode node = cctx.discovery().node(nodeId);
 
@@ -1308,6 +1311,9 @@ public class GridDhtPartitionDemander {
                                 fut.partitionMissed(node.id(), miss);
                         }
 
+                        for (Integer miss : s.supply().missed())
+                            fut.partitionDone(node.id(), miss);
+
                         if (fut.remaining.get(node.id()) == null)
                             break; // While.
 


Mime
View raw message