ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: 1093
Date Sat, 17 Oct 2015 17:15:32 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1093-2 62a7b2f8a -> 391afcdb9


1093


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

Branch: refs/heads/ignite-1093-2
Commit: 391afcdb9f17ccacf106b60ce04de92f57c7d39e
Parents: 62a7b2f
Author: Anton Vinogradov <avinogradov@gridgain.com>
Authored: Sat Oct 17 20:15:08 2015 +0300
Committer: Anton Vinogradov <avinogradov@gridgain.com>
Committed: Sat Oct 17 20:15:08 2015 +0300

----------------------------------------------------------------------
 .../cache/distributed/dht/preloader/GridDhtPreloader.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/391afcdb/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
index 3441f94..a072ddc 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
@@ -202,6 +202,9 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter {
         supplier = new GridDhtPartitionSupplier(cctx);
         demander = new GridDhtPartitionDemander(cctx, demandLock);
 
+        supplier.start();
+        demander.start();
+
         cctx.events().addListener(discoLsnr, EVT_NODE_JOINED, EVT_NODE_LEFT, EVT_NODE_FAILED);
     }
 
@@ -219,9 +222,6 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter {
         final long startTopVer = loc.order();
 
         topVer.setIfGreater(startTopVer);
-
-        supplier.start();
-        demander.start();
     }
 
     /** {@inheritDoc} */
@@ -404,7 +404,7 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter {
     }
 
     /** {@inheritDoc} */
-    public void handleDemandMessage(int idx, UUID id, GridDhtPartitionDemandMessage d){
+    public void handleDemandMessage(int idx, UUID id, GridDhtPartitionDemandMessage d) {
         supplier.handleDemandMessage(idx, id, d);
     }
 


Mime
View raw message