abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2827
Change subject: [NO ISSUE][TEST] Fix Component Lifecycle Test
......................................................................
[NO ISSUE][TEST] Fix Component Lifecycle Test
Change-Id: Idb5156db0fb0e060d998851756ee3925c02b5791
---
M
hyracks-fullstack/hyracks/hyracks-tests/hyracks-storage-am-lsm-btree-test/src/test/java/org/apache/hyracks/storage/am/lsm/btree/LSMBTreeComponentLifecycleTest.java
1 file changed, 5 insertions(+), 5 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/27/2827/1
diff --git
a/hyracks-fullstack/hyracks/hyracks-tests/hyracks-storage-am-lsm-btree-test/src/test/java/org/apache/hyracks/storage/am/lsm/btree/LSMBTreeComponentLifecycleTest.java
b/hyracks-fullstack/hyracks/hyracks-tests/hyracks-storage-am-lsm-btree-test/src/test/java/org/apache/hyracks/storage/am/lsm/btree/LSMBTreeComponentLifecycleTest.java
index 21f3877..251f57a 100644
---
a/hyracks-fullstack/hyracks/hyracks-tests/hyracks-storage-am-lsm-btree-test/src/test/java/org/apache/hyracks/storage/am/lsm/btree/LSMBTreeComponentLifecycleTest.java
+++
b/hyracks-fullstack/hyracks/hyracks-tests/hyracks-storage-am-lsm-btree-test/src/test/java/org/apache/hyracks/storage/am/lsm/btree/LSMBTreeComponentLifecycleTest.java
@@ -37,6 +37,7 @@
import org.apache.hyracks.storage.am.lsm.btree.impl.NoOpTestCallback;
import org.apache.hyracks.storage.am.lsm.btree.util.LSMBTreeTestContext;
import org.apache.hyracks.storage.am.lsm.btree.util.LSMBTreeTestHarness;
+import org.apache.hyracks.storage.am.lsm.common.api.IIoOperationFailedCallback;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMComponent;
import
org.apache.hyracks.storage.am.lsm.common.api.ILSMComponent.LSMComponentType;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIOOperation;
@@ -47,7 +48,6 @@
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndexAccessor;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndexOperationContext;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMMemoryComponent;
-import org.apache.hyracks.storage.am.lsm.common.api.IIoOperationFailedCallback;
import org.apache.hyracks.storage.am.lsm.common.impls.AsynchronousScheduler;
import org.apache.logging.log4j.Level;
import org.apache.logging.log4j.LogManager;
@@ -292,7 +292,7 @@
ILSMIndexOperationContext opCtx = accessor.getOpContext();
assertCorrectSearchComponents(opCtx, index, 0);
// Allow one flush at a time and ensure that inserter didn't succeed
- for (int i = 0; i < numFlushes - 1; i++) {
+ for (int i = 0; i < numFlushes -
index.getNumberOfAllMemoryComponents(); i++) {
flushSemaphore.release();
firstUser.step();
flushRequest.await(2 + i);
@@ -300,21 +300,21 @@
// also ensure that you get the correct components when searching
assertCorrectSearchComponents(opCtx, index, i + 1);
}
- // Allow last flush to proceed
flushSemaphore.release();
+ firstUser.step();
// wait for the insert to complete
insertRequest.await();
+ // Allow last flush to proceed
+ flushSemaphore.release();
firstUser.step();
firstUser.step();
flushRequest.await();
firstUser.stop();
secondUser.stop();
-
int expectedMemoryComponent = numFlushes % numMemoryComponents;
Assert.assertEquals(getExpectedMemoryComponentIndex(expectedMemoryComponent),
index.getCurrentMemoryComponentIndex());
Assert.assertEquals(0, index.getDiskComponents().size());
-
EncapsulatingIoCallback encapsulating = (EncapsulatingIoCallback)
index.getIOOperationCallback();
CountingIoOperationCallback ioCallback = (CountingIoOperationCallback)
encapsulating.getEncapsulated();
// assert equal before, after, finalize were called
--
To view, visit https://asterix-gerrit.ics.uci.edu/2827
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Idb5156db0fb0e060d998851756ee3925c02b5791
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
