ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: exchange
Date Tue, 27 Jun 2017 09:09:48 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-2.1.2-exchange 518c65c94 -> c95b86042


exchange


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c95b8604
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c95b8604
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c95b8604

Branch: refs/heads/ignite-2.1.2-exchange
Commit: c95b860425ccabca481c3b5dfee5fa59c964e262
Parents: 518c65c
Author: sboikov <sboikov@gridgain.com>
Authored: Tue Jun 27 12:08:07 2017 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Tue Jun 27 12:08:07 2017 +0300

----------------------------------------------------------------------
 .../cache/GridCachePartitionExchangeManager.java    |  4 ++++
 .../processors/cache/GridCacheProcessor.java        |  4 ++++
 .../preloader/GridDhtPartitionsExchangeFuture.java  | 16 ++++++++++++++++
 3 files changed, 24 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/c95b8604/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
index 1544131..8de2a29 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
@@ -1158,6 +1158,8 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
      * @param err Error.
      */
     public void onExchangeDone(GridDhtPartitionsExchangeFuture exchFut, @Nullable Throwable
err) {
+        long start = U.currentTimeMillis();
+
         AffinityTopologyVersion topVer = exchFut.topologyVersion();
 
         if (log.isDebugEnabled())
@@ -1235,6 +1237,8 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
                     fut.cleanUp();
             }
         }
+
+        log.info("manager onExchangeDone [topVer=" + topVer + ", time=" + (U.currentTimeMillis()
- start) + ']');
     }
 
     /**

http://git-wip-us.apache.org/repos/asf/ignite/blob/c95b8604/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index c425bfb..119326a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -2112,6 +2112,8 @@ public class GridCacheProcessor extends GridProcessorAdapter {
         @Nullable ExchangeActions exchActions,
         Throwable err
     ) {
+        long start = U.currentTimeMillis();
+
         initCacheProxies(topVer, err);
 
         if (exchActions != null && exchActions.systemCachesStarting() &&
exchActions.newClusterState() == null)
@@ -2166,6 +2168,8 @@ public class GridCacheProcessor extends GridProcessorAdapter {
             if (stoppedGrps != null && !sharedCtx.kernalContext().clientNode())
                 sharedCtx.database().onCacheGroupsStopped(stoppedGrps);
         }
+
+        log.info("processor onExchangeDone [topVer=" + topVer + ", time=" + (U.currentTimeMillis()
- start) + ']');
     }
 
     /**

http://git-wip-us.apache.org/repos/asf/ignite/blob/c95b8604/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
index 7cdb6af..77963e9 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
@@ -682,6 +682,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
      * @throws IgniteCheckedException If failed.
      */
     private void initTopologies() throws IgniteCheckedException {
+        long start = U.currentTimeMillis();
+
         cctx.database().checkpointReadLock();
 
         try {
@@ -697,6 +699,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
         finally {
             cctx.database().checkpointReadUnlock();
         }
+
+        exchLog.info("initTopologies [topVer=" + topologyVersion() + ", time=" + (U.currentTimeMillis()
- start) + ']');
     }
 
     /**
@@ -1337,12 +1341,16 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
                 discoEvt.type() == EVT_NODE_JOINED)
                 detectLostPartitions();
 
+            long start = U.currentTimeMillis();
+
             Map<Integer, CacheValidation> m = U.newHashMap(cctx.cache().cacheGroups().size());
 
             for (CacheGroupContext grp : cctx.cache().cacheGroups())
                 m.put(grp.groupId(), validateCacheGroup(grp, discoEvt.topologyNodes()));
 
             grpValidRes = m;
+
+            exchLog.info("validateCacheGroup [topVer=" + topologyVersion() + ", time=" +
(U.currentTimeMillis() - start) + ']');
         }
 
         startLocalSnasphotOperation();
@@ -1351,6 +1359,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
 
         cctx.exchange().onExchangeDone(this, err);
 
+        long start = U.currentTimeMillis();
+
         if (exchActions != null && err == null)
             exchActions.completeRequestFutures(cctx);
 
@@ -1380,6 +1390,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
             }
         }
 
+        exchLog.info("onExchangeDone [topVer=" + topologyVersion() + ", time=" + (U.currentTimeMillis()
- start) + ']');
+
         if (super.onDone(res, err) && realExchange) {
             boolean crd;
 
@@ -1783,6 +1795,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
      * Detect lost partitions.
      */
     private void detectLostPartitions() {
+        long start = U.currentTimeMillis();
+
         boolean detected = false;
 
         synchronized (cctx.exchange().interruptLock()) {
@@ -1800,6 +1814,8 @@ public class GridDhtPartitionsExchangeFuture extends GridDhtTopologyFutureAdapte
 
         if (detected)
             cctx.exchange().scheduleResendPartitions();
+
+        exchLog.info("detectLostPartitions [topVer=" + topologyVersion() + ", time=" + (U.currentTimeMillis()
- start) + ']');
     }
 
     /**


Mime
View raw message