You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2018/11/29 16:44:30 UTC
ignite git commit: IGNITE-9720 WA for test hang
Repository: ignite
Updated Branches:
refs/heads/ignite-9720 fb639a0ba -> a092939ee
IGNITE-9720 WA for test hang
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a092939e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a092939e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a092939e
Branch: refs/heads/ignite-9720
Commit: a092939ee158a3e8e8b6f9e1e42018c7ae305836
Parents: fb639a0
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Thu Nov 29 19:44:18 2018 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Thu Nov 29 19:44:18 2018 +0300
----------------------------------------------------------------------
.../continuous/CacheContinuousQueryFailoverAbstractSelfTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/a092939e/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
index e7c2261..7cf94e6 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java
@@ -1940,7 +1940,7 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC
IgniteInternalFuture<?> restartFut = GridTestUtils.runAsync(new Callable<Void>() {
@Override public Void call() throws Exception {
try {
- while (!stop.get() && !err) {
+ while (!stop.get() && !err && !Thread.currentThread().isInterrupted()) {
final int idx = rnd.nextInt(SRV_NODES);
log.info("Stop node: " + idx);
@@ -2044,7 +2044,7 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC
log.error("Thread id: " + threadId);
- while (System.currentTimeMillis() < stopTime && !stop.get() && !err) {
+ while (System.currentTimeMillis() < stopTime && !stop.get() && !err && !Thread.currentThread().isInterrupted()) {
Integer key = rnd.nextInt(PARTS);
Integer val = valCntr.incrementAndGet();