You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2016/08/16 21:33:56 UTC
[08/24] incubator-geode git commit: GEODE-1241: Fixed the misspelt
names in Geode WAN module
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
deleted file mode 100644
index c51c992..0000000
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogation_PartitionedRegionDUnitTest.java
+++ /dev/null
@@ -1,412 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package com.gemstone.gemfire.internal.cache.wan.serial;
-
-import org.junit.experimental.categories.Category;
-import org.junit.Test;
-
-import static org.junit.Assert.*;
-
-import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase;
-import com.gemstone.gemfire.test.dunit.internal.JUnit4DistributedTestCase;
-import com.gemstone.gemfire.test.junit.categories.DistributedTest;
-
-import org.junit.experimental.categories.Category;
-
-import com.gemstone.gemfire.CancelException;
-import com.gemstone.gemfire.cache.CacheClosedException;
-import com.gemstone.gemfire.internal.cache.ForceReattemptException;
-import com.gemstone.gemfire.internal.cache.wan.WANTestBase;
-import com.gemstone.gemfire.test.dunit.AsyncInvocation;
-import com.gemstone.gemfire.test.dunit.IgnoredException;
-import com.gemstone.gemfire.test.junit.categories.FlakyTest;
-
-@Category(DistributedTest.class)
-public class SerialWANPropogation_PartitionedRegionDUnitTest extends WANTestBase {
-
- private static final long serialVersionUID = 1L;
-
- public SerialWANPropogation_PartitionedRegionDUnitTest() {
- super();
- }
-
- @Test
- public void testPartitionedSerialPropagation() throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.startSender( "ln" ));
- //vm5.invoke(() -> WANTestBase.startSender( "ln" ));
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-
- @Test
- public void testBothReplicatedAndPartitionedSerialPropagation()
- throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
- 1000 ));
- vm5.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-
- @Test
- public void testSerialReplicatedAndPartitionedPropagation() throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "lnSerial",
- 2, false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "lnSerial",
- 2, false, 100, 10, false, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial", 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.startSender( "lnSerial" ));
- vm5.invoke(() -> WANTestBase.startSender( "lnSerial" ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
- 1000 ));
- vm5.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-
- @Test
- public void testSerialReplicatedAndSerialPartitionedPropagation()
- throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "lnSerial1",
- 2, false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "lnSerial1",
- 2, false, 100, 10, false, false, null, true ));
-
- vm5.invoke(() -> WANTestBase.createSender( "lnSerial2",
- 2, false, 100, 10, false, false, null, true ));
- vm6.invoke(() -> WANTestBase.createSender( "lnSerial2",
- 2, false, 100, 10, false, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial1", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial1", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial1", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "lnSerial1", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial2", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial2", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial2", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial2", 1, 100, isOffHeap() ));
-
- startSenderInVMs("lnSerial1", vm4, vm5);
-
- startSenderInVMs("lnSerial2", vm5, vm6);
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
- 1000 ));
- vm5.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-
- @Test
- public void testPartitionedSerialPropagationToTwoWanSites() throws Exception {
-
- Integer lnPort = createFirstLocatorWithDSId(1);
- Integer nyPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstRemoteLocator(2, lnPort ));
- Integer tkPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(3,lnPort ));
-
- createCacheInVMs(nyPort, vm2);
- vm2.invoke(() -> WANTestBase.createReceiver());
- createCacheInVMs(tkPort, vm3);
- vm3.invoke(() -> WANTestBase.createReceiver());
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "lnSerial1",
- 2, false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "lnSerial1",
- 2, false, 100, 10, false, false, null, true ));
-
- vm4.invoke(() -> WANTestBase.createSender( "lnSerial2",
- 3, false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "lnSerial2",
- 3, false, 100, 10, false, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- startSenderInVMs("lnSerial1", vm4, vm5);
- startSenderInVMs("lnSerial2", vm4, vm5);
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial1,lnSerial2", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial1,lnSerial2", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial1,lnSerial2", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "lnSerial1,lnSerial2", 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-
- @Test
- public void testPartitionedSerialPropagationHA() throws Exception {
- IgnoredException.addIgnoredException("Broken pipe");
- IgnoredException.addIgnoredException("Connection reset");
- IgnoredException.addIgnoredException("Unexpected IOException");
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- //do initial 100 puts to create all the buckets
- vm5.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 100 ));
-
- IgnoredException.addIgnoredException(CancelException.class.getName());
- IgnoredException.addIgnoredException(CacheClosedException.class.getName());
- IgnoredException.addIgnoredException(ForceReattemptException.class.getName());
- //start async puts
- AsyncInvocation inv = vm5.invokeAsync(() -> WANTestBase.doPuts( getTestMethodName() + "_PR", 1000 ));
- //close the cache on vm4 in between the puts
- vm4.invoke(() -> WANTestBase.killSender());
-
- inv.join();
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-
- @Test
- public void testPartitionedSerialPropagationWithParallelThreads() throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", "ln", 1, 100, isOffHeap() ));
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName() + "_PR", null, 1, 100, isOffHeap() ));
-
- createReceiverInVMs(vm2, vm3);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
-
- startSenderInVMs("ln", vm4, vm5);
-
-
-
- vm4.invoke(() -> WANTestBase.doMultiThreadedPuts( // TODO: eats exceptions
- getTestMethodName() + "_PR", 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_PR", 1000 ));
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
deleted file mode 100644
index f67639b..0000000
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPropogationsFeatureDUnitTest.java
+++ /dev/null
@@ -1,338 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package com.gemstone.gemfire.internal.cache.wan.serial;
-
-import org.junit.experimental.categories.Category;
-import org.junit.Test;
-
-import static org.junit.Assert.*;
-
-import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase;
-import com.gemstone.gemfire.test.dunit.internal.JUnit4DistributedTestCase;
-import com.gemstone.gemfire.test.junit.categories.DistributedTest;
-
-import com.gemstone.gemfire.internal.cache.wan.WANTestBase;
-
-
-@Category(DistributedTest.class)
-public class SerialWANPropogationsFeatureDUnitTest extends WANTestBase{
-
- private static final long serialVersionUID = 1L;
-
- public SerialWANPropogationsFeatureDUnitTest() {
- super();
- }
-
- @Test
- public void testSerialReplicatedWanWithOverflow() {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 10, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 10, 10, false, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
- vm2.invoke(() -> addListenerToSleepAfterCreateEvent(1000, getTestMethodName() + "_RR"));
- vm3.invoke(() -> addListenerToSleepAfterCreateEvent(1000, getTestMethodName() + "_RR"));
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doHeavyPuts(
- getTestMethodName() + "_RR", 15 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 15, 240000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 15, 240000 ));
- }
-
- @Test
- public void testSerialReplicatedWanWithPersistence() {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, true, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, true, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
-
- }
-
- @Test
- public void testReplicatedSerialPropagationWithConflation() throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 1000, true, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 1000, true, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR",
- 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- }
-
- @Test
- public void testReplicatedSerialPropagationWithParallelThreads()
- throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false, null, true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", null, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName() + "_RR", "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doMultiThreadedPuts(
- getTestMethodName() + "_RR", 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName() + "_RR", 1000 ));
- }
-
- @Test
- public void testSerialPropogationWithFilter() throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2,lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false,
- new MyGatewayEventFilter(), true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false,
- new MyGatewayEventFilter(), true ));
-
- vm4.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), "ln", 1, 100, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm2.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), null, 1, 100, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createPartitionedRegion(
- getTestMethodName(), null, 1, 100, isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName(), 800 ));
- }
-
- @Test
- public void testReplicatedSerialPropagationWithFilter() throws Exception {
-
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm2, vm3);
- createReceiverInVMs(vm2, vm3);
-
- createCacheInVMs(lnPort, vm4, vm5, vm6, vm7);
-
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false,
- new MyGatewayEventFilter(), true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2,
- false, 100, 10, false, false,
- new MyGatewayEventFilter(), true ));
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), null, isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), null, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
-
- vm2.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName(), 800 ));
- vm3.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName(), 800 ));
- }
-
- @Test
- public void testReplicatedSerialPropagationWithFilter_AfterAck()
- throws Exception {
- Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
- Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
-
- createCacheInVMs(nyPort, vm6, vm7);
- createReceiverInVMs(vm6, vm7);
-
- createCacheInVMs(lnPort, vm2, vm3, vm4, vm5);
- vm4.invoke(() -> WANTestBase.createSender( "ln", 2, false, 100, 10, false, false,
- new MyGatewayEventFilter_AfterAck(), true ));
- vm5.invoke(() -> WANTestBase.createSender( "ln", 2, false, 100, 10, false, false,
- new MyGatewayEventFilter_AfterAck(), true ));
-
- vm6.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), null, isOffHeap() ));
- vm7.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), null, isOffHeap() ));
-
- startSenderInVMs("ln", vm4, vm5);
-
- vm2.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
- vm3.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
- vm4.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
- vm5.invoke(() -> WANTestBase.createReplicatedRegion(
- getTestMethodName(), "ln", isOffHeap() ));
-
- vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName(), 1000 ));
-
- vm4.invoke(() -> WANTestBase.validateQueueContents( "ln",
- 0 ));
- vm5.invoke(() -> WANTestBase.validateQueueContents( "ln",
- 0 ));
-
- Integer vm4Acks = (Integer)vm4.invoke(() -> WANTestBase.validateAfterAck( "ln"));
- Integer vm5Acks = (Integer)vm5.invoke(() -> WANTestBase.validateAfterAck( "ln"));
-
- assertEquals(2000, (vm4Acks + vm5Acks));
-
- vm6.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName(), 1000 ));
- vm7.invoke(() -> WANTestBase.validateRegionSize(
- getTestMethodName(), 1000 ));
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANStatsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANStatsDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANStatsDUnitTest.java
index 8d6efe1..2019cac 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANStatsDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANStatsDUnitTest.java
@@ -21,8 +21,6 @@ import org.junit.Test;
import static org.junit.Assert.*;
-import com.gemstone.gemfire.test.dunit.cache.internal.JUnit4CacheTestCase;
-import com.gemstone.gemfire.test.dunit.internal.JUnit4DistributedTestCase;
import com.gemstone.gemfire.test.junit.categories.DistributedTest;
import static com.gemstone.gemfire.test.dunit.Wait.*;
@@ -288,7 +286,7 @@ public class SerialWANStatsDUnitTest extends WANTestBase {
}
@Test
- public void testReplicatedSerialPropagationUNPorcessedEvents() throws Exception {
+ public void testReplicatedSerialPropagationUnprocessedEvents() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 ));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort ));
@@ -372,7 +370,7 @@ public class SerialWANStatsDUnitTest extends WANTestBase {
* Not Disabled - see ticket #52118
*
* NOTE: The test failure is avoided by having a larger number of puts operation so
- * that WANTestBase.verifyRegionQueueNotEmpty("ln" )) is sucessful as there is a
+ * that WANTestBase.verifyRegionQueueNotEmpty("ln" )) is successful as there is a
* significant delay during the high number of puts.
*
* In future if this failure reappears, the put operations must be increase or a better fix must be found.
@@ -452,12 +450,12 @@ public class SerialWANStatsDUnitTest extends WANTestBase {
vm5.invoke(() -> WANTestBase.checkUnProcessedStats("ln", numEntries));
- vm2.invoke(() -> WANTestBase.checkExcepitonStats(1));
+ vm2.invoke(() -> WANTestBase.checkExceptionStats(1));
}
@Test
- public void testSerialPropogationWithFilter() throws Exception {
+ public void testSerialPropagationWithFilter() throws Exception {
Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1));
Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator(2,lnPort ));
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
index ec38b31..f9b46ef 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WANCommandTestBase.java
@@ -119,7 +119,7 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
public void createSender(String dsName, int remoteDsId,
boolean isParallel, Integer maxMemory,
Integer batchSize, boolean isConflation, boolean isPersistent,
- GatewayEventFilter filter, boolean isManulaStart) {
+ GatewayEventFilter filter, boolean isManualStart) {
File persistentDirectory = new File(dsName +"_disk_"+System.currentTimeMillis()+"_" + VM.getCurrentVMNum());
persistentDirectory.mkdir();
DiskStoreFactory dsf = cache.createDiskStoreFactory();
@@ -129,7 +129,7 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
gateway.setParallel(true);
gateway.setMaximumQueueMemory(maxMemory);
gateway.setBatchSize(batchSize);
- gateway.setManualStart(isManulaStart);
+ gateway.setManualStart(isManualStart);
if (filter != null) {
gateway.addGatewayEventFilter(filter);
}
@@ -148,7 +148,7 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
GatewaySenderFactory gateway = cache.createGatewaySenderFactory();
gateway.setMaximumQueueMemory(maxMemory);
gateway.setBatchSize(batchSize);
- gateway.setManualStart(isManulaStart);
+ gateway.setManualStart(isManualStart);
if (filter != null) {
gateway.addGatewayEventFilter(filter);
}
@@ -217,7 +217,7 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
receiver.start();
} catch (IOException e) {
e.printStackTrace();
- fail("Test " + getName() + " failed to start GatewayRecevier");
+ fail("Test " + getName() + " failed to start GatewayReceiver");
}
return port;
}
@@ -264,7 +264,7 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
}
} catch (IOException e) {
e.printStackTrace();
- fail("Test " + getName() + " failed to start GatewayRecevier");
+ fail("Test " + getName() + " failed to start GatewayReceiver");
}
}
@@ -294,7 +294,7 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
receiver.start();
} catch (IOException e) {
e.printStackTrace();
- fail("Test " + getName() + " failed to start GatewayRecevier on port " + port);
+ fail("Test " + getName() + " failed to start GatewayReceiver on port " + port);
}
return port;
}
@@ -386,14 +386,14 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
List<GatewayEventFilter> actualGatewayEventFilters = sender
.getGatewayEventFilters();
- List<String> actualEventFilterClassnames = new ArrayList<String>(
+ List<String> actualEventFilterClassNames = new ArrayList<String>(
actualGatewayEventFilters.size());
for (GatewayEventFilter filter : actualGatewayEventFilters) {
- actualEventFilterClassnames.add(filter.getClass().getName());
+ actualEventFilterClassNames.add(filter.getClass().getName());
}
for (String expectedGatewayEventFilter : expectedGatewayEventFilters) {
- if (!actualEventFilterClassnames.contains(expectedGatewayEventFilter)) {
+ if (!actualEventFilterClassNames.contains(expectedGatewayEventFilter)) {
fail("GatewayEventFilter " + expectedGatewayEventFilter
+ " is not added to the GatewaySender");
}
@@ -406,14 +406,14 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
.size(), sender.getGatewayTransportFilters().size());
List<GatewayTransportFilter> actualGatewayTransportFilters = sender
.getGatewayTransportFilters();
- List<String> actualTransportFilterClassnames = new ArrayList<String>(
+ List<String> actualTransportFilterClassNames = new ArrayList<String>(
actualGatewayTransportFilters.size());
for (GatewayTransportFilter filter : actualGatewayTransportFilters) {
- actualTransportFilterClassnames.add(filter.getClass().getName());
+ actualTransportFilterClassNames.add(filter.getClass().getName());
}
for (String expectedGatewayTransportFilter : expectedGatewayTransportFilters) {
- if (!actualTransportFilterClassnames
+ if (!actualTransportFilterClassNames
.contains(expectedGatewayTransportFilter)) {
fail("GatewayTransportFilter " + expectedGatewayTransportFilter
+ " is not added to the GatewaySender.");
@@ -451,14 +451,14 @@ public abstract class WANCommandTestBase extends CliCommandTestBase {
.size(), receiver.getGatewayTransportFilters().size());
List<GatewayTransportFilter> actualGatewayTransportFilters = receiver
.getGatewayTransportFilters();
- List<String> actualTransportFilterClassnames = new ArrayList<String>(
+ List<String> actualTransportFilterClassNames = new ArrayList<String>(
actualGatewayTransportFilters.size());
for (GatewayTransportFilter filter : actualGatewayTransportFilters) {
- actualTransportFilterClassnames.add(filter.getClass().getName());
+ actualTransportFilterClassNames.add(filter.getClass().getName());
}
for (String expectedGatewayTransportFilter : expectedGatewayTransportFilters) {
- if (!actualTransportFilterClassnames
+ if (!actualTransportFilterClassNames
.contains(expectedGatewayTransportFilter)) {
fail("GatewayTransportFilter " + expectedGatewayTransportFilter
+ " is not added to the GatewayReceiver.");
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
index 1a145cb..0c91f33 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandListDUnitTest.java
@@ -248,19 +248,19 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
vm6.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> createCacheWithGroups( lnPort, "Serial_Sender, Paralle_Sender"));
+ vm3.invoke(() -> createCacheWithGroups( lnPort, "Serial_Sender, Parallel_Sender"));
vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
- vm4.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender, Paralle_Sender"));
+ vm4.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender, Parallel_Sender"));
vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, false ));
- vm5.invoke(() -> createAndStartReceiverWithGroup( lnPort, "Paralle_Sender,Receiver_Group" ));
+ vm5.invoke(() -> createAndStartReceiverWithGroup( lnPort, "Parallel_Sender,Receiver_Group" ));
vm5.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, false ));
@@ -291,7 +291,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
fail("testListGatewaySenderGatewayReceiver_group failed as did not get CommandResult");
}
- command = CliStrings.LIST_GATEWAY + " --" + CliStrings.LIST_GATEWAY__GROUP + "=Paralle_Sender";
+ command = CliStrings.LIST_GATEWAY + " --" + CliStrings.LIST_GATEWAY__GROUP + "=Parallel_Sender";
cmdResult = executeCommand(command);
if (cmdResult != null) {
TabularResultData tableSenderResultData =
@@ -334,7 +334,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
fail("testListGatewaySenderGatewayReceiver_group failed as did not get CommandResult");
}
- command = CliStrings.LIST_GATEWAY + " --" + CliStrings.LIST_GATEWAY__GROUP + "=Serial_Sender,Paralle_Sender";
+ command = CliStrings.LIST_GATEWAY + " --" + CliStrings.LIST_GATEWAY__GROUP + "=Serial_Sender,Parallel_Sender";
cmdResult = executeCommand(command);
if (cmdResult != null) {
String strCmdResult = commandResultToString(cmdResult);
@@ -355,7 +355,7 @@ public class WanCommandListDUnitTest extends WANCommandTestBase {
fail("testListGatewaySenderGatewayReceiver_group failed as did not get CommandResult");
}
- command = CliStrings.LIST_GATEWAY + " --" + CliStrings.LIST_GATEWAY__GROUP + "=Serial_Sender,Paralle_Sender,Receiver_Group";
+ command = CliStrings.LIST_GATEWAY + " --" + CliStrings.LIST_GATEWAY__GROUP + "=Serial_Sender,Parallel_Sender,Receiver_Group";
cmdResult = executeCommand(command);
if (cmdResult != null) {
String strCmdResult = commandResultToString(cmdResult);
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
index 362df80..9271614 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/wancommand/WanCommandStatusDUnitTest.java
@@ -245,19 +245,19 @@ public class WanCommandStatusDUnitTest extends WANCommandTestBase{
vm7.invoke(() -> createAndStartReceiver( nyPort ));
- vm3.invoke(() -> createCacheWithGroups( lnPort, "Serial_Sender, Paralle_Sender"));
+ vm3.invoke(() -> createCacheWithGroups( lnPort, "Serial_Sender, Parallel_Sender"));
vm3.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true ));
vm3.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm4.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender, Paralle_Sender"));
+ vm4.invoke(() -> createCacheWithGroups( lnPort,"Serial_Sender, Parallel_Sender"));
vm4.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
vm4.invoke(() -> createSender(
"ln_Parallel", 2, true, 100, 400, false, false, null, true));
- vm5.invoke(() -> createCacheWithGroups( lnPort,"Paralle_Sender"));
+ vm5.invoke(() -> createCacheWithGroups( lnPort,"Parallel_Sender"));
vm5.invoke(() -> createSender(
"ln_Serial", 2, false, 100, 400, false, false, null, true));
vm5.invoke(() -> createSender(
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/management/WANManagementDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/management/WANManagementDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/management/WANManagementDUnitTest.java
index 4d17d9b..c21cf26 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/management/WANManagementDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/management/WANManagementDUnitTest.java
@@ -404,7 +404,7 @@ public class WANManagementDUnitTest extends ManagementTestBase {
/**
- * Checks whether a GatewayreceiverMBean is created or not
+ * Checks whether a GatewayReceiverMBean is created or not
*
* @param vm
* reference to VM
@@ -424,7 +424,7 @@ public class WANManagementDUnitTest extends ManagementTestBase {
}
/**
- * Checks whether a GatewayreceiverMBean is created or not
+ * Checks whether a GatewayReceiverMBean is created or not
*
* @param vm
* reference to VM
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
index 692f92f..bdd5d71 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/configuration/ClusterConfigurationDUnitTest.java
@@ -200,7 +200,7 @@ public class ClusterConfigurationDUnitTest extends CliCommandTestBase {
Region region3 = cache.getRegion(DESTROY_REGION);
assertNull(region3);
- //Index verfication
+ //Index verification
Index index1 = cache.getQueryService().getIndex(region1, INDEX1);
assertNotNull(index1);
assertNull(cache.getQueryService().getIndex(region2, INDEX2));
@@ -327,7 +327,7 @@ public class ClusterConfigurationDUnitTest extends CliCommandTestBase {
/**
* Tests for {@link Extension}, {@link Extensible}, {@link XmlParser},
* {@link XmlGenerator}, {@link XmlEntity} as it applies to Extensions.
- * Asserts that Mock Entension is created and destroyed on region and cache.
+ * Asserts that Mock Extension is created and destroyed on region and cache.
*
* @since GemFire 8.1
*/
@@ -402,7 +402,7 @@ public class ClusterConfigurationDUnitTest extends CliCommandTestBase {
final String diskDirs = "dir1";
//final String
- //createPersistentRegion(persRegion, RegionShortcut.PARTITION_PERSISTENT, "", diskStoreName);
+ //createPersistentRegion(peersRegion, RegionShortcut.PARTITION_PERSISTENT, "", diskStoreName);
final String autoCompact = "true";
final String allowForceCompaction = "true";
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/pulse/TestRemoteClusterDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/pulse/TestRemoteClusterDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/pulse/TestRemoteClusterDUnitTest.java
index 22294ee..4829523 100644
--- a/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/pulse/TestRemoteClusterDUnitTest.java
+++ b/geode-wan/src/test/java/com/gemstone/gemfire/management/internal/pulse/TestRemoteClusterDUnitTest.java
@@ -221,7 +221,7 @@ public class TestRemoteClusterDUnitTest extends ManagementTestBase {
}
/**
- * Checks whether a GatewayreceiverMBean is created or not
+ * Checks whether a GatewayReceiverMBean is created or not
*
* @param vm
* reference to VM
@@ -242,7 +242,7 @@ public class TestRemoteClusterDUnitTest extends ManagementTestBase {
}
/**
- * Checks whether a GatewayreceiverMBean is created or not
+ * Checks whether a GatewayReceiverMBean is created or not
*
* @param vm reference to VM
*/