You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kh...@apache.org on 2017/03/17 20:11:08 UTC
[33/49] geode git commit: GEODE-2548: Removing the test
alternativelyCloseDataStoresAfterGettingAPageAndThenValidateTheContentsOfTheResults
GEODE-2548: Removing the test alternativelyCloseDataStoresAfterGettingAPageAndThenValidateTheContentsOfTheResults
* Removed the test as it was shutting down one datastore before the other datastore could recover from it.
* The second datastore just keeps waiting (hang) to recover but the other datastore was shut down
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/22750cf7
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/22750cf7
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/22750cf7
Branch: refs/heads/feature/GEODE-2420
Commit: 22750cf78ba6e4fc96d0d5fdd76cc6f1876dc64f
Parents: 755661a
Author: nabarun <nn...@pivotal.io>
Authored: Mon Mar 13 12:03:07 2017 -0700
Committer: Ken Howe <kh...@pivotal.io>
Committed: Fri Mar 17 13:09:45 2017 -0700
----------------------------------------------------------------------
.../geode/cache/lucene/PaginationDUnitTest.java | 54 --------------------
1 file changed, 54 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/22750cf7/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java
index ad6727e..11d5cd0 100644
--- a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java
+++ b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/PaginationDUnitTest.java
@@ -138,60 +138,6 @@ public class PaginationDUnitTest extends LuceneQueriesAccessorBase {
});
}
- @Test
- @Ignore
- @Parameters(method = "getListOfRegionTestTypes")
- public void alternativelyCloseDataStoresAfterGettingAPageAndThenValidateTheContentsOfTheResults(
- RegionTestableType regionTestType) {
- SerializableRunnableIF createIndex = () -> {
- LuceneService luceneService = LuceneServiceProvider.get(getCache());
- luceneService.createIndexFactory().setFields("text").create(INDEX_NAME, REGION_NAME);
- };
-
- dataStore1.invoke(() -> initDataStore(createIndex, regionTestType));
- dataStore2.invoke(() -> initDataStore(createIndex, regionTestType));
- accessor.invoke(() -> initAccessor(createIndex, regionTestType));
-
- putEntryInEachBucket();
-
- assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore1, FLUSH_WAIT_TIME_MS));
-
- accessor.invoke(() -> {
- List<LuceneResultStruct<Integer, TestObject>> combinedResult =
- new ArrayList<LuceneResultStruct<Integer, TestObject>>();
- Cache cache = getCache();
- LuceneService service = LuceneServiceProvider.get(cache);
- LuceneQuery<Integer, TestObject> query;
- query = service.createLuceneQueryFactory().setResultLimit(1000).setPageSize(PAGE_SIZE)
- .create(INDEX_NAME, REGION_NAME, "world", "text");
- PageableLuceneQueryResults<Integer, TestObject> pages = query.findPages();
- assertTrue(pages.hasNext());
-
- dataStore1.invoke(() -> closeCache());
- dataStore2.invoke(() -> closeCache());
-
- for (int i = 0; i < (NUM_BUCKETS / PAGE_SIZE); i++) {
- List<LuceneResultStruct<Integer, TestObject>> page;
- if (i % 2 == 0) {
- // Bring up dataStore2 and shutdown dataStore1
- dataStore2.invoke(() -> initDataStore(createIndex, regionTestType));
- assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore2, FLUSH_WAIT_TIME_MS));
- dataStore1.invoke(() -> closeCache());
- page = pages.next();
- } else {
- // Bring up dataStore1 and shutdown dataStore2
- dataStore1.invoke(() -> initDataStore(createIndex, regionTestType));
- assertTrue(waitForFlushBeforeExecuteTextSearch(dataStore1, FLUSH_WAIT_TIME_MS));
- dataStore2.invoke(() -> closeCache());
- page = pages.next();
- }
- assertEquals(PAGE_SIZE, page.size());
- combinedResult.addAll(page);
- }
- validateTheCombinedResult(combinedResult);
- });
- }
-
private void validateTheCombinedResult(
final List<LuceneResultStruct<Integer, TestObject>> combinedResult) {
Map<Integer, TestObject> resultMap = combinedResult.stream()