Repository: ignite Updated Branches: refs/heads/ignite-1093-2 1f655f252 -> fa34b7f4b
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fa34b7f4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fa34b7f4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fa34b7f4 Branch: refs/heads/ignite-1093-2 Commit: fa34b7f4bedd0f1051f1abd7f88d0e0e07afeded Parents: 1f655f2 Author: Anton Vinogradov <[email protected]> Authored: Tue Oct 27 10:56:40 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Tue Oct 27 10:56:40 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/dht/preloader/GridDhtPreloader.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fa34b7f4/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 c781183..627b254 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 @@ -406,7 +406,14 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter { /** {@inheritDoc} */ public void handleDemandMessage(int idx, UUID id, GridDhtPartitionDemandMessage d) { - supplier.handleDemandMessage(idx, id, d); + busyLock.readLock().lock(); + + try { + supplier.handleDemandMessage(idx, id, d); + } + finally { + busyLock.readLock().unlock(); + } } /** {@inheritDoc} */
