Index: modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java (revision 4897315b33a59e8566ffd026e99445279f27c53a) +++ modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtCacheAdapter.java (revision ) @@ -728,6 +728,10 @@ * @param req Get request. */ protected void processNearSingleGetRequest(final UUID nodeId, final GridNearSingleGetRequest req) { + boolean isStatisticsEnabled = ctx.config().isStatisticsEnabled(); + + long start = isStatisticsEnabled ? System.nanoTime() : 0L; + assert ctx.affinityNode(); long ttl = req.accessTtl(); @@ -825,6 +829,9 @@ sendTtlUpdateRequest(expiryPlc); } }); + + if (isStatisticsEnabled) + ctx.cache().metrics0().addGetTimeNanos(System.nanoTime() - start); } /** Index: modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java (revision 4897315b33a59e8566ffd026e99445279f27c53a) +++ modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java (revision ) @@ -2786,6 +2786,10 @@ * @param req Near atomic update request. */ private void processNearAtomicUpdateRequest(UUID nodeId, GridNearAtomicUpdateRequest req) { + boolean isStatisticsEnabled = ctx.config().isStatisticsEnabled(); + + long start = isStatisticsEnabled ? System.nanoTime() : 0L; + if (msgLog.isDebugEnabled()) { msgLog.debug("Received near atomic update request [futId=" + req.futureVersion() + ", writeVer=" + req.updateVersion() + @@ -2795,6 +2799,9 @@ req.nodeId(ctx.localNodeId()); updateAllAsyncInternal(nodeId, req, updateReplyClos); + + if (isStatisticsEnabled) + ctx.cache().metrics0().addPutTimeNanos(System.nanoTime() - start); } /**