ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: #ignite-sprint-4-tests: debug query tests.
Date Mon, 20 Apr 2015 17:41:53 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-sprint-4-tests d730e232b -> cfb7241d6


#ignite-sprint-4-tests: debug query tests.


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

Branch: refs/heads/ignite-sprint-4-tests
Commit: cfb7241d6df8d2567fe29dd9f994aadfe46d1898
Parents: d730e23
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Mon Apr 20 20:41:43 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Mon Apr 20 20:41:43 2015 +0300

----------------------------------------------------------------------
 .../cache/distributed/dht/GridDhtLocalPartition.java    | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cfb7241d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
index 24d702b..6836c2f 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLocalPartition.java
@@ -222,9 +222,15 @@ public class GridDhtLocalPartition implements Comparable<GridDhtLocalPartition>
 
         // Make sure to remove exactly this entry.
         synchronized (entry) {
-            if (map.containsKey(entry.key()) && map.remove(entry.key(), entry)) {
-                if (!entry.isInternal() && !entry.deleted())
-                    mapPubSize.decrement();
+            if (map.containsKey(entry.key()) && map.remove(entry.key(), entry) &&
!entry.isInternal()) {
+                System.out.println("DELETED ENTRY "  + entry.key().value(cctx.cacheObjectContext(),
true));
+                mapPubSize.decrement();
+
+                int l = mapPubSize.intValue();
+                if (l < 0) {
+                    System.out.println("DELETED ENRTY TWO TIMES " + entry.key().value(cctx.cacheObjectContext(),
true));
+                    assert l >= 0;
+                }
             }
         }
 


Mime
View raw message