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 <ivasilin...@gridgain.com> Authored: Mon Apr 20 20:41:43 2015 +0300 Committer: ivasilinets <ivasilin...@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; + } } }
