http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropagationOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropagationOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropagationOffHeapDUnitTest.java new file mode 100644 index 0000000..b08b5c2 --- /dev/null +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropagationOffHeapDUnitTest.java @@ -0,0 +1,43 @@ +/* + * 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.offheap; + +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.parallel.ParallelWANPropagationDUnitTest; + +@SuppressWarnings("serial") +@Category(DistributedTest.class) +public class ParallelWANPropagationOffHeapDUnitTest extends ParallelWANPropagationDUnitTest { + + public ParallelWANPropagationOffHeapDUnitTest() { + super(); + } + + @Override + public boolean isOffHeap() { + return true; + } + +}
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationConcurrentOpsOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationConcurrentOpsOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationConcurrentOpsOffHeapDUnitTest.java deleted file mode 100644 index aa74fa8..0000000 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationConcurrentOpsOffHeapDUnitTest.java +++ /dev/null @@ -1,44 +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.offheap; - -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.parallel.ParallelWANPropagationConcurrentOpsDUnitTest; - -@SuppressWarnings("serial") -@Category(DistributedTest.class) -public class ParallelWANPropogationConcurrentOpsOffHeapDUnitTest extends - ParallelWANPropagationConcurrentOpsDUnitTest { - - public ParallelWANPropogationConcurrentOpsOffHeapDUnitTest() { - super(); - } - - @Override - public boolean isOffHeap() { - return true; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationOffHeapDUnitTest.java deleted file mode 100644 index 4a77012..0000000 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/ParallelWANPropogationOffHeapDUnitTest.java +++ /dev/null @@ -1,43 +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.offheap; - -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.parallel.ParallelWANPropagationDUnitTest; - -@SuppressWarnings("serial") -@Category(DistributedTest.class) -public class ParallelWANPropogationOffHeapDUnitTest extends ParallelWANPropagationDUnitTest { - - public ParallelWANPropogationOffHeapDUnitTest() { - super(); - } - - @Override - public boolean isOffHeap() { - return true; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagationOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagationOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagationOffHeapDUnitTest.java new file mode 100644 index 0000000..d6cecd1 --- /dev/null +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagationOffHeapDUnitTest.java @@ -0,0 +1,38 @@ +/* + * 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.offheap; + +import org.junit.experimental.categories.Category; + +import com.gemstone.gemfire.test.junit.categories.DistributedTest; + +import com.gemstone.gemfire.internal.cache.wan.serial.SerialWANPropagationDUnitTest; + +@SuppressWarnings("serial") +@Category(DistributedTest.class) +public class SerialWANPropagationOffHeapDUnitTest extends SerialWANPropagationDUnitTest { + + public SerialWANPropagationOffHeapDUnitTest() { + super(); + } + + @Override + public boolean isOffHeap() { + return true; + } + +} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagation_PartitionedRegionOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagation_PartitionedRegionOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagation_PartitionedRegionOffHeapDUnitTest.java new file mode 100644 index 0000000..4abd6e6 --- /dev/null +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropagation_PartitionedRegionOffHeapDUnitTest.java @@ -0,0 +1,39 @@ +/* + * 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.offheap; + +import org.junit.experimental.categories.Category; + +import com.gemstone.gemfire.test.junit.categories.DistributedTest; + +import com.gemstone.gemfire.internal.cache.wan.serial.SerialWANPropagation_PartitionedRegionDUnitTest; + +@SuppressWarnings("serial") +@Category(DistributedTest.class) +public class SerialWANPropagation_PartitionedRegionOffHeapDUnitTest + extends SerialWANPropagation_PartitionedRegionDUnitTest { + + public SerialWANPropagation_PartitionedRegionOffHeapDUnitTest() { + super(); + } + + @Override + public boolean isOffHeap() { + return true; + } + +} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogationOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogationOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogationOffHeapDUnitTest.java deleted file mode 100644 index 625d028..0000000 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogationOffHeapDUnitTest.java +++ /dev/null @@ -1,43 +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.offheap; - -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.serial.SerialWANPropogationDUnitTest; - -@SuppressWarnings("serial") -@Category(DistributedTest.class) -public class SerialWANPropogationOffHeapDUnitTest extends SerialWANPropogationDUnitTest { - - public SerialWANPropogationOffHeapDUnitTest() { - super(); - } - - @Override - public boolean isOffHeap() { - return true; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogation_PartitionedRegionOffHeapDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogation_PartitionedRegionOffHeapDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogation_PartitionedRegionOffHeapDUnitTest.java deleted file mode 100644 index d755404..0000000 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/offheap/SerialWANPropogation_PartitionedRegionOffHeapDUnitTest.java +++ /dev/null @@ -1,43 +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.offheap; - -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.serial.SerialWANPropogation_PartitionedRegionDUnitTest; - -@SuppressWarnings("serial") -@Category(DistributedTest.class) -public class SerialWANPropogation_PartitionedRegionOffHeapDUnitTest extends SerialWANPropogation_PartitionedRegionDUnitTest { - - public SerialWANPropogation_PartitionedRegionOffHeapDUnitTest() { - super(); - } - - @Override - public boolean isOffHeap() { - return true; - } - -} http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueueOverflowDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueueOverflowDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueueOverflowDUnitTest.java index 44308f8..a248520 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueueOverflowDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelGatewaySenderQueueOverflowDUnitTest.java @@ -414,12 +414,12 @@ public class ParallelGatewaySenderQueueOverflowDUnitTest extends WANTestBase { fact.setDiskStoreName("FORNY"); fact.setMaximumQueueMemory(200); fact.setAlertThreshold(1200); - GatewayEventFilter myeventfilter1 = new MyGatewayEventFilter1(); - fact.addGatewayEventFilter(myeventfilter1); - GatewayTransportFilter myStreamfilter1 = new MyGatewayTransportFilter1(); - fact.addGatewayTransportFilter(myStreamfilter1); - GatewayTransportFilter myStreamfilter2 = new MyGatewayTransportFilter2(); - fact.addGatewayTransportFilter(myStreamfilter2); + GatewayEventFilter myEventFilter1 = new MyGatewayEventFilter1(); + fact.addGatewayEventFilter(myEventFilter1); + GatewayTransportFilter myStreamFilter1 = new MyGatewayTransportFilter1(); + fact.addGatewayTransportFilter(myStreamFilter1); + GatewayTransportFilter myStreamFilter2 = new MyGatewayTransportFilter2(); + fact.addGatewayTransportFilter(myStreamFilter2); final IgnoredException exTKSender = IgnoredException.addIgnoredException("Could not connect"); try { GatewaySender sender1 = fact.create("TKSender", 2); @@ -470,12 +470,12 @@ public class ParallelGatewaySenderQueueOverflowDUnitTest extends WANTestBase { fact.setDiskSynchronous(true); fact.setMaximumQueueMemory(200); fact.setAlertThreshold(1200); - GatewayEventFilter myeventfilter1 = new MyGatewayEventFilter1(); - fact.addGatewayEventFilter(myeventfilter1); - GatewayTransportFilter myStreamfilter1 = new MyGatewayTransportFilter1(); - fact.addGatewayTransportFilter(myStreamfilter1); - GatewayTransportFilter myStreamfilter2 = new MyGatewayTransportFilter2(); - fact.addGatewayTransportFilter(myStreamfilter2); + GatewayEventFilter myEventFilter1 = new MyGatewayEventFilter1(); + fact.addGatewayEventFilter(myEventFilter1); + GatewayTransportFilter myStreamFilter1 = new MyGatewayTransportFilter1(); + fact.addGatewayTransportFilter(myStreamFilter1); + GatewayTransportFilter myStreamFilter2 = new MyGatewayTransportFilter2(); + fact.addGatewayTransportFilter(myStreamFilter2); final IgnoredException ex = IgnoredException.addIgnoredException("Could not connect"); try { GatewaySender sender1 = fact.create("TKSender", 2); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANConflationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANConflationDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANConflationDUnitTest.java index d73ac17..87a74b9 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANConflationDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANConflationDUnitTest.java @@ -80,7 +80,7 @@ public class ParallelWANConflationDUnitTest extends WANTestBase { } /** - * This test is desabled as it is not guaranteed to pass it everytime. This + * This test is disabled as it is not guaranteed to pass it everytime. This * test is related to the conflation in batch. yet did find any way to * ascertain that the vents in the batch will always be conflated. * @@ -292,7 +292,7 @@ public class ParallelWANConflationDUnitTest extends WANTestBase { // //This is the same as the previous test, except for the UsingCustId methods @Test - public void testParallelPropagationColoatedRegionConflationSameKey() + public void testParallelPropagationColocatedRegionConflationSameKey() throws Exception { initialSetUp(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java index be3c42d..359a56d 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPersistenceEnabledGatewaySenderDUnitTest.java @@ -73,10 +73,10 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTest AttributesFactory rFact = new AttributesFactory(); rFact.addGatewaySenderId(sender1.getId()); - PartitionAttributesFactory pfact = new PartitionAttributesFactory(); - pfact.setTotalNumBuckets(100); - pfact.setRedundantCopies(1); - rFact.setPartitionAttributes(pfact.create()); + PartitionAttributesFactory pFact = new PartitionAttributesFactory(); + pFact.setTotalNumBuckets(100); + pFact.setRedundantCopies(1); + rFact.setPartitionAttributes(pFact.create()); Region r = cache.createRegionFactory(rFact.create()).create("MyRegion"); sender1.start(); } finally { @@ -85,7 +85,7 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTest } catch (Exception e) { - fail("UnExpectd Exception :" + e); + fail("Unexpected Exception :" + e); } } @@ -1450,7 +1450,7 @@ public class ParallelWANPersistenceEnabledGatewaySenderDUnitTest extends WANTest * This test is added for defect # 45747. */ @Test - public void testParallelPropagationWithSenderPerisistenceEnabledForAccessor() { + public void testParallelPropagationWithSenderPersistenceEnabledForAccessor() { //create locator on local site Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); //create locator on remote site http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationConcurrentOpsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationConcurrentOpsDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationConcurrentOpsDUnitTest.java index f55a1eb..427054a 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationConcurrentOpsDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationConcurrentOpsDUnitTest.java @@ -113,7 +113,7 @@ public class ParallelWANPropagationConcurrentOpsDUnitTest extends WANTestBase { * @throws Exception */ @Test - public void testParallelPropagationWithLowNumberofBuckets() throws Exception { + public void testParallelPropagationWithLowNumberOfBuckets() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); @@ -159,7 +159,7 @@ public class ParallelWANPropagationConcurrentOpsDUnitTest extends WANTestBase { } @Test - public void testParalleQueueDrainInOrder_PR() throws Exception { + public void testParallelQueueDrainInOrder_PR() 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/parallel/ParallelWANPropagationDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java index 804da23..7b0cf3e 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANPropagationDUnitTest.java @@ -551,7 +551,7 @@ public class ParallelWANPropagationDUnitTest extends WANTestBase { } @Test - public void testSerialReplicatedAndParallePartitionedPropagation() + public void testSerialReplicatedAndParallelPartitionedPropagation() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java index 1f855c1..b754254 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/parallel/ParallelWANStatsDUnitTest.java @@ -91,7 +91,7 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{ } @Test - public void testPartitionedRegionParallelPropagation_AfterDispatch_NoRedundacny() throws Exception { + public void testPartitionedRegionParallelPropagation_AfterDispatch_NoRedundancy() throws Exception { Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); @@ -274,7 +274,7 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{ * @throws Exception */ @Test - public void testParallePropagationWithRemoteRegionDestroy() throws Exception { + public void testParallelPropagationWithRemoteRegionDestroy() throws Exception { addIgnoredException("RegionDestroyedException"); Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); @@ -310,7 +310,7 @@ public class ParallelWANStatsDUnitTest extends WANTestBase{ } @Test - public void testParallelPropogationWithFilter() throws Exception { + public void testParallelPropagationWithFilter() 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/serial/SerialGatewaySenderDistributedDeadlockDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderDistributedDeadlockDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderDistributedDeadlockDUnitTest.java index 2595275..b38d35b 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderDistributedDeadlockDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderDistributedDeadlockDUnitTest.java @@ -266,26 +266,26 @@ public class SerialGatewaySenderDistributedDeadlockDUnitTest extends WANTestBase //exercise region and gateway operations vm4.invoke(() -> WANTestBase.doPuts(getTestMethodName() + "_RR", 100)); vm5.invoke(() -> WANTestBase.doPuts(getTestMethodName() + "_RR", 100)); - Wait.pause(2000); //wait for events to propogate + Wait.pause(2000); //wait for events to propagate vm4.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 100)); vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 100)); vm5.invoke(() -> WANTestBase.doDestroys(getTestMethodName() + "_RR", 100)); - Wait.pause(2000);//wait for events to propogate + Wait.pause(2000);//wait for events to propagate vm5.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 0)); vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 0)); vm4.invoke(() -> WANTestBase.doPuts(getTestMethodName() + "_RR", 100)); vm5.invoke(() -> WANTestBase.doPuts(getTestMethodName() + "_RR", 100)); - Wait.pause(2000); //wait for events to propogate + Wait.pause(2000); //wait for events to propagate vm4.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 100)); vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 100)); vm4.invoke(() -> SerialGatewaySenderDistributedDeadlockDUnitTest.doInvalidates(getTestMethodName() + "_RR", 100, 100)); vm4.invoke(() -> WANTestBase.doPutAll(getTestMethodName() + "_RR", 100, 10)); vm5.invoke(() -> WANTestBase.doPutAll(getTestMethodName() + "_RR", 100, 10)); - Wait.pause(2000);//wait for events to propogate + Wait.pause(2000);//wait for events to propagate vm4.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 1000)); vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 1000)); vm4.invoke(() -> WANTestBase.doDestroys(getTestMethodName() + "_RR", 1000)); - Wait.pause(2000);//wait for events to propogate + Wait.pause(2000);//wait for events to propagate vm5.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 0)); vm2.invoke(() -> WANTestBase.validateRegionSize(getTestMethodName() + "_RR", 0)); vm4.invoke(() -> WANTestBase.doPutsPDXSerializable(getTestMethodName() + "_RR", 100)); @@ -357,7 +357,7 @@ public class SerialGatewaySenderDistributedDeadlockDUnitTest extends WANTestBase if (r.containsValueForKey(temp)) { r.invalidate(temp); } - } catch (com.gemstone.gemfire.cache.EntryNotFoundException enfe) { + } catch (com.gemstone.gemfire.cache.EntryNotFoundException entryNotFoundException) { //ignore as an entry may not exist } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java index cb55a2a..56d2bcc 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java @@ -162,7 +162,7 @@ public class SerialGatewaySenderEventListenerDUnitTest extends WANTestBase { /** * Test validates whether the listener attached receives all the events. - * When there are 2 listeners attcahed to the GatewaySender. + * When there are 2 listeners attached to the GatewaySender. */ @Category(FlakyTest.class) // GEODE-1066: random ports, waitForCriterion, time sensitive @Test @@ -215,7 +215,7 @@ public class SerialGatewaySenderEventListenerDUnitTest extends WANTestBase { } /** - * Test vaildates whether the PoolImpl is created. Ideally when a listener is attached + * Test validates whether the PoolImpl is created. Ideally when a listener is attached * pool should not be created. */ @Test http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java index 2e796e7..200e5b6 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderOperationsDUnitTest.java @@ -590,14 +590,14 @@ public class SerialGatewaySenderOperationsDUnitTest extends WANTestBase { SerializableRunnable check = new SerializableRunnable("assert no cache servers") { public void run() { InternalLocator inl = (InternalLocator)Locator.getLocator(); - ServerLocator servel = inl.getServerLocatorAdvisee(); - LogWriterUtils.getLogWriter().info("Server load map is " + servel.getLoadMap()); - assertTrue("expected an empty map but found " + servel.getLoadMap(), - servel.getLoadMap().isEmpty()); + ServerLocator server = inl.getServerLocatorAdvisee(); + LogWriterUtils.getLogWriter().info("Server load map is " + server.getLoadMap()); + assertTrue("expected an empty map but found " + server.getLoadMap(), + server.getLoadMap().isEmpty()); QueueConnectionRequest request = new QueueConnectionRequest( ClientProxyMembershipID.getNewProxyMembership(InternalDistributedSystem.getConnectedInstance()), 1, new HashSet<>(), "", false); - QueueConnectionResponse response = (QueueConnectionResponse)servel.processRequest(request); + QueueConnectionResponse response = (QueueConnectionResponse)server.processRequest(request); assertTrue("expected no servers but found " + response.getServers(), response.getServers().isEmpty()); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java index 7776402..411396b 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderQueueDUnitTest.java @@ -134,7 +134,7 @@ public class SerialGatewaySenderQueueDUnitTest extends WANTestBase { assertEquals(primarySenderUpdates.get("Destroy"), receiverUpdates.get("Create")); Wait.pause(5000); - // We expect that after this much time secondary would have got batchremoval message + // We expect that after this much time secondary would have got batch removal message // removing all the keys. secondarySenderUpdates = (HashMap)vm5.invoke(() -> WANTestBase.checkQueue()); assertEquals(secondarySenderUpdates.get("Destroy"), receiverUpdates.get("Create")); @@ -240,12 +240,12 @@ public class SerialGatewaySenderQueueDUnitTest extends WANTestBase { fact.setDiskStoreName("FORNY"); fact.setMaximumQueueMemory(200); fact.setAlertThreshold(1200); - GatewayEventFilter myeventfilter1 = new MyGatewayEventFilter1(); - fact.addGatewayEventFilter(myeventfilter1); - GatewayTransportFilter myStreamfilter1 = new MyGatewayTransportFilter1(); - fact.addGatewayTransportFilter(myStreamfilter1); - GatewayTransportFilter myStreamfilter2 = new MyGatewayTransportFilter2(); - fact.addGatewayTransportFilter(myStreamfilter2); + GatewayEventFilter myEventFilter1 = new MyGatewayEventFilter1(); + fact.addGatewayEventFilter(myEventFilter1); + GatewayTransportFilter myStreamFilter1 = new MyGatewayTransportFilter1(); + fact.addGatewayTransportFilter(myStreamFilter1); + GatewayTransportFilter myStreamFilter2 = new MyGatewayTransportFilter2(); + fact.addGatewayTransportFilter(myStreamFilter2); final IgnoredException exTKSender = IgnoredException.addIgnoredException("Could not connect"); try { GatewaySender sender1 = fact.create("TKSender", 2); @@ -294,12 +294,12 @@ public class SerialGatewaySenderQueueDUnitTest extends WANTestBase { fact.setDiskSynchronous(true); fact.setMaximumQueueMemory(200); fact.setAlertThreshold(1200); - GatewayEventFilter myeventfilter1 = new MyGatewayEventFilter1(); - fact.addGatewayEventFilter(myeventfilter1); - GatewayTransportFilter myStreamfilter1 = new MyGatewayTransportFilter1(); - fact.addGatewayTransportFilter(myStreamfilter1); - GatewayTransportFilter myStreamfilter2 = new MyGatewayTransportFilter2(); - fact.addGatewayTransportFilter(myStreamfilter2); + GatewayEventFilter myEventFilter1 = new MyGatewayEventFilter1(); + fact.addGatewayEventFilter(myEventFilter1); + GatewayTransportFilter myStreamFilter1 = new MyGatewayTransportFilter1(); + fact.addGatewayTransportFilter(myStreamFilter1); + GatewayTransportFilter myStreamFilter2 = new MyGatewayTransportFilter2(); + fact.addGatewayTransportFilter(myStreamFilter2); final IgnoredException exp = IgnoredException.addIgnoredException("Could not connect"); try { GatewaySender sender1 = fact.create("TKSender", 2); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f37769c/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java index bd4555f..7664ab4 100644 --- a/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java +++ b/geode-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialWANPersistenceEnabledGatewaySenderDUnitTest.java @@ -240,11 +240,11 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends vm4.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, false, 100, 10, false, true, null, firstDStore, true )); - LogWriterUtils.getLogWriter().info("Creted the sender.... in vm4 "); + LogWriterUtils.getLogWriter().info("Created the sender.... in vm4 "); vm5.invoke(() -> WANTestBase.createSenderWithDiskStore( "ln", 2, false, 100, 10, false, true, null, secondDStore, true )); - LogWriterUtils.getLogWriter().info("Creted the sender.... in vm5 "); + LogWriterUtils.getLogWriter().info("Created the sender.... in vm5 "); AsyncInvocation inv1 = vm4.invokeAsync(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Started the sender in vm 4"); @@ -343,7 +343,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends try { inv1.join(); } catch (InterruptedException e) { - fail("Got interrupted exception while waiting for startSedner to finish."); + fail("Got interrupted exception while waiting for startSender to finish."); } Wait.pause(5000); @@ -421,10 +421,10 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends vm5.invoke(() -> WANTestBase.createCache( lnPort )); vm4.invoke(() -> WANTestBase.createSender( "ln", 2, false, 100, 10, false, false, null, true)); - LogWriterUtils.getLogWriter().info("Creted the sender.... in vm4 "); + LogWriterUtils.getLogWriter().info("Created the sender.... in vm4 "); vm5.invoke(() -> WANTestBase.createSender( "ln", 2, false, 100, 10, false, false, null, true)); - LogWriterUtils.getLogWriter().info("Creted the sender.... in vm5 "); + LogWriterUtils.getLogWriter().info("Created the sender.... in vm5 "); vm4.invoke(() -> WANTestBase.startSender( "ln" )); LogWriterUtils.getLogWriter().info("Started the sender in vm 4"); @@ -440,7 +440,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends try { inv1.join(); } catch (InterruptedException e) { - fail("Got interrupted exception while waiting for startSedner to finish."); + fail("Got interrupted exception while waiting for startSender to finish."); } Wait.pause(5000); @@ -533,7 +533,7 @@ public class SerialWANPersistenceEnabledGatewaySenderDUnitTest extends try { inv1.join(); } catch (InterruptedException e) { - fail("Got interrupted exception while waiting for startSedner to finish."); + fail("Got interrupted exception while waiting for startSender to finish."); } Wait.pause(5000);
