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

[nnag]

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.an...@gmail.com>
Authored: Mon Jul 10 13:05:44 2017 -0700
Committer: nabarun <n...@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());