IGNITE-49: Fixed code style
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/9c6601fa Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/9c6601fa Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/9c6601fa Branch: refs/heads/ignite-49 Commit: 9c6601fa3fc704f891e716ded83c7bf5b8aa5db8 Parents: 5a9d57a 5598513 Author: nikolay_tikhonov <ntikho...@gridgain.com> Authored: Thu Jan 22 16:16:26 2015 +0300 Committer: nikolay_tikhonov <ntikho...@gridgain.com> Committed: Thu Jan 22 16:16:26 2015 +0300 ---------------------------------------------------------------------- .../core/src/main/java/org/apache/ignite/IgniteCacheManager.java | 3 +-- .../cache/distributed/dht/atomic/GridDhtAtomicCache.java | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9c6601fa/modules/core/src/main/java/org/apache/ignite/IgniteCacheManager.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/9c6601fa/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java ---------------------------------------------------------------------- diff --cc modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java index 6152398,5345da2..c4486fe --- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java +++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java @@@ -818,9 -825,22 +818,8 @@@ public class GridDhtAtomicCache<K, V> e subjId, taskNameHash); -- if (statsEnabled) { - updateFut.listenAsync(new CI1<IgniteFuture<Object>>() { - @Override public void apply(IgniteFuture<Object> fut) { - try { - if (!fut.isCancelled()) { - fut.get(); - - ctx.cache().metrics0().addRemoveTimeNanos(System.nanoTime() - start); - } - } - catch (IgniteCheckedException ignore){ - //No-op. - } - } - }); - } ++ if (statsEnabled) + updateFut.listenAsync(new UpdateRemoveTimeStatClosure<>(metrics0(), start)); - } return asyncOp(new CO<IgniteFuture<Object>>() { @Override public IgniteFuture<Object> apply() {
