public abstract class MultiVMRegionTestCase extends RegionTestCase
Region
tests that involve more than one VM.RegionTestCase.TestExpiry
eventCount, preSnapshotRegion
Constructor and Description |
---|
MultiVMRegionTestCase() |
Modifier and Type | Method and Description |
---|---|
static void |
caseTearDown() |
protected void |
createRegionWithAttribute(org.apache.geode.test.dunit.VM vm,
java.lang.String name,
boolean syncDiskWrite) |
static void |
doOpsLoopNoFlush(int runTimeMs,
boolean includeClear,
boolean includePutAll) |
static java.util.Map |
getCCRegionContents() |
java.util.Properties |
getDistributedSystemProperties() |
protected <K,V> RegionAttributes<K,V> |
getRegionAttributes(java.lang.String type)
return the region attributes for the given type of region.
|
protected long |
getRepeatTimeoutMs()
The number of milliseconds to try repeating validation code in the event that AssertionError is
thrown.
|
protected static <K,V> TestCacheLoader<K,V> |
loader() |
protected void |
postTearDownRegionTestCase() |
protected static <K,V> void |
setLoader(TestCacheLoader<K,V> loader) |
protected boolean |
supportsNetLoad()
Indicate whether this region supports netload
|
protected boolean |
supportsReplication()
Indicate whether replication/GII supported
|
protected boolean |
supportsTransactions()
Indicate whether this region supports transactions
|
void |
testCacheLoaderModifyingArgument()
Tests that when a
CacheLoader modifies the callback argument in place, the change
is visible to the CacheWriter even if it is in another VM. |
void |
testCacheLoaderWithNetLoad() |
void |
testCacheLoaderWithNetSearch() |
void |
testConcurrentOperations()
This is a for the ConcurrentMap operations.
|
void |
testDefinedEntryUpdated()
Two VMs create a region.
|
void |
testDistributedDestroy()
Tests that destroying an entry is propagated to all VMs that define
that entry.
|
void |
testDistributedGet()
Tests that doing a distributed get results in a
netSearch . |
void |
testDistributedInvalidate()
Tests that invalidating an entry is propagated to all VMs that
define that entry.
|
void |
testDistributedInvalidate4()
Tests that invalidating an entry in multiple VMs does not cause
any problems.
|
void |
testDistributedPut()
Tests that an entry update is propagated to other caches that have that same entry defined.
|
void |
testDistributedPutNoUpdate()
Tests that doing a
put on a distributed region in one VM does not effect a
region in a different VM that does not have that key defined. |
void |
testDistributedRegionDestroy()
Tests that destroying a region is propagated to all VMs that define
that region.
|
void |
testDistributedRegionInvalidate()
Tests that invalidating a region is propagated to all VMs
that define that entry.
|
void |
testDistributedUpdate()
Tests that doing a
put in a distributed region one VM updates the value in
another VM. |
void |
testEntryTtlDestroyEvent()
Tests that an entry in a distributed region that expires with a distributed destroy causes an
event in other VM with isExpiration flag set.
|
void |
testEntryTtlLocalDestroy()
Tests that an entry in a distributed region expires with a local destroy after a given time to
live.
|
void |
testGetInitialImage()
Tests that a newly-created mirrored region contains all of the entries of another region.
|
void |
testLargeGetInitialImage()
Tests that a newly-created mirrored region contains all of the entries of another region, with
a large quantity of data.
|
void |
testLocalAndRemoteCacheWriters()
Tests that, when given a choice, a local
CacheWriter is invoked instead of a
remote one. |
void |
testLocalCacheLoader()
Tests that a local loader is preferred to a remote one
|
void |
testLocalDestroy()
Tests that a Region.localDestroy(java.lang.Object) does not effect other VMs that define that
entry.
|
void |
testLocalRegionDestroy()
Tests that a
Region.localDestroyRegion() is not propagated to other VMs that define that
region. |
void |
testMirroredDataFromNonMirrored()
Tests that a mirrored region gets data pushed to it from a non-mirrored region and the
afterCreate event is invoked on a listener.
|
void |
testMirroredLocalLoad()
Tests that a local load occurs, even with mirroring
|
void |
testMirroredNetLoad()
Tests sure that a
netLoad occurs, even with mirroring |
void |
testNBRegionDestructionDuringGetInitialImage() |
void |
testNBRegionInvalidationDuringGetInitialImage() |
void |
testNetSearchObservesIdleTime() |
void |
testNetSearchObservesTtl() |
void |
testNoDataSerializer()
Tests what happens when one VM attempts to read an object for which it does not have a
registered
DataSerializer . |
void |
testNoInstantiator()
Tests what happens when one VM attempts to read an object for which it does not have a
registered
Instantiator . |
void |
testNoLoaderWithInvalidEntry()
Tests that a remote
CacheLoader is not invoked if the remote region has an invalid
entry (that is, a key, but no value). |
void |
testNoMirroredDataToNonMirrored()
Tests that a mirrored region does not push data to a non-mirrored region.
|
void |
testNonblockingGetInitialImage()
Tests that distributed ack operations do not block while another cache is doing a
getInitialImage.
|
void |
testNoRegionKeepAlive()
Tests that a region is not kept alive
|
void |
testNoRemoteCacheLoader()
Tests that
Region.get(java.lang.Object) returns null when there is no remote loader. |
void |
testOrderedUpdates()
Verifies that distributed updates are delivered in order.
|
void |
testRemoteCacheListener()
Tests that a
CacheListener is invoked in a remote VM. |
void |
testRemoteCacheListenerInSubregion()
Tests that a
CacheListener is invoked in a remote VM. |
void |
testRemoteCacheLoader()
Tests that a
CacheLoader is invoked in a remote VM. |
void |
testRemoteCacheLoaderArg()
Tests that the parameter passed to a remote
CacheLoader is actually passed. |
void |
testRemoteCacheLoaderException()
Tests that a remote
CacheLoader that throws a CacheLoaderException results is
propagated back to the caller. |
void |
testRemoteCacheWriter()
Tests that a remote
CacheWriter is invoked and that CacheWriter arguments
and CacheWriterException s are propagated appropriately. |
void |
testRemoteLoaderNetSearch()
Tests that invoking
netSearch in a remote loader returns null instead
of causing infinite recursion. |
void |
testReplicate()
Tests that keys and values are pushed with
DataPolicy.REPLICATE . |
void |
testTXAlgebra() |
void |
testTXMultiRegion() |
void |
testTXNonblockingGetInitialImage()
Tests that distributed ack operations do not block while another cache is doing a
getInitialImage.
|
void |
testTXRmtMirror() |
void |
testTXSimpleOps()
Tests that an entry update is propagated to other caches that have that same entry defined.
|
void |
testTXUpdateLoadNoConflict()
Tests that the push of a loaded value does not cause a conflict on the side receiving the
update
|
void |
testUpdateResetsIdleTime()
Tests to makes sure that a distributed update resets the expiration timer.
|
void |
versionTestClearOnNonReplicateWithConcurrentEvents() |
void |
versionTestClearWithConcurrentEvents() |
void |
versionTestClearWithConcurrentEventsAsync() |
void |
versionTestConcurrentEvents()
This tests the concurrency versioning system to ensure that event conflation happens correctly
and that the statistic is being updated properly
|
void |
versionTestConcurrentEventsOnEmptyRegion()
This tests the concurrency versioning system to ensure that event conflation happens correctly
and that the statistic is being updated properly
|
void |
versionTestConcurrentEventsOnNonReplicatedRegion()
This tests the concurrency versioning system to ensure that event conflation happens correctly
and that the statistic is being updated properly
|
void |
versionTestGetAllWithVersions() |
void |
versionTestGIISendsTombstones() |
void |
versionTestTombstones() |
createRegion, createRootRegion, entryIsLocal, flushIfNecessary, getRegionAttributes, pauseIfNecessary, pauseIfNecessary, postTearDownCacheTestCase, remoteTestPostSnapshot, supportsLocalDestroyAndLocalInvalidate, supportsSubregions, testBadRegionAccess, testCloseRegion, testContainsKey, testCreateSubregions, testCustomEntryIdleReset, testCustomEntryIdleTimeout1, testCustomEntryIdleTimeout2, testCustomEntryIdleTimeout3, testCustomEntryTtl1, testCustomEntryTtl2, testCustomEntryTtl3, testCustomIdleOnce, testDestroyEntry, testDestroyRegion, testEntries, testEntriesRecursive, testEntryExpirationAfterMutate, testEntryFromLoadTtlInvalidate, testEntryIdleDestroy, testEntryIdleInvalidate, testEntryIdleReset, testEntryIdleTimeout3, testEntryIdleTtl, testEntryTtl3, testEntryTtlDestroy, testEntryTtlInvalidate, testEntryUserAttribute, testGetCache, testGetName, testGetParentRegion, testGetPathFromRoot, testInvalidateEntry, testInvalidateRegion, testKeys, testLocalDestroyEntry, testLocalDestroyRegion, testLocalInvalidateEntry, testLocalInvalidateRegion, testNulls, testPutNonExistentEntry, testRegionExpirationAfterMutate, testRegionIdleDestroy, testRegionIdleInvalidate, testRegionTtlDestroy, testRegionTtlInvalidate, testRegionUserAttribute, testRootSnapshot, testSnapshot, testSubregions, testSubregionsRecursive, testValues, waitForDestroy, waitForDestroy, waitForInvalidate, waitForInvalidate, waitForRegionDestroy
addExceptionTag1, basicGetCache, beginCacheXml, closeAllCache, closeCache, createExpiryRootRegion, createLonerCache, createRegion, createRegion, createRootRegion, createRootRegion, finishCacheXml, finishCacheXml, getCache, getCache, getCache, getCache, getCache, getClientCache, getClientCache, getDiskDir, getDiskDirs, getGemfireCache, getRootRegion, getRootRegion, hasCache, preTearDown, preTearDownCacheTestCase, removeExceptionTag1
basicGetSystem, cleanDiskDirs, cleanupAllVms, deleteBACKUPDiskStoreFile, destroyRegions, disconnectAllFromDS, disconnectFromDS, getBlackboard, getLonerSystem, getName, getSystem, getSystem, getSystemStatic, getTestClass, getTestMethodName, getUniqueName, initializeBlackboard, initializeDistributedTestCase, isConnectedToDS, nullSystem, postSetUp, postTearDown, postTearDownAssertions, preSetUp, preTearDownAssertions, setSystem, setUpDistributedTestCase, tearDownDistributedTestCase
protected static <K,V> TestCacheLoader<K,V> loader()
protected static <K,V> void setLoader(TestCacheLoader<K,V> loader)
public static void caseTearDown()
protected final void postTearDownRegionTestCase() throws java.lang.Exception
postTearDownRegionTestCase
in class RegionTestCase
java.lang.Exception
public java.util.Properties getDistributedSystemProperties()
getDistributedSystemProperties
in interface org.apache.geode.test.dunit.internal.DistributedTestFixture
getDistributedSystemProperties
in class org.apache.geode.test.dunit.internal.JUnit4DistributedTestCase
public void testConcurrentOperations()
public void testDistributedUpdate()
put
in a distributed region one VM updates the value in
another VM.public void testOrderedUpdates() throws java.lang.Exception
Note that this test does not make sense for regions that are Scope.DISTRIBUTED_NO_ACK
for which we do not guarantee the ordering of updates for a single producer/single consumer.
java.lang.Exception
public void testDistributedGet()
netSearch
.public void testDistributedPutNoUpdate() throws java.lang.Exception
put
on a distributed region in one VM does not effect a
region in a different VM that does not have that key defined.java.lang.Exception
public void testDefinedEntryUpdated()
public void testDistributedDestroy()
public void testDistributedRegionDestroy()
public void testLocalDestroy() throws java.lang.Exception
java.lang.Exception
public void testLocalRegionDestroy() throws java.lang.Exception
Region.localDestroyRegion()
is not propagated to other VMs that define that
region.java.lang.Exception
public void testDistributedInvalidate()
public void testDistributedInvalidate4()
public void testDistributedRegionInvalidate()
public void testRemoteCacheListener()
CacheListener
is invoked in a remote VM.public void testRemoteCacheListenerInSubregion()
CacheListener
is invoked in a remote VM.protected boolean supportsNetLoad()
public void testRemoteCacheLoader()
CacheLoader
is invoked in a remote VM. This essentially tests
netLoad
.public void testRemoteCacheLoaderArg()
CacheLoader
is actually passed.public void testRemoteCacheLoaderException()
CacheLoader
that throws a CacheLoaderException
results is
propagated back to the caller.public void testCacheLoaderWithNetSearch()
public void testCacheLoaderWithNetLoad()
public void testNoRemoteCacheLoader()
Region.get(java.lang.Object)
returns null
when there is no remote loader.public void testNoLoaderWithInvalidEntry()
CacheLoader
is not invoked if the remote region has an invalid
entry (that is, a key, but no value).public void testRemoteCacheWriter()
CacheWriter
is invoked and that CacheWriter
arguments
and CacheWriterException
s are propagated appropriately.public void testLocalAndRemoteCacheWriters()
CacheWriter
is invoked instead of a
remote one.public void testCacheLoaderModifyingArgument()
CacheLoader
modifies the callback argument in place, the change
is visible to the CacheWriter
even if it is in another VM.public void testRemoteLoaderNetSearch()
netSearch
in a remote loader returns null
instead
of causing infinite recursion.public void testLocalCacheLoader()
public void testDistributedPut()
protected boolean supportsReplication()
public void testReplicate()
DataPolicy.REPLICATE
.public void testGetInitialImage()
public void testLargeGetInitialImage()
public void testMirroredDataFromNonMirrored()
public void testNoMirroredDataToNonMirrored()
public void testMirroredLocalLoad()
public void testMirroredNetLoad()
netLoad
occurs, even with mirroringpublic void testNoRegionKeepAlive()
public void testNetSearchObservesTtl()
public void testNetSearchObservesIdleTime()
public void testEntryTtlDestroyEvent()
public void testEntryTtlLocalDestroy() throws java.lang.Exception
java.lang.Exception
public void testUpdateResetsIdleTime()
public void testNonblockingGetInitialImage()
public void testTXNonblockingGetInitialImage()
public void testNBRegionInvalidationDuringGetInitialImage() throws java.lang.Exception
java.lang.Exception
public void testNBRegionDestructionDuringGetInitialImage()
public void testNoDataSerializer()
DataSerializer
.public void testNoInstantiator()
Instantiator
.public void testTXSimpleOps()
protected boolean supportsTransactions()
public void testTXUpdateLoadNoConflict()
public void testTXMultiRegion()
public void testTXRmtMirror()
public void testTXAlgebra()
protected <K,V> RegionAttributes<K,V> getRegionAttributes(java.lang.String type)
public void versionTestGIISendsTombstones()
public void versionTestConcurrentEvents() throws java.lang.Exception
java.lang.Exception
protected void createRegionWithAttribute(org.apache.geode.test.dunit.VM vm, java.lang.String name, boolean syncDiskWrite)
public void versionTestClearWithConcurrentEvents()
public void versionTestClearWithConcurrentEventsAsync()
public void versionTestClearOnNonReplicateWithConcurrentEvents()
public void versionTestTombstones()
public void versionTestConcurrentEventsOnEmptyRegion()
public static void doOpsLoopNoFlush(int runTimeMs, boolean includeClear, boolean includePutAll)
public void versionTestConcurrentEventsOnNonReplicatedRegion()
public void versionTestGetAllWithVersions()
protected long getRepeatTimeoutMs()
public static java.util.Map getCCRegionContents()