Repository: asterixdb Updated Branches: refs/heads/master a731afb17 -> a91abc2e5
[NO ISSUE][TEST] Fix Component Lifecycle Test Change-Id: Idb5156db0fb0e060d998851756ee3925c02b5791 Reviewed-on: https://asterix-gerrit.ics.uci.edu/2827 Sonar-Qube: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Contrib: Jenkins <[email protected]> Integration-Tests: Jenkins <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/asterixdb/repo Commit: http://git-wip-us.apache.org/repos/asf/asterixdb/commit/a91abc2e Tree: http://git-wip-us.apache.org/repos/asf/asterixdb/tree/a91abc2e Diff: http://git-wip-us.apache.org/repos/asf/asterixdb/diff/a91abc2e Branch: refs/heads/master Commit: a91abc2e54921d4eb8f98ed84a18142df663b6dd Parents: a731afb Author: Abdullah Alamoudi <[email protected]> Authored: Mon Jul 30 08:39:30 2018 -0700 Committer: abdullah alamoudi <[email protected]> Committed: Mon Jul 30 14:37:23 2018 -0700 ---------------------------------------------------------------------- .../am/lsm/btree/LSMBTreeComponentLifecycleTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/asterixdb/blob/a91abc2e/hyracks-fullstack/hyracks/hyracks-tests/hyracks-storage-am-lsm-btree-test/src/test/java/org/apache/hyracks/storage/am/lsm/btree/LSMBTreeComponentLifecycleTest.java ---------------------------------------------------------------------- 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.ITestOpCallback; 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.ILSMIndex; 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 @@ public class LSMBTreeComponentLifecycleTest { 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 @@ public class LSMBTreeComponentLifecycleTest { // 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
