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/31 23:36:39 UTC
[geode] branch develop updated: GEODE-6820: Initialize count down
latches in setup method. (#3652)
This is an automated email from the ASF dual-hosted git repository.
eshu11 pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 7bfbf55 GEODE-6820: Initialize count down latches in setup method. (#3652)
7bfbf55 is described below
commit 7bfbf5546f74273c1c8991aef9e923ede2808b0e
Author: Eric Shu <es...@pivotal.io>
AuthorDate: Fri May 31 16:36:27 2019 -0700
GEODE-6820: Initialize count down latches in setup method. (#3652)
---
.../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