Repository: ignite Updated Branches: refs/heads/ignite-3212 bb83c4fa8 -> 7e3ecb955
ignite-3212 Fixed issue with message send failure and late discovery event. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7e3ecb95 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7e3ecb95 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7e3ecb95 Branch: refs/heads/ignite-3212 Commit: 7e3ecb955f27c25244cc2faa67500e19cbfb4a94 Parents: bb83c4f Author: sboikov <[email protected]> Authored: Thu Jun 2 15:57:11 2016 +0300 Committer: sboikov <[email protected]> Committed: Thu Jun 2 15:57:11 2016 +0300 ---------------------------------------------------------------------- .../ignite/internal/processors/cache/GridCacheMvccManager.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7e3ecb95/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java index c4db01e..5e8608e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java @@ -249,6 +249,8 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { if (log.isDebugEnabled()) log.debug("Processing node left [nodeId=" + discoEvt.eventNode().id() + "]"); + long start = U.currentTimeMillis(); + for (GridCacheFuture<?> fut : activeFutures()) fut.onNodeLeft(discoEvt.eventNode().id()); @@ -262,6 +264,8 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter { atomicFuts.remove(futVer, cacheFut); } } + + log.info("Node fail handle time: " + (U.currentTimeMillis() - start)); } };
