# Refactoring: removed unused parameter from atomic cache method.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/87e3be30 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/87e3be30 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/87e3be30 Branch: refs/heads/ignite-292 Commit: 87e3be301c5b249e9e4e1c41f8de9804ade9158c Parents: 46386e5 Author: vozerov <voze...@gridgain.com> Authored: Wed Feb 18 17:27:53 2015 +0300 Committer: vozerov <voze...@gridgain.com> Committed: Wed Feb 18 17:27:53 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 4 +--- .../cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java | 4 ++-- 2 files changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/87e3be30/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- 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 4d21eba..4b04404 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 @@ -1010,13 +1010,11 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { * * @param nodeId Node ID. * @param req Update request. - * @param cached Cached entry if updating single local entry. * @param completionCb Completion callback. */ public void updateAllAsyncInternal( final UUID nodeId, final GridNearAtomicUpdateRequest<K, V> req, - @Nullable final GridCacheEntryEx<K, V> cached, final CI2<GridNearAtomicUpdateRequest<K, V>, GridNearAtomicUpdateResponse<K, V>> completionCb ) { IgniteInternalFuture<Object> forceFut = preldr.request(req.keys(), req.topologyVersion()); @@ -2398,7 +2396,7 @@ public class GridDhtAtomicCache<K, V> extends GridDhtCacheAdapter<K, V> { req.nodeId(ctx.localNodeId()); - updateAllAsyncInternal(nodeId, req, null, updateReplyClos); + updateAllAsyncInternal(nodeId, req, updateReplyClos); } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/87e3be30/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java index 5c65404..14b8248 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java @@ -778,7 +778,7 @@ public class GridNearAtomicUpdateFuture<K, V> extends GridFutureAdapter<Object> singleReq = req; if (ctx.localNodeId().equals(nodeId)) { - cache.updateAllAsyncInternal(nodeId, req, cached, + cache.updateAllAsyncInternal(nodeId, req, new CI2<GridNearAtomicUpdateRequest<K, V>, GridNearAtomicUpdateResponse<K, V>>() { @Override public void apply(GridNearAtomicUpdateRequest<K, V> req, GridNearAtomicUpdateResponse<K, V> res) { @@ -845,7 +845,7 @@ public class GridNearAtomicUpdateFuture<K, V> extends GridFutureAdapter<Object> opRes = new GridCacheReturn<>(null, true); if (locUpdate != null) { - cache.updateAllAsyncInternal(cctx.localNodeId(), locUpdate, cached, + cache.updateAllAsyncInternal(cctx.localNodeId(), locUpdate, new CI2<GridNearAtomicUpdateRequest<K, V>, GridNearAtomicUpdateResponse<K, V>>() { @Override public void apply(GridNearAtomicUpdateRequest<K, V> req, GridNearAtomicUpdateResponse<K, V> res) {
