geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From n...@apache.org
Subject geode git commit: GEODE-3066: Test tweaks to stabilize it.
Date Mon, 12 Jun 2017 21:18:37 GMT
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 <nnag@pivotal.io>
Authored: Mon Jun 12 11:33:37 2017 -0700
Committer: nabarun <nnag@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());
 


Mime
View raw message