ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [36/36] incubator-ignite git commit: # Options for Visor tester
Date Thu, 26 Feb 2015 03:54:50 GMT
# Options for Visor tester


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

Branch: refs/heads/ignite-preload-debug
Commit: 0aa749c0aff9eb087a54cf65e57dfd43f691a426
Parents: edc78ae
Author: AKuznetsov <akuznetsov@gridgain.com>
Authored: Thu Feb 26 10:53:47 2015 +0700
Committer: AKuznetsov <akuznetsov@gridgain.com>
Committed: Thu Feb 26 10:53:47 2015 +0700

----------------------------------------------------------------------
 .../dht/preloader/GridDhtPartitionDemandPool.java         | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/0aa749c0/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java
index cb19423..4412f4c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionDemandPool.java
@@ -811,13 +811,13 @@ public class GridDhtPartitionDemandPool<K, V> {
 
         /** {@inheritDoc} */
         @Override protected void body() throws InterruptedException, IgniteInterruptedCheckedException
{
-            U.debug(log, "DemandWorker " + id + " body 1");
+            U.debug(log, "DemandWorker " + id + " body enter");
 
             try {
                 int preloadOrder = cctx.config().getPreloadOrder();
 
                 if (preloadOrder > 0) {
-                    U.debug(log, "DemandWorker " + id + " body 2");
+                    U.debug(log, "DemandWorker " + id + " body preloadOrder > 0");
                     IgniteInternalFuture<?> fut = cctx.kernalContext().cache().orderedPreloadFuture(preloadOrder);
 
                     try {
@@ -841,14 +841,20 @@ public class GridDhtPartitionDemandPool<K, V> {
                     }
                 }
 
+                U.debug(log, "DemandWorker " + id + " body !(preloadOrder > 0)");
+
                 GridDhtPartitionsExchangeFuture<K, V> exchFut = null;
 
                 boolean stopEvtFired = false;
 
                 while (!isCancelled()) {
                     try {
+                        U.debug(log, "DemandWorker " + id + " body barrier.await()");
+
                         barrier.await();
 
+                        U.debug(log, "DemandWorker " + id + " body after barrier.await()");
+
                         if (id == 0 && exchFut != null && !exchFut.dummy()
&&
                             cctx.events().isRecordable(EVT_CACHE_PRELOAD_STOPPED)) {
 


Mime
View raw message