You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2016/04/19 20:19:35 UTC
[09/13] incubator-geode git commit: GEODE-1032 : Additional wait time
to check for empty queue,
refactored WANTestBase.java to remove unused functions,
replaced wait criterions with awaitility.
GEODE-1032 : Additional wait time to check for empty queue, refactored WANTestBase.java to remove unused functions, replaced wait criterions with awaitility.
* Added additional wait time in awaitility to check for empty queue [WANTestBase.java]
* Replaced wait criterion with awaitility [WANTestBase.java]
* Removed used parameters from function signatures [WANTestBase.java]
* Added listener to put the thread to sleep on create event so that the transmission is slowed and sender queue is not empty when the cache is closed.[testReplicatedSerialPropagationWithRemoteReceiverRestartedOnOtherNode]
* Used the new function signature for validateRegionSize which passes time to wait as a parameter for test cases which wait for 240 seconds.
This closes #128
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/84a4b474
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/84a4b474
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/84a4b474
Branch: refs/heads/feature/GEODE-1233
Commit: 84a4b474c202e078aaef26487d90482915260835
Parents: 8f7f4d5
Author: nabarun <nn...@pivotal.io>
Authored: Mon Apr 4 14:31:02 2016 -0700
Committer: Jason Huynh <hu...@gmail.com>
Committed: Mon Apr 18 10:25:40 2016 -0700
----------------------------------------------------------------------
.../tier/sockets/DurableClientTestCase.java | 1 -
.../cache/wan/CacheClientNotifierDUnitTest.java | 2 +-
.../gemfire/internal/cache/wan/WANTestBase.java | 1853 +++---------------
...oncurrentParallelGatewaySenderDUnitTest.java | 38 +-
...allelGatewaySenderOperation_1_DUnitTest.java | 20 +-
...allelGatewaySenderOperation_2_DUnitTest.java | 25 +-
.../ConcurrentWANPropogation_1_DUnitTest.java | 16 +-
.../ConcurrentWANPropogation_2_DUnitTest.java | 29 +-
.../cache/wan/disttx/DistTXWANDUnitTest.java | 10 +-
.../CommonParallelGatewaySenderDUnitTest.java | 8 +-
...wWANConcurrencyCheckForDestroyDUnitTest.java | 18 +-
.../cache/wan/misc/PDXNewWanDUnitTest.java | 31 +-
...dRegion_ParallelWANPersistenceDUnitTest.java | 19 +-
...dRegion_ParallelWANPropogationDUnitTest.java | 51 +-
...downAllPersistentGatewaySenderDUnitTest.java | 4 +-
.../cache/wan/misc/WANSSLDUnitTest.java | 2 +-
.../cache/wan/misc/WanValidationsDUnitTest.java | 19 +-
...arallelGatewaySenderOperationsDUnitTest.java | 12 +-
...llelGatewaySenderQueueOverflowDUnitTest.java | 24 +-
.../ParallelWANConflationDUnitTest.java | 20 +-
...ersistenceEnabledGatewaySenderDUnitTest.java | 28 +-
...lelWANPropagationConcurrentOpsDUnitTest.java | 6 +-
.../ParallelWANPropagationDUnitTest.java | 47 +-
...ParallelWANPropagationLoopBackDUnitTest.java | 21 +-
.../wan/parallel/ParallelWANStatsDUnitTest.java | 18 +-
...tewaySenderDistributedDeadlockDUnitTest.java | 12 +-
...rialGatewaySenderEventListenerDUnitTest.java | 6 +-
.../SerialGatewaySenderOperationsDUnitTest.java | 25 +-
.../SerialGatewaySenderQueueDUnitTest.java | 6 +-
...ersistenceEnabledGatewaySenderDUnitTest.java | 14 +-
.../SerialWANPropagationLoopBackDUnitTest.java | 22 +-
.../serial/SerialWANPropogationDUnitTest.java | 110 +-
...NPropogation_PartitionedRegionDUnitTest.java | 16 +-
.../SerialWANPropogationsFeatureDUnitTest.java | 19 +-
.../wan/serial/SerialWANStatsDUnitTest.java | 49 +-
.../management/WANManagementDUnitTest.java | 6 +-
.../pulse/TestRemoteClusterDUnitTest.java | 2 +-
37 files changed, 569 insertions(+), 2040 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/84a4b474/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientTestCase.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientTestCase.java b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientTestCase.java
index 4d53146..563c9a7 100755
--- a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientTestCase.java
+++ b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DurableClientTestCase.java
@@ -1475,7 +1475,6 @@ public class DurableClientTestCase extends DistributedTestCase {
CountDownLatch clientConnected = new CountDownLatch(1);
public void doTestHook(String spot) {
- System.out.println("JASON " + spot);
try {
if (spot.equals("CLIENT_PRE_RECONNECT")) {
if (!reconnectLatch.await(60, TimeUnit.SECONDS)) {
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/84a4b474/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java
index 9557f0d..7406f2d 100755
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/CacheClientNotifierDUnitTest.java
@@ -178,7 +178,7 @@ public class CacheClientNotifierDUnitTest extends WANTestBase {
// create recever and cache servers will be at ny
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
vm1.invoke(() -> WANTestBase.createCache( nyPort ));
- int receiverPort = vm1.invoke(() -> WANTestBase.createReceiver( nyPort ));
+ int receiverPort = vm1.invoke(() -> WANTestBase.createReceiver());
checkCacheServer(vm1, receiverPort, false, 0);
// create PR for receiver