Fixed 'singleRmv' flag for cache.remove(k, v) operation in tx cache. (cherry picked from commit 126ab60)
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/800579c9 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/800579c9 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/800579c9 Branch: refs/heads/master Commit: 800579c9ca193f7660e35f241c255904c573eef1 Parents: e82eefe Author: sboikov <[email protected]> Authored: Tue Dec 20 15:15:04 2016 +0300 Committer: sboikov <[email protected]> Committed: Tue Dec 20 15:18:28 2016 +0300 ---------------------------------------------------------------------- .../apache/ignite/internal/processors/cache/GridCacheAdapter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/800579c9/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java index f235f6a..3b4557d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java @@ -2948,6 +2948,7 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V /** * @param key Key. + * @param filter Filter. * @return {@code True} if entry was removed. * @throws IgniteCheckedException If failed. */ @@ -2959,7 +2960,7 @@ public abstract class GridCacheAdapter<K, V> implements IgniteInternalCache<K, V Collections.singletonList(key), /*retval*/false, filter, - /*singleRmv*/true).get().success(); + /*singleRmv*/filter == null).get().success(); } @Override public String toString() {
