You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/12/05 14:42:00 UTC

[38/50] [abbrv] ignite git commit: debugging TC hangs

debugging TC hangs


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

Branch: refs/heads/ignite-comm-balance-master
Commit: 781c9d92bce0e7e2adc336bfd1a62983358c4475
Parents: 71b7b2a
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Tue Nov 29 11:32:44 2016 +0700
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Tue Nov 29 11:32:44 2016 +0700

----------------------------------------------------------------------
 .../java/org/apache/ignite/internal/util/StripedExecutor.java  | 4 ++--
 .../cache/GridCacheOffHeapMultiThreadedUpdateSelfTest.java     | 6 +++---
 2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/781c9d92/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
index a6161f3..44c7ddb 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedExecutor.java
@@ -70,12 +70,12 @@ public class StripedExecutor implements ExecutorService {
             // TODO
             Thread t = new Thread(new Runnable() {
                 @Override public void run() {
-                    for (;;) {
+                    for (; !isShutdown();) {
                         try {
                             Thread.sleep(10000);
                         }
                         catch (InterruptedException e) {
-                            e.printStackTrace();
+                            return;
                         }
 
                         for (Stripe stripe : stripes) {

http://git-wip-us.apache.org/repos/asf/ignite/blob/781c9d92/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapMultiThreadedUpdateSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapMultiThreadedUpdateSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapMultiThreadedUpdateSelfTest.java
index 9458a63..6e2e91f 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapMultiThreadedUpdateSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffHeapMultiThreadedUpdateSelfTest.java
@@ -115,10 +115,10 @@ public class GridCacheOffHeapMultiThreadedUpdateSelfTest extends GridCacheOffHea
         if (gridCount() > 1)
             testPutTx(keyForNode(1), PESSIMISTIC);
     }
-    
+
     /**
      * TODO: IGNITE-592.
-     *  
+     *
      * @throws Exception If failed.
      */
     public void testPutTxOptimistic() throws Exception {
@@ -227,4 +227,4 @@ public class GridCacheOffHeapMultiThreadedUpdateSelfTest extends GridCacheOffHea
 
         assertFalse(failed);
     }
-}
\ No newline at end of file
+}