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 Tue, 27 Oct 2015 07:56:51 GMT
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 <av@apache.org>
Authored: Tue Oct 27 10:56:40 2015 +0300
Committer: Anton Vinogradov <av@apache.org>
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} */


Mime
View raw message