GEODE-1699: Making accessor VM a proxy in LuceneQuery tests The P2P lucene query tests were creating an accessor VM that was actually a datastore. That caused some of the tests that thought they were pausing the dispatcher for the AEQ to still have an active dispatcher on the accessor.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/fb39f889 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/fb39f889 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/fb39f889 Branch: refs/heads/develop Commit: fb39f889ac1cb891f39aae281419e723e5b615c0 Parents: f253ad2 Author: Dan Smith <[email protected]> Authored: Tue Aug 23 15:50:35 2016 -0700 Committer: Dan Smith <[email protected]> Committed: Wed Aug 24 09:33:26 2016 -0700 ---------------------------------------------------------------------- .../gemfire/cache/lucene/LuceneQueriesPeerPRDUnitTest.java | 5 ++++- .../cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java | 5 ++++- 2 files changed, 8 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/fb39f889/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRDUnitTest.java b/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRDUnitTest.java index 702ac1f..3af44ef 100644 --- a/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRDUnitTest.java +++ b/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRDUnitTest.java @@ -35,6 +35,9 @@ public class LuceneQueriesPeerPRDUnitTest extends LuceneQueriesPRBase { } @Override protected void initAccessor(final SerializableRunnableIF createIndex) throws Exception { - initDataStore(createIndex); + createIndex.run(); + getCache().createRegionFactory(RegionShortcut.PARTITION_PROXY) + .setPartitionAttributes(getPartitionAttributes()) + .create(REGION_NAME); } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/fb39f889/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java b/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java index d509cb2..f44f547 100644 --- a/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java +++ b/geode-lucene/src/test/java/com/gemstone/gemfire/cache/lucene/LuceneQueriesPeerPRRedundancyDUnitTest.java @@ -52,7 +52,10 @@ public class LuceneQueriesPeerPRRedundancyDUnitTest extends LuceneQueriesPRBase } @Override protected void initAccessor(final SerializableRunnableIF createIndex) throws Exception { - initDataStore(createIndex); + createIndex.run(); + Region region = getCache().createRegionFactory(RegionShortcut.PARTITION_PROXY_REDUNDANT) + .setPartitionAttributes(getPartitionAttributes()) + .create(REGION_NAME); } @Test
