You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/02/18 14:30:02 UTC

[08/13] ignite git commit: Test investigation fix.

Test investigation fix.


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

Branch: refs/heads/ignite-1786
Commit: 2ad4b5cfc7d8f5d3fcf7f0233129078237129beb
Parents: d2e6535
Author: Anton Vinogradov <av...@apache.org>
Authored: Wed Feb 17 19:08:06 2016 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Wed Feb 17 19:08:06 2016 +0300

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


http://git-wip-us.apache.org/repos/asf/ignite/blob/2ad4b5cf/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 9634b0b..1354d96 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
@@ -975,7 +975,8 @@ public class GridDhtPartitionDemander {
                 if (parts != null) {
                     boolean rmvd = parts.remove(p);
 
-                    assert rmvd;
+                    assert rmvd : "Partition already done [cache=" + cctx.name() + ", fromNode=" + nodeId +
+                        ", part=" + p + ", left=" + parts + "]";
 
                     if (parts.isEmpty()) {
                         U.log(log, "Completed " + ((remaining.size() == 1 ? "(final) " : "") +