| /* |
| * ========================================================================= |
| * Copyright (c) 2002-2014 Pivotal Software, Inc. All Rights Reserved. |
| * This product is protected by U.S. and international copyright |
| * and intellectual property laws. Pivotal products are covered by |
| * more patents listed at http://www.pivotal.io/patents. |
| * ========================================================================= |
| */ |
| |
| package com.gemstone.gemfire.cache.query.partitioned; |
| |
| /** |
| * This test tests the PR query behaviour with respect to cache closure |
| * happening on one of the data stores. PR is configured with redundantCopies = |
| * 1, and cache close is done randomly on one of the data stores and then |
| * recreated, thus avoiding any data loss. |
| * |
| * @author pbatra |
| */ |
| |
| import java.util.LinkedList; |
| import java.util.List; |
| import java.util.Properties; |
| import java.util.Random; |
| |
| import com.gemstone.gemfire.cache.query.data.PortfolioData; |
| import com.gemstone.gemfire.internal.cache.ForceReattemptException; |
| import com.gemstone.gemfire.internal.cache.PartitionedRegionDUnitTestCase; |
| |
| import dunit.AsyncInvocation; |
| import dunit.DistributedTestCase; |
| import dunit.Host; |
| import dunit.VM; |
| |
| public class PRQueryCacheCloseDUnitTest extends PartitionedRegionDUnitTestCase |
| { |
| |
| /** |
| * constructor * |
| * |
| * @param name |
| */ |
| |
| public PRQueryCacheCloseDUnitTest(String name) { |
| |
| super(name); |
| } |
| |
| static Properties props = new Properties(); |
| |
| int totalNumBuckets = 100; |
| |
| int threadSleepTime = 500; |
| |
| int querySleepTime = 2000; |
| |
| int queryTestCycle = 10; |
| |
| PRQueryDUnitHelper PRQHelp = new PRQueryDUnitHelper(""); |
| |
| final String name = "Portfolios"; |
| |
| final String localName = "LocalPortfolios"; |
| |
| final int cnt = 0, cntDest = 50; |
| |
| final int redundancy = 1; |
| |
| /** |
| * This test <br> |
| * 1. Creates PR regions across with scope = DACK, one accessor node & 2 |
| * datastores <br> |
| * 2. Creates a Local region on one of the VM's <br> |
| * 3. Puts in the same data both in PR region & the Local Region <br> |
| * 4. Queries the data both in local & PR <br> |
| * 5. Also calls cache.close() randomly on one of the datastore VM's with |
| * delay <br> |
| * 6. then recreates the PR on the same VM <br> |
| * 7. Verfies the size , type , contents of both the resultSets Obtained <br> |
| */ |
| public void testPRWithCacheCloseInOneDatastoreWithDelay() throws Exception |
| { |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Querying PR Test with cache Close PR operation*****"); |
| Host host = Host.getHost(0); |
| |
| VM accessor = host.getVM(0); |
| VM datastore1 = host.getVM(1); |
| VM datastore2 = host.getVM(2); |
| |
| List vmList = new LinkedList(); |
| vmList.add(datastore1); |
| vmList.add(datastore2); |
| // Creting PR's on the participating VM's |
| |
| // Creting Accessor PR's on the participating VM's |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Creating Accessor node on VM0"); |
| accessor.invoke(PRQHelp.getCacheSerializableRunnableForPRAccessorCreate(name, |
| redundancy)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Successfully Created Accessor node on VM0"); |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Creating PR's across all VM1 , VM2"); |
| datastore1.invoke(PRQHelp.getCacheSerializableRunnableForPRCreate(name, |
| redundancy)); |
| datastore2.invoke(PRQHelp.getCacheSerializableRunnableForPRCreate(name, |
| redundancy)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Successfully Created PR on VM1 , VM2"); |
| |
| // creating a local region on one of the JVM's |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Creating Local Region on VM0"); |
| accessor.invoke(PRQHelp |
| .getCacheSerializableRunnableForLocalRegionCreation(localName)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Successfully Created Local Region on VM0"); |
| |
| // Generating portfolio object array to be populated across the PR's & Local |
| // Regions |
| |
| final PortfolioData[] portfolio = PRQHelp.createPortfolioData(cnt, cntDest); |
| |
| // Putting the data into the accessor node |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Inserting Portfolio data through the accessor node"); |
| accessor.invoke(PRQHelp.getCacheSerializableRunnableForPRPuts(name, portfolio, |
| cnt, cntDest)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Successfully Inserted Portfolio data through the accessor node"); |
| |
| // Putting the same data in the local region created |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Inserting Portfolio data on local node VM0 for result Set Comparison"); |
| accessor.invoke(PRQHelp.getCacheSerializableRunnableForPRPuts(localName, |
| portfolio, cnt, cntDest)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Successfully Inserted Portfolio data on local node VM0 for result Set Comparison"); |
| |
| Random random = new Random(); |
| AsyncInvocation async0; |
| // querying the VM for data |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Querying on VM0 both on PR Region & local ,also Comparing the Results sets from both"); |
| async0 = accessor |
| .invokeAsync(PRQHelp.getCacheSerializableRunnableForPRQueryAndCompareResults( |
| name, localName)); |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Calling for cache close on either of the Datastores VM1 , VM2 at random and then recreating the cache, with a predefined Delay "); |
| for (int j = 0; j < queryTestCycle; j++) { |
| int k = (random.nextInt(vmList.size())); |
| ((VM)(vmList.get(k))).invoke(PRQHelp.getCacheSerializableRunnableForCacheClose( |
| name, redundancy)); |
| pause(threadSleepTime); |
| } |
| DistributedTestCase.join(async0, 5 * 60 * 1000, getLogWriter()); |
| |
| if (async0.exceptionOccurred()) { |
| // for now, certain exceptions when a region is closed are acceptable |
| // including ForceReattemptException (e.g. resulting from RegionDestroyed) |
| boolean isForceReattempt = false; |
| Throwable t = async0.getException(); |
| do { |
| if (t instanceof ForceReattemptException) { |
| isForceReattempt = true; |
| break; |
| } |
| t = t.getCause(); |
| } while (t != null); |
| |
| if (!isForceReattempt) { |
| fail("Unexpected exception during query", async0.getException()); |
| } |
| } |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithDelay: Querying with PR Operations ENDED*****"); |
| } |
| |
| /** |
| * This test <br> |
| * 1. Creates PR regions across with scope = DACK, one accessor node & 2 |
| * datastores <br> |
| * 2. Creates a Local region on one of the VM's <br> |
| * 3. Puts in the same data both in PR region & the Local Region <br> |
| * 4. Queries the data both in local & PR <br> |
| * 5. Also calls cache.close() randomly on one of the datastore VM's without |
| * Delay<br> |
| * 6. then recreates the PR on the same VM <br> |
| * 7. Verfies the size , type , contents of both the resultSets Obtained <br> |
| */ |
| public void testPRWithCacheCloseInOneDatastoreWithoutDelay() throws Exception |
| { |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Querying PR Test with cache Close PR operation without delay*****"); |
| Host host = Host.getHost(0); |
| VM vm0 = host.getVM(0); |
| VM vm1 = host.getVM(1); |
| VM vm2 = host.getVM(2); |
| |
| List vmList = new LinkedList(); |
| vmList.add(vm1); |
| vmList.add(vm2); |
| |
| // Creting PR's on the participating VM's |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Creating Accessor node on VM0"); |
| vm0.invoke(PRQHelp.getCacheSerializableRunnableForPRAccessorCreate(name, |
| redundancy)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Successfully Created Accessor node on VM0"); |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Creating PR's across all VM1 , VM2"); |
| vm1.invoke(PRQHelp.getCacheSerializableRunnableForPRCreate(name, |
| redundancy)); |
| vm2.invoke(PRQHelp.getCacheSerializableRunnableForPRCreate(name, |
| redundancy)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Successfully Created PR on VM1 , VM2"); |
| |
| // creating a local region on one of the JVM's |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Creating Local Region on VM0"); |
| vm0.invoke(PRQHelp |
| .getCacheSerializableRunnableForLocalRegionCreation(localName)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Successfully Created Local Region on VM0"); |
| |
| getLogWriter().info("Successfully Created PR's across all VM's"); |
| // creating a local region on one of the JVM's |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Successfully Created Local Region on VM0"); |
| |
| // Generating portfolio object array to be populated across the PR's & Local |
| // Regions |
| |
| final PortfolioData[] portfolio = PRQHelp.createPortfolioData(cnt, cntDest); |
| // Putting the data into the accessor node |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Inserting Portfolio data through the accessor node"); |
| vm0.invoke(PRQHelp.getCacheSerializableRunnableForPRPuts(name, portfolio, |
| cnt, cntDest)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Successfully Inserted Portfolio data through the accessor node"); |
| |
| // Putting the same data in the local region created |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Inserting Portfolio data on local node VM0 for result Set Comparison"); |
| vm0.invoke(PRQHelp.getCacheSerializableRunnableForPRPuts(localName, |
| portfolio, cnt, cntDest)); |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Successfully Inserted Portfolio data on local node VM0 for result Set Comparison"); |
| |
| Random random = new Random(); |
| |
| AsyncInvocation async0; |
| // querying the VM for data |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Querying on VM0 both on PR Region & local ,also Comparing the Results sets from both"); |
| async0 = vm0 |
| .invokeAsync(PRQHelp.getCacheSerializableRunnableForPRQueryAndCompareResults( |
| name, localName)); |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Calling for cache close on either of the Datastores VM1 , VM2 at random and then recreating the cache, with no delay "); |
| for (int j = 0; j < queryTestCycle; j++) { |
| int k = (random.nextInt(vmList.size())); |
| ((VM)(vmList.get(k))).invoke(PRQHelp.getCacheSerializableRunnableForCacheClose( |
| name, redundancy)); |
| } |
| |
| DistributedTestCase.join(async0, 5 * 60 * 1000, getLogWriter()); |
| |
| if (async0.exceptionOccurred()) { |
| // for now, certain exceptions when a region is closed are acceptable |
| // including ForceReattemptException (e.g. resulting from RegionDestroyed) |
| boolean isForceReattempt = false; |
| Throwable t = async0.getException(); |
| do { |
| if (t instanceof ForceReattemptException) { |
| isForceReattempt = true; |
| break; |
| } |
| t = t.getCause(); |
| } while (t != null); |
| |
| if (!isForceReattempt) { |
| fail("Unexpected exception during query", async0.getException()); |
| } |
| } |
| |
| getLogWriter() |
| .info( |
| "PRQueryCacheCloseDUnitTest#testPRWithCacheCloseInOneDatastoreWithoutDelay: Querying with PR Operations without delay ENDED*****"); |
| } |
| |
| |
| } |
