You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by es...@apache.org on 2019/05/30 23:37:36 UTC
[geode] branch feature/GEODE-6820 updated: GEODE-6820: Initialize
count down latches in setup method.
This is an automated email from the ASF dual-hosted git repository.
eshu11 pushed a commit to branch feature/GEODE-6820
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-6820 by this push:
new 9818cd1 GEODE-6820: Initialize count down latches in setup method.
9818cd1 is described below
commit 9818cd139d11af1b3e4e228a1ec4e6cb5971021c
Author: eshu <es...@pivotal.io>
AuthorDate: Thu May 30 16:34:40 2019 -0700
GEODE-6820: Initialize count down latches in setup method.
---
.../geode/internal/cache/ClearTXLockingDUnitTest.java | 15 ++++++++++++---
1 file changed, 12 insertions(+), 3 deletions(-)
diff --git a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ClearTXLockingDUnitTest.java b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ClearTXLockingDUnitTest.java
index 12276ae..7d1ce48 100644
--- a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ClearTXLockingDUnitTest.java
+++ b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ClearTXLockingDUnitTest.java
@@ -72,9 +72,9 @@ public class ClearTXLockingDUnitTest implements Serializable {
private static final String REGION_NAME1 = "testRegion1";
private static final String REGION_NAME2 = "testRegion2";
- private static final CountDownLatch opsLatch = new CountDownLatch(1);
- private static final CountDownLatch regionLatch = new CountDownLatch(1);
- private static final CountDownLatch verifyLatch = new CountDownLatch(1);
+ private static CountDownLatch opsLatch;
+ private static CountDownLatch regionLatch;
+ private static CountDownLatch verifyLatch;
private static volatile InternalCache cache;
@@ -93,6 +93,15 @@ public class ClearTXLockingDUnitTest implements Serializable {
createCache(vm0);
createCache(vm1);
+
+ for (VM vm : VM.toArray(vm0, vm1, getController())) {
+ vm.invoke(() -> {
+ opsLatch = new CountDownLatch(1);
+ regionLatch = new CountDownLatch(1);
+ verifyLatch = new CountDownLatch(1);
+ });
+ }
+
}
@After