[geode] branch develop updated: GEODE-5472: avoid a deadlock situation by waiting before creating the region again. (#2186)

[jinmeiliao]

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 <jil...@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);