ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [15/33] ignite git commit: 1093
Date Wed, 28 Oct 2015 10:18:20 GMT
1093


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

Branch: refs/heads/ignite-1093-3
Commit: d78e4cdbe1799231f4dd0a4fe5de0ff9b9300343
Parents: df6edf1
Author: Anton Vinogradov <av@apache.org>
Authored: Tue Oct 27 14:06:59 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
Committed: Tue Oct 27 14:06:59 2015 +0300

----------------------------------------------------------------------
 .../cache/distributed/dht/preloader/GridDhtPartitionSupplier.java  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/d78e4cdb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
index e0e9ce1..f5ae93b 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionSupplier.java
@@ -217,12 +217,14 @@ class GridDhtPartitionSupplier {
         try {
             SupplyContext sctx = scMap.remove(scId);
 
+            // Context will be cleaned in case topology changed.
             if (sctx != null && (!d.topologyVersion().equals(sctx.topVer) || d.updateSequence()
!= sctx.updateSeq)) {
                 clearContext(sctx, log);
 
                 sctx = null;
             }
 
+            // Initial demand request should contain partitions list.
             if (sctx == null && d.partitions() == null)
                 return;
 


Mime
View raw message