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/06/09 17:05:20 UTC
[03/51] [partial] incubator-geode git commit: GEODE-837: update tests
from JUnit3 to JUnit4
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/b914df23/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/PRDeltaPropagationDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/PRDeltaPropagationDUnitTest.java b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/PRDeltaPropagationDUnitTest.java
index 8614a80..c178454 100755
--- a/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/PRDeltaPropagationDUnitTest.java
+++ b/geode-cq/src/test/java/com/gemstone/gemfire/internal/cache/PRDeltaPropagationDUnitTest.java
@@ -16,9 +16,34 @@
*/
package com.gemstone.gemfire.internal.cache;
+import static com.gemstone.gemfire.distributed.DistributedSystemConfigProperties.*;
+import static org.junit.Assert.*;
+
+import java.io.DataInput;
+import java.io.DataOutput;
+import java.io.IOException;
+import java.util.Properties;
+
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
import com.gemstone.gemfire.Delta;
import com.gemstone.gemfire.DeltaTestImpl;
-import com.gemstone.gemfire.cache.*;
+import com.gemstone.gemfire.cache.AttributesFactory;
+import com.gemstone.gemfire.cache.AttributesMutator;
+import com.gemstone.gemfire.cache.Cache;
+import com.gemstone.gemfire.cache.CacheFactory;
+import com.gemstone.gemfire.cache.DataPolicy;
+import com.gemstone.gemfire.cache.EntryEvent;
+import com.gemstone.gemfire.cache.ExpirationAction;
+import com.gemstone.gemfire.cache.ExpirationAttributes;
+import com.gemstone.gemfire.cache.InterestPolicy;
+import com.gemstone.gemfire.cache.PartitionAttributes;
+import com.gemstone.gemfire.cache.PartitionAttributesFactory;
+import com.gemstone.gemfire.cache.Region;
+import com.gemstone.gemfire.cache.RegionAttributes;
+import com.gemstone.gemfire.cache.Scope;
+import com.gemstone.gemfire.cache.SubscriptionAttributes;
import com.gemstone.gemfire.cache.client.PoolManager;
import com.gemstone.gemfire.cache.client.internal.PoolImpl;
import com.gemstone.gemfire.cache.query.CqAttributes;
@@ -35,27 +60,24 @@ import com.gemstone.gemfire.internal.AvailablePort;
import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientNotifier;
import com.gemstone.gemfire.internal.cache.tier.sockets.CacheClientProxy;
import com.gemstone.gemfire.internal.cache.tier.sockets.ConflationDUnitTest;
-import com.gemstone.gemfire.test.dunit.*;
-
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.IOException;
-import java.util.Properties;
-
-import static com.gemstone.gemfire.distributed.DistributedSystemConfigProperties.LOCATORS;
-import static com.gemstone.gemfire.distributed.DistributedSystemConfigProperties.MCAST_PORT;
+import com.gemstone.gemfire.test.dunit.Assert;
+import com.gemstone.gemfire.test.dunit.Host;
+import com.gemstone.gemfire.test.dunit.LogWriterUtils;
+import com.gemstone.gemfire.test.dunit.SerializableRunnable;
+import com.gemstone.gemfire.test.dunit.VM;
+import com.gemstone.gemfire.test.dunit.Wait;
+import com.gemstone.gemfire.test.dunit.WaitCriterion;
+import com.gemstone.gemfire.test.dunit.internal.JUnit4DistributedTestCase;
+import com.gemstone.gemfire.test.junit.categories.DistributedTest;
/**
- *
* Tests the PR delta propagation functionality.
- *
*/
-public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
+@Category(DistributedTest.class)
+public class PRDeltaPropagationDUnitTest extends JUnit4DistributedTestCase {
private final static Compressor compressor = SnappyCompressor.getDefaultInstance();
- private static final long serialVersionUID = 1L;
-
protected static Cache cache = null;
protected static VM dataStore1 = null;
@@ -93,7 +115,6 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
/*
* cq
*/
- //private static final String CQ = "SELECT * FROM "+Region.SEPARATOR+REGION_NAME;
private static final String CQ = "SELECT * FROM "+Region.SEPARATOR+REGION_NAME + " p where p.intVar < 9";
private static int numValidCqEvents = 0;
@@ -102,10 +123,6 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
private static boolean queryDestroyExecuted = false;
private static boolean notADeltaInstanceObj = false;
- public PRDeltaPropagationDUnitTest(String name) {
- super(name);
- }
-
@Override
public final void postSetUp() throws Exception {
Host host = Host.getHost(0);
@@ -121,12 +138,12 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * 1) Put delta objects on accessor node.
- * 2) From accessor to primary delta gets propagated as part of <code>PutMessage</code> delta.
- * 3) From primary to secondary delta gets propagated as part RR distribution.
- *
+ * 1) Put delta objects on accessor node.
+ * 2) From accessor to primary delta gets propagated as part of <code>PutMessage</code> delta.
+ * 3) From primary to secondary delta gets propagated as part RR distribution.
*/
- public void testDeltaPropagationForPR() throws Throwable {
+ @Test
+ public void testDeltaPropagationForPR() throws Exception {
createCacheInAllPRVms();
createDeltaPR(Boolean.FALSE);
put();
@@ -136,10 +153,11 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * Monitor number of times constructor is called
- * Without copy or cloning, we should have 1 instance
+ * Monitor number of times constructor is called
+ * Without copy or cloning, we should have 1 instance
*/
- public void testConstructorCountWithoutCloning() throws Throwable {
+ @Test
+ public void testConstructorCountWithoutCloning() throws Exception {
clearConstructorCounts();
createCacheInAllPRVms();
@@ -156,11 +174,12 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * Monitor number of times constructor is called
- * With cloning, we should have more than 1 instance
- * on members receiving delta updates
+ * Monitor number of times constructor is called
+ * With cloning, we should have more than 1 instance
+ * on members receiving delta updates
*/
- public void testConstructorCountWithCloning() throws Throwable {
+ @Test
+ public void testConstructorCountWithCloning() throws Exception {
clearConstructorCounts();
createCacheInAllPRVms();
@@ -178,10 +197,11 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * Create partition with cloning disabled, then
- * enable cloning and verify proper operation
+ * Create partition with cloning disabled, then
+ * enable cloning and verify proper operation
*/
- public void testConstructorCountWithMutator() throws Throwable {
+ @Test
+ public void testConstructorCountWithMutator() throws Exception {
clearConstructorCounts();
createCacheInAllPRVms();
@@ -238,7 +258,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
assertFalse(copy);
}
- private void clearConstructorCounts() throws Throwable {
+ private void clearConstructorCounts() throws Exception {
setBuildCount(0);
dataStore1.invoke(() -> PRDeltaPropagationDUnitTest.setBuildCount(0));
dataStore2.invoke(() -> PRDeltaPropagationDUnitTest.setBuildCount(0));
@@ -255,8 +275,8 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
/**
* Check delta propagation works properly with PR failover.
*/
-
- public void testDeltaPropagationForPRFailover() throws Throwable {
+ @Test
+ public void testDeltaPropagationForPRFailover() throws Exception {
Object args[] = new Object[] { REGION_NAME, new Integer(1), new Integer(50),
new Integer(8), Boolean.FALSE, null };
Integer port1 = (Integer)dataStore1.invoke(
@@ -290,7 +310,8 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
client1.invoke(() -> PRDeltaPropagationDUnitTest.checkDeltaInvoked(new Integer(deltaSent)));
}
- public void testDeltaPropagationForPRFailoverWithCompression() throws Throwable {
+ @Test
+ public void testDeltaPropagationForPRFailoverWithCompression() throws Exception {
Object args[] = new Object[] { REGION_NAME, new Integer(1), new Integer(50),
new Integer(8), Boolean.FALSE, compressor };
Integer port1 = (Integer)dataStore1.invoke(
@@ -332,8 +353,8 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
/**
* Check full object gets resend if delta can not be applied
*/
-
- public void testDeltaPropagationForPRWithExpiry() throws Throwable {
+ @Test
+ public void testDeltaPropagationForPRWithExpiry() throws Exception {
createCacheInAllPRVms();
createDeltaPR(Boolean.TRUE);
putWithExpiry();
@@ -342,12 +363,12 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * 1) Put delta objects on client feeder connected PR accessor bridge server.
- * 2) From accessor to data store delta gets propagated as part of <code>PutMessage</code> delta.
- * 3) From data store to client delta should get propagated.
- *
+ * 1) Put delta objects on client feeder connected PR accessor bridge server.
+ * 2) From accessor to data store delta gets propagated as part of <code>PutMessage</code> delta.
+ * 3) From data store to client delta should get propagated.
*/
- public void testDeltaPropagationPRAccessorAsBridgeServer() throws Throwable {
+ @Test
+ public void testDeltaPropagationPRAccessorAsBridgeServer() throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(0), new Integer(0),
new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(0), new Integer(50),
@@ -372,9 +393,9 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
* datastore node. This invalid delta exception propagated back to client
* through accessor.
* 4) Client sends full object in response.
- *
*/
- public void testDeltaPropagationPRAccessorAsBridgeServerWithDeltaException() throws Throwable {
+ @Test
+ public void testDeltaPropagationPRAccessorAsBridgeServerWithDeltaException() throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(0), new Integer(0),
new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(0), new Integer(50),
@@ -396,14 +417,11 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
// perform invalidate on accessor
dataStore2.invoke(() -> PRDeltaPropagationDUnitTest.invalidateDeltaKey());
- /*Thread.sleep(2000);*/
-
test = new DeltaTestImpl();
test.setStr("DELTA");
deltaPR.put(DELTA_KEY, test);
-/* putWithExpiry();*/
- deltaPR.put(LAST_KEY, "");
+ deltaPR.put(LAST_KEY, "");
client1.invoke(() -> PRDeltaPropagationDUnitTest.waitForLastKey());
client1.invoke(() -> PRDeltaPropagationDUnitTest.checkForFullObject());
}
@@ -416,10 +434,10 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
* datastore node. This invalid delta exception propagated back to client
* through accessor.
* 4) Client sends full object in response.
- *
*/
+ @Test
public void testDeltaPropagationClientEmptyPRAccessorAsBridgeServerWithDeltaException()
- throws Throwable {
+ throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(0),
new Integer(0), new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(0),
@@ -462,18 +480,17 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
* datastore node. This invalid delta exception propagated back to client
* through accessor.
* 4) Client sends full object in response.
- *
*/
- public void testDeltaPropagationReplicatedRegionPeerWithDeltaException() throws Throwable {
+ @Test
+ public void testDeltaPropagationReplicatedRegionPeerWithDeltaException() throws Exception {
Object args1[] = new Object[] {Boolean.FALSE, Boolean.TRUE};
Object args2[] = new Object[] {Boolean.TRUE, Boolean.FALSE};
-// server 1 with empty data policy
+ // server 1 with empty data policy
Integer port1 = (Integer)dataStore1.invoke(
PRDeltaPropagationDUnitTest.class, "createServerCache", args1);
// server 2 with non empty data policy
- dataStore2.invoke(
- PRDeltaPropagationDUnitTest.class, "createServerCache", args2);
+ dataStore2.invoke(PRDeltaPropagationDUnitTest.class, "createServerCache", args2);
createClientCache(port1, Boolean.FALSE, Boolean.FALSE, Boolean.FALSE);
@@ -505,8 +522,9 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
* 2) Second client attached to datastore. Register CQ.
* 3) Varifies that no data loss, event revcieved on second client
*/
+ @Test
public void testCqClientConnectAccessorAndDataStore()
- throws Throwable {
+ throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(1),
new Integer(0), new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(1),
@@ -555,14 +573,15 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * Toplogy: PR: Accessor, dataStore.
+ * Topology: PR: Accessor, dataStore.
* client and client1 connected to PR accessor;
* client puts delta objects on dataStore via accessor
- * Accesor gets adjunctMessage about put
+ * Accessor gets adjunctMessage about put
* Verify on client1 that queryUpdate and queryDestroy are executed properly
*/
+ @Test
public void testClientOnAccessorReceivesCqEvents()
- throws Throwable {
+ throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(1),
new Integer(0), new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(1),
@@ -607,8 +626,9 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
* client puts delta objects on accessor
* Verify on client1 that queryUpdate and queryDestroy are executed properly
*/
+ @Test
public void testCQClientOnRedundantBucketReceivesCQEvents()
- throws Throwable {
+ throws Exception {
// args for accessor
Object args1[] = new Object[] { REGION_NAME, new Integer(1),
new Integer(0), new Integer(2), Boolean.FALSE, null };
@@ -665,8 +685,9 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
* Verify that client1 receives 2 deltas for 2 updates (due to RI)
* Verify on client1 that queryUpdate and queryDestroy are executed properly
*/
+ @Test
public void testCQRIClientOnRedundantBucketReceivesDeltaAndCQEvents()
- throws Throwable {
+ throws Exception {
// args for accessor
Object args1[] = new Object[] { REGION_NAME, new Integer(1),
new Integer(0), new Integer(2), Boolean.FALSE, null };
@@ -712,13 +733,13 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * 1) Put delta objects on client feeder connected to PR accessor bridge server.
- * 2) From accessor to data store delta gets propagated as part of <code>PutMessage</code> delta.
- * 3) From data store to accessor delta + full value gets propagated as part of Adjunct Message.
- * 4) From accessor to client delta should get propagated.
- *
+ * 1) Put delta objects on client feeder connected to PR accessor bridge server.
+ * 2) From accessor to data store delta gets propagated as part of <code>PutMessage</code> delta.
+ * 3) From data store to accessor delta + full value gets propagated as part of Adjunct Message.
+ * 4) From accessor to client delta should get propagated.
*/
- public void testDeltaPropagationWithAdjunctMessaging() throws Throwable {
+ @Test
+ public void testDeltaPropagationWithAdjunctMessaging() throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(0), new Integer(0),
new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(0), new Integer(50),
@@ -736,13 +757,13 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * 1) Accessor is a Feeder.From accessor to data store delta gets propagated as part of <code>PutMessage</code> delta.
- * 2) From data store to accessor delta + full value gets propagted as part of Adjunct Message.
- * 3) From accessor to a client with data policy normal delta should get propagated.
- * 4) From accessor to client with data policy empty full value should get propagated.
- *
+ * 1) Accessor is a Feeder.From accessor to data store delta gets propagated as part of <code>PutMessage</code> delta.
+ * 2) From data store to accessor delta + full value gets propagted as part of Adjunct Message.
+ * 3) From accessor to a client with data policy normal delta should get propagated.
+ * 4) From accessor to client with data policy empty full value should get propagated.
*/
- public void testDeltaPropagationWithAdjunctMessagingForEmptyClient() throws Throwable {
+ @Test
+ public void testDeltaPropagationWithAdjunctMessagingForEmptyClient() throws Exception {
Object args1[] = new Object[] { REGION_NAME, new Integer(0), new Integer(0),
new Integer(8), Boolean.FALSE, null };
Object args2[] = new Object[] { REGION_NAME, new Integer(0), new Integer(50),
@@ -766,14 +787,15 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
/**
- * 1) One accessor and one datastore is defined with a PR with zero redundant copies.
- * 2) Client is connected only to the accessor.
- * 3) One delta put is performed on datastore.
- * 4) Flag to cause toDelta() throw an exception is set on datastore.
- * 5) Another delta put is performed on datastore.
- * 6) Verify that the second delta put fails and value on datastore is same as the one put by first delta update.
+ * 1) One accessor and one datastore is defined with a PR with zero redundant copies.
+ * 2) Client is connected only to the accessor.
+ * 3) One delta put is performed on datastore.
+ * 4) Flag to cause toDelta() throw an exception is set on datastore.
+ * 5) Another delta put is performed on datastore.
+ * 6) Verify that the second delta put fails and value on datastore is same as the one put by first delta update.
*/
- public void testDeltaPropagationWithAdjunctMessagingAndBadDelta() throws Throwable {
+ @Test
+ public void testDeltaPropagationWithAdjunctMessagingAndBadDelta() throws Exception {
Object accessor[] = new Object[] { REGION_NAME, 0, 0, 8, Boolean.FALSE, null };
Object dataStore[] = new Object[] { REGION_NAME, 0, 50, 8, Boolean.FALSE, null };
@@ -807,8 +829,6 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
DeltaTestImpl.resetDeltaInvokationCounters();
}
-
-
// check and reset delta counters
public static void fromDeltaCounter(Integer count) {
assertTrue("FromDelta counters do not match, expected: " + count.intValue()
@@ -818,7 +838,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
public static void checkIsFailed() {
- assertFalse("Full value is not recieved by server", isFailed);
+ assertFalse("Full value is not reeived by server", isFailed);
}
public static Boolean isFailed() {
@@ -840,7 +860,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
public static void createCacheInVm() {
- new PRDeltaPropagationDUnitTest("temp").createCache(new Properties());
+ new PRDeltaPropagationDUnitTest().createCache(new Properties());
}
public void createCache(Properties props) {
@@ -933,7 +953,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
Boolean isEmpty) throws Exception {
Properties props = new Properties();
- new PRDeltaPropagationDUnitTest("temp").createCache(props);
+ new PRDeltaPropagationDUnitTest().createCache(props);
AttributesFactory factory = new AttributesFactory();
factory.setScope(Scope.DISTRIBUTED_ACK);
factory.setConcurrencyChecksEnabled(true);
@@ -950,6 +970,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
AttributesMutator am = deltaPR.getAttributesMutator();
if (isListAttach.booleanValue()) {
am.addCacheListener(new CacheListenerAdapter() {
+ @Override
public void afterCreate(EntryEvent event) {
if (event.getNewValue() == null)
isFailed = true;
@@ -958,7 +979,8 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
lastKeyReceived = true;
}
}
-
+
+ @Override
public void afterUpdate(EntryEvent event) {
if (event.getNewValue() == null)
isFailed = true;
@@ -977,7 +999,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
public static void createClientCache(Integer port1,
Boolean subscriptionEnable, Boolean isEmpty, Boolean isCq) throws Exception {
- PRDeltaPropagationDUnitTest test = new PRDeltaPropagationDUnitTest("temp");
+ PRDeltaPropagationDUnitTest test = new PRDeltaPropagationDUnitTest();
Properties props = new Properties();
props.setProperty(MCAST_PORT, "0");
props.setProperty(LOCATORS, "");
@@ -1008,21 +1030,25 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
factory.setPoolName(p.getName());
factory.setCloningEnabled(false);
- factory.addCacheListener(new CacheListenerAdapter(){
- public void afterCreate(EntryEvent event) {
+ factory.addCacheListener(new CacheListenerAdapter() {
+ @Override
+ public void afterCreate(EntryEvent event) {
if (LAST_KEY.equals(event.getKey())) {
- lastKeyReceived = true;
- }}});
+ lastKeyReceived = true;
+ }
+ }
+ });
RegionAttributes attrs = factory.create();
deltaPR = cache.createRegion(REGION_NAME, attrs);
- //deltaPR.create(DELTA_KEY, new PRDeltaTestImpl());
- if(subscriptionEnable.booleanValue())
+ if (subscriptionEnable.booleanValue()) {
deltaPR.registerInterest("ALL_KEYS");
+ }
pool = p;
if (isCq.booleanValue()) {
CqAttributesFactory cqf = new CqAttributesFactory();
CqListenerAdapter cqlist = new CqListenerAdapter() {
+ @Override
@SuppressWarnings("synthetic-access")
public void onEvent(CqEvent cqEvent) {
if (LAST_KEY.equals(cqEvent.getKey().toString())) {
@@ -1065,7 +1091,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
}
public static void createClientCache(Integer port1, Integer port2) throws Exception {
- PRDeltaPropagationDUnitTest test = new PRDeltaPropagationDUnitTest("temp");
+ PRDeltaPropagationDUnitTest test = new PRDeltaPropagationDUnitTest();
Properties props = new Properties();
props.setProperty(MCAST_PORT, "0");
props.setProperty(LOCATORS, "");
@@ -1085,10 +1111,13 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
factory.setCloningEnabled(false);
factory.setConcurrencyChecksEnabled(true);
factory.addCacheListener(new CacheListenerAdapter(){
- public void afterCreate(EntryEvent event) {
+ @Override
+ public void afterCreate(EntryEvent event) {
if (LAST_KEY.equals(event.getKey())) {
- lastKeyReceived = true;
- }}});
+ lastKeyReceived = true;
+ }
+ }
+ });
RegionAttributes attrs = factory.create();
deltaPR = cache.createRegion(REGION_NAME, attrs);
@@ -1215,15 +1244,19 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
public static Boolean verifyQueryUpdateExecuted() {
return PRDeltaPropagationDUnitTest.queryUpdateExecuted;
}
+
public static Boolean verifyQueryDestroyExecuted() {
return PRDeltaPropagationDUnitTest.queryDestroyExecuted;
}
+
public static Boolean checkVMRecievesDeltaObjectThrCQListner() {
return PRDeltaPropagationDUnitTest.notADeltaInstanceObj;
}
+
public static boolean isLastKeyReceived() {
return lastKeyReceived;
}
+
public static void verifyDeltaSent(Integer deltas) {
CacheClientNotifier ccn = ((CacheServerImpl)cache
.getCacheServers().toArray()[0]).getAcceptor()
@@ -1275,6 +1308,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
public PRDeltaTestImpl() {
}
+ @Override
public void toDelta(DataOutput out) throws IOException {
super.toDelta(out);
if (isBadToDelta) {
@@ -1283,6 +1317,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
deltaSent++;
}
+ @Override
public void fromDelta(DataInput in) throws IOException {
super.fromDelta(in);
if (isBadFromDelta) {
@@ -1299,6 +1334,7 @@ public class PRDeltaPropagationDUnitTest extends DistributedTestCase {
return deltaApplied;
}
+ @Override
public String toString() {
return "PRDeltaTestImpl[deltaApplied=" + deltaApplied + "]"
+ super.toString();