geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinmeil...@apache.org
Subject [geode] branch develop updated: GEODE-5472: avoid a deadlock situation by waiting before creating the region again. (#2186)
Date Wed, 25 Jul 2018 16:38:07 GMT
This is an automated email from the ASF dual-hosted git repository.

jinmeiliao 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 d3ba33a  GEODE-5472: avoid a deadlock situation by waiting before creating the region
again. (#2186)
d3ba33a is described below

commit d3ba33a62767d15820b7d67d5d629e3df1482f75
Author: jinmeiliao <jiliao@pivotal.io>
AuthorDate: Wed Jul 25 09:38:02 2018 -0700

    GEODE-5472: avoid a deadlock situation by waiting before creating the region again. (#2186)
---
 .../cache/partitioned/PersistentPartitionedRegionRegressionTest.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionRegressionTest.java
b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionRegressionTest.java
index a8ee62f..40a4434 100644
--- a/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionRegressionTest.java
+++ b/geode-core/src/distributedTest/java/org/apache/geode/internal/cache/partitioned/PersistentPartitionedRegionRegressionTest.java
@@ -303,8 +303,10 @@ public class PersistentPartitionedRegionRegressionTest implements Serializable
{
 
     vm1.invoke(() -> checkData(0, 4, "a", partitionedRegionName));
 
-    vm0.invoke(() -> createPartitionedRegion(0, -1, 113, true));
+    // wait till cache is completely shutdown before trying to create the region again. otherwise
+    // deadlock situation might happen.
     vm0.invoke(() -> await().atMost(2, MINUTES).until(() -> CRASHED.get()));
+    vm0.invoke(() -> createPartitionedRegion(0, -1, 113, true));
     vm0.invoke(() -> checkData(0, 4, "a", partitionedRegionName));
 
     assertThat(vm1.invoke(() -> getBucketList(partitionedRegionName))).isEqualTo(bucketsOnVM1);


Mime
View raw message