You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2015/07/23 04:53:27 UTC
[24/24] incubator-ignite git commit: IGNITE-104 - Ordered ATOMIC
updates
IGNITE-104 - Ordered ATOMIC updates
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b544e80b
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b544e80b
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b544e80b
Branch: refs/heads/ignite-104
Commit: b544e80b80803d116b13c3cdd78b619c38b86359
Parents: 0f54d4c
Author: Valentin Kulichenko <vk...@gridgain.com>
Authored: Wed Jul 22 19:52:57 2015 -0700
Committer: Valentin Kulichenko <vk...@gridgain.com>
Committed: Wed Jul 22 19:52:57 2015 -0700
----------------------------------------------------------------------
.../processors/cache/distributed/near/GridNearAtomicCache.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b544e80b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java
index ab3b06f..0aa1638 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearAtomicCache.java
@@ -71,7 +71,7 @@ public class GridNearAtomicCache<K, V> extends GridNearCacheAdapter<K, V> {
int size = CU.isSystemCache(ctx.name()) ? 100 :
Integer.getInteger(IGNITE_ATOMIC_CACHE_DELETE_HISTORY_SIZE, 1_000_000);
- if (ctx.deferredDelete())
+ if (ctx.deferredDelete(this))
rmvQueue = new GridCircularBuffer<>(U.ceilPow2(size / 10));
}