storm-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject [1/3] storm git commit: [STORM-1170] Fix the producer alive issue in DisruptoQueueTest
Date Thu, 05 Nov 2015 20:53:49 GMT
Repository: storm
Updated Branches:
  refs/heads/master 9e2b02dcd -> 2bad9c62e


[STORM-1170] Fix the producer alive issue in DisruptoQueueTest


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/77aa363d
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/77aa363d
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/77aa363d

Branch: refs/heads/master
Commit: 77aa363ddf9de8a1bd0a11e86ee29c1c283424c2
Parents: f3ed08b
Author: zhuol <zhuol@yahoo-inc.com>
Authored: Wed Nov 4 14:24:18 2015 -0600
Committer: zhuol <zhuol@yahoo-inc.com>
Committed: Wed Nov 4 14:24:18 2015 -0600

----------------------------------------------------------------------
 storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/77aa363d/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
----------------------------------------------------------------------
diff --git a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
index 281c19a..2ab0109 100644
--- a/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
+++ b/storm-core/test/jvm/backtype/storm/utils/DisruptorQueueTest.java
@@ -126,7 +126,7 @@ public class DisruptorQueueTest extends TestCase {
 
         @Override
         public void run() {
-            for (long i = 0; i < _max; i++) {
+            for (long i = 0; i < _max && !(Thread.currentThread().isInterrupted());
i++) {
                 queue.publish(i);
             }
         }


Mime
View raw message