ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [22/22] incubator-ignite git commit: IGNITE-49: Fixed code style
Date Thu, 22 Jan 2015 13:20:31 GMT
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 <ntikhonov@gridgain.com>
Authored: Thu Jan 22 16:16:26 2015 +0300
Committer: nikolay_tikhonov <ntikhonov@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() {


Mime
View raw message