geode git commit: GEODE-3066: Test tweaks to stabilize it.

[nnag]

Repository: geode
Updated Branches:
  refs/heads/develop 8cd03e87f -> eb3312aed


GEODE-3066: Test tweaks to stabilize it.

        * Regions created before senders and receivers are started.
        * Added a listener to slow down the puts so that when the remote region 
is destroyed, the put operation is still ongoing.

        This closes #574


Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/eb3312ae
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/eb3312ae
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/eb3312ae

Branch: refs/heads/develop
Commit: eb3312aed9767eb2fc08599a372c8dbcbeddf237
Parents: 8cd03e8
Author: nabarun <n...@pivotal.io>
Authored: Mon Jun 12 11:33:37 2017 -0700
Committer: nabarun <n...@pivotal.io>
Committed: Mon Jun 12 14:18:19 2017 -0700

----------------------------------------------------------------------
 .../serial/SerialWANPropagationDUnitTest.java   | 25 ++++++++++++--------
 1 file changed, 15 insertions(+), 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/geode/blob/eb3312ae/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java
----------------------------------------------------------------------
diff --git 
a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java
 
b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java
index a60614c..5f69f69 100644
--- 
a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java
+++ 
b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/serial/SerialWANPropagationDUnitTest.java
@@ -360,14 +360,6 @@ public class SerialWANPropagationDUnitTest extends 
WANTestBase {
 
     // these are part of remote site
     createCacheInVMs(nyPort, vm2, vm3);
-    createReceiverInVMs(vm2, vm3);
-
-    // these are part of local site
-    createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
-    // senders are created on local site
-    vm4.invoke(() -> WANTestBase.createSender("ln", 2, false, 100, 500, false, 
false, null, true));
-    vm5.invoke(() -> WANTestBase.createSender("ln", 2, false, 100, 500, false, 
false, null, true));
 
     // create one RR (RR_1) on remote site
     vm2.invoke(
@@ -375,8 +367,13 @@ public class SerialWANPropagationDUnitTest extends 
WANTestBase {
     vm3.invoke(
         () -> WANTestBase.createReplicatedRegion(getTestMethodName() + 
"_RR_1", null, isOffHeap()));
 
-    // start the senders on local site
-    startSenderInVMs("ln", vm4, vm5);
+    createReceiverInVMs(vm2, vm3);
+
+    vm2.invoke(() -> addListenerToSleepAfterCreateEvent(1000, 
getTestMethodName() + "_RR_1"));
+    vm3.invoke(() -> addListenerToSleepAfterCreateEvent(1000, 
getTestMethodName() + "_RR_1"));
+
+    // these are part of local site
+    createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
 
     // create one RR (RR_1) on local site
     vm4.invoke(
@@ -388,6 +385,14 @@ public class SerialWANPropagationDUnitTest extends 
WANTestBase {
     vm7.invoke(
         () -> WANTestBase.createReplicatedRegion(getTestMethodName() + 
"_RR_1", "ln", isOffHeap()));
 
+    // senders are created on local site
+    vm4.invoke(() -> WANTestBase.createSender("ln", 2, false, 100, 500, false, 
false, null, true));
+    vm5.invoke(() -> WANTestBase.createSender("ln", 2, false, 100, 500, false, 
false, null, true));
+
+
+    // start the senders on local site
+    startSenderInVMs("ln", vm4, vm5);
+
     IgnoredException.addIgnoredException(BatchException70.class.getName());
     
IgnoredException.addIgnoredException(ServerOperationException.class.getName());