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-1731: Modifying region size check to be more accurate
Date Wed, 12 Jul 2017 01:28:59 GMT
Repository: geode
Updated Branches:
  refs/heads/develop c48b5381c -> 659654a0c


GEODE-1731: Modifying region size check to be more accurate

	* Changed the hardcoded 5010 region size check to the size of the region already plus 20
new elements. The 20 new elements is due to the fact that a synchronous call to get the region
size of vm2 had to be used, so there should be more time for elements to be put.

	This closes #622


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

Branch: refs/heads/develop
Commit: 659654a0c7133cce88e80c0374ab198c5c6dee8b
Parents: c48b538
Author: David Anuta <david.r.anuta@gmail.com>
Authored: Mon Jul 10 13:05:44 2017 -0700
Committer: nabarun <nnag@pivotal.io>
Committed: Tue Jul 11 18:28:11 2017 -0700

----------------------------------------------------------------------
 .../concurrent/ConcurrentParallelGatewaySenderDUnitTest.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/geode/blob/659654a0/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java
b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java
index 529d25e..add6958 100644
--- a/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java
+++ b/geode-wan/src/test/java/org/apache/geode/internal/cache/wan/concurrent/ConcurrentParallelGatewaySenderDUnitTest.java
@@ -631,13 +631,15 @@ public class ConcurrentParallelGatewaySenderDUnitTest extends WANTestBase
{
 
     AsyncInvocation inv2 = vm4.invokeAsync(() -> WANTestBase.killSender());
 
+    int prevRegionSize = vm2.invoke(() -> WANTestBase.getRegionSize(getTestMethodName()
+ "_PR"));
+
     AsyncInvocation inv3 =
         vm6.invokeAsync(() -> WANTestBase.doPuts(getTestMethodName() + "_PR", 10000));
 
     vm2.invoke(() -> Awaitility.await().atMost(30000, TimeUnit.MILLISECONDS)
         .until(() -> assertEquals(
-            "Failure in waiting for additional 10 events to be received by the receiver ",
true,
-            getRegionSize(getTestMethodName() + "_PR") > 5010)));
+            "Failure in waiting for additional 20 events to be received by the receiver ",
true,
+            getRegionSize(getTestMethodName() + "_PR") > 20 + prevRegionSize)));
 
     AsyncInvocation inv4 = vm5.invokeAsync(() -> WANTestBase.killSender());
 


Mime
View raw message