Repository: ignite Updated Branches: refs/heads/ignite-1093-2 e74a20f50 -> 00140b310
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/00140b31 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/00140b31 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/00140b31 Branch: refs/heads/ignite-1093-2 Commit: 00140b3103e1eb6c22672cc6e7f456c5805f3f34 Parents: e74a20f Author: Anton Vinogradov <[email protected]> Authored: Wed Oct 14 15:28:57 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Wed Oct 14 15:28:57 2015 +0300 ---------------------------------------------------------------------- .../distributed/dht/preloader/GridDhtPreloader.java | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/00140b31/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 e4b9434..4a6a235 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 @@ -201,9 +201,6 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter { demander = new GridDhtPartitionDemander(cctx, demandLock); cctx.events().addListener(discoLsnr, EVT_NODE_JOINED, EVT_NODE_LEFT, EVT_NODE_FAILED); - - supplier.start(); - demander.start(); } /** {@inheritDoc} */ @@ -220,6 +217,9 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter { final long startTopVer = loc.order(); topVer.setIfGreater(startTopVer); + + supplier.start(); + demander.start(); } /** {@inheritDoc} */ @@ -240,11 +240,6 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter { cctx.events().removeListener(discoLsnr); - top = null; - } - - /** {@inheritDoc} */ - @Override public void stop() { // Acquire write busy lock. busyLock.writeLock().lock(); @@ -253,6 +248,8 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter { if (demander != null) demander.stop(); + + top = null; } /** {@inheritDoc} */
