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 1aee04496d8fe..0a11f50fef1eb 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 @@ -2944,7 +2944,7 @@ public IgniteInternalFuture removeAsync(final K key, @Nullable final Ca } /** {@inheritDoc} */ - @Override public GridCacheReturn replace(final K key, final V oldVal, final V newVal) + @Override public GridCacheReturn replacex(final K key, final V oldVal, final V newVal) throws IgniteCheckedException { A.notNull(key, "key", oldVal, "oldVal", newVal, "newVal"); @@ -3006,7 +3006,7 @@ public IgniteInternalFuture removeAsync(final K key, @Nullable final Ca } /** {@inheritDoc} */ - @Override public IgniteInternalFuture replaceAsync(final K key, final V oldVal, final V newVal) + @Override public IgniteInternalFuture replacexAsync(final K key, final V oldVal, final V newVal) { A.notNull(key, "key", oldVal, "oldVal", newVal, "newVal"); diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProjectionEx.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProjectionEx.java index fe8b78bc7b0e8..d7db04eb3cec4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProjectionEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProjectionEx.java @@ -95,7 +95,7 @@ public IgniteInternalFuture putAllConflictAsync(Map replaceAsync(K key, V oldVal, V newVal); + public IgniteInternalFuture replacexAsync(K key, V oldVal, V newVal); /** * Stores given key-value pair in cache only if only if the previous value is equal to the @@ -116,7 +116,7 @@ public IgniteInternalFuture putAllConflictAsync(Map replaceAsync(K key, V oldVal, V newVal) { + @Override public IgniteInternalFuture replacexAsync(K key, V oldVal, V newVal) { A.notNull(key, "key", oldVal, "oldVal", newVal, "newVal"); - return cache.replaceAsync(key, oldVal, newVal); + return cache.replacexAsync(key, oldVal, newVal); } /** {@inheritDoc} */ - @Override public GridCacheReturn replace(K key, V oldVal, V newVal) throws IgniteCheckedException { - return replaceAsync(key, oldVal, newVal).get(); + @Override public GridCacheReturn replacex(K key, V oldVal, V newVal) throws IgniteCheckedException { + return replacexAsync(key, oldVal, newVal).get(); } /** {@inheritDoc} */ diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java index e629a94da8249..f388d985fa38d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProxyImpl.java @@ -1160,11 +1160,11 @@ public GridCacheProjectionImpl gateProjection() { } /** {@inheritDoc} */ - @Override public IgniteInternalFuture replaceAsync(K key, V oldVal, V newVal) { + @Override public IgniteInternalFuture replacexAsync(K key, V oldVal, V newVal) { GridCacheProjectionImpl prev = gate.enter(prj); try { - return delegate.replaceAsync(key, oldVal, newVal); + return delegate.replacexAsync(key, oldVal, newVal); } finally { gate.leave(prev); @@ -1172,11 +1172,11 @@ public GridCacheProjectionImpl gateProjection() { } /** {@inheritDoc} */ - @Override public GridCacheReturn replace(K key, V oldVal, V newVal) throws IgniteCheckedException { + @Override public GridCacheReturn replacex(K key, V oldVal, V newVal) throws IgniteCheckedException { GridCacheProjectionImpl prev = gate.enter(prj); try { - return delegate.replace(key, oldVal, newVal); + return delegate.replacex(key, oldVal, newVal); } finally { gate.leave(prev); diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index 7e67032652a12..786900ed15788 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@ -412,8 +412,8 @@ public void near(GridNearAtomicCache near) { } /** {@inheritDoc} */ - @Override public GridCacheReturn replace(K key, V oldVal, V newVal) throws IgniteCheckedException { - return replaceAsync(key, oldVal, newVal).get(); + @Override public GridCacheReturn replacex(K key, V oldVal, V newVal) throws IgniteCheckedException { + return replacexAsync(key, oldVal, newVal).get(); } /** {@inheritDoc} */ @@ -426,7 +426,7 @@ public void near(GridNearAtomicCache near) { /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public IgniteInternalFuture replaceAsync(K key, V oldVal, V newVal) { + @Override public IgniteInternalFuture replacexAsync(K key, V oldVal, V newVal) { return updateAllAsync0(F.asMap(key, newVal), null, null, 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 e650f77592ebe..9356af1c27bc3 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 @@ -465,8 +465,8 @@ public void processDhtAtomicUpdateRequest( } /** {@inheritDoc} */ - @Override public GridCacheReturn replace(K key, V oldVal, V newVal) throws IgniteCheckedException { - return dht.replace(key, oldVal, newVal); + @Override public GridCacheReturn replacex(K key, V oldVal, V newVal) throws IgniteCheckedException { + return dht.replacex(key, oldVal, newVal); } /** {@inheritDoc} */ @@ -477,8 +477,8 @@ public void processDhtAtomicUpdateRequest( /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public IgniteInternalFuture replaceAsync(K key, V oldVal, V newVal) { - return dht.replaceAsync(key, oldVal, newVal); + @Override public IgniteInternalFuture replacexAsync(K key, V oldVal, V newVal) { + return dht.replacexAsync(key, oldVal, newVal); } /** {@inheritDoc} */ diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java index 6a0a2192fa7e6..bdbdb274e0fa5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/local/atomic/GridLocalAtomicCache.java @@ -211,7 +211,7 @@ public GridLocalAtomicCache(GridCacheContext ctx) { /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public GridCacheReturn replace(K key, V oldVal, V newVal) throws IgniteCheckedException { + @Override public GridCacheReturn replacex(K key, V oldVal, V newVal) throws IgniteCheckedException { A.notNull(key, "key", oldVal, "oldVal", newVal, "newVal"); return (GridCacheReturn)updateAllInternal(UPDATE, @@ -251,7 +251,7 @@ public GridLocalAtomicCache(GridCacheContext ctx) { /** {@inheritDoc} */ @SuppressWarnings("unchecked") - @Override public IgniteInternalFuture replaceAsync(K key, V oldVal, V newVal) { + @Override public IgniteInternalFuture replacexAsync(K key, V oldVal, V newVal) { A.notNull(key, "key", oldVal, "oldVal", newVal, "newVal"); return updateAllAsync0(F.asMap(key, newVal),