From 18241e8e45fdbf7e23ff7353bdaf4c16f830efad Mon Sep 17 00:00:00 2001 From: Anton Persson Date: Mon, 24 Apr 2017 15:58:21 +0200 Subject: [PATCH] Fix compilation error after rebase --- .../internal/gbptree/RecoveryCleanupWorkCollectorIT.java | 7 ++++--- .../index/labelscan/NativeLabelScanStoreRebuildTest.java | 8 +++++--- 2 files changed, 9 insertions(+), 6 deletions(-) diff --git a/community/index/src/test/java/org/neo4j/index/internal/gbptree/RecoveryCleanupWorkCollectorIT.java b/community/index/src/test/java/org/neo4j/index/internal/gbptree/RecoveryCleanupWorkCollectorIT.java index 8cf42fb324537..6bb803e60fa97 100644 --- a/community/index/src/test/java/org/neo4j/index/internal/gbptree/RecoveryCleanupWorkCollectorIT.java +++ b/community/index/src/test/java/org/neo4j/index/internal/gbptree/RecoveryCleanupWorkCollectorIT.java @@ -91,6 +91,9 @@ private void doTest( int numberOfTrees ) throws IOException fillWithData( tree, keysPerTree ); writeTime += System.nanoTime() - start; tree.checkpoint( IOLimiter.unlimited() ); + + // Make dirty + tree.writer().close(); } } @@ -99,8 +102,6 @@ private void doTest( int numberOfTrees ) throws IOException for ( int i = 0; i < numberOfTrees; i++ ) { trees[i] = gbpTree( file[i] ); - trees[i].prepareForRecovery(); - trees[i].finishRecovery(); } recoveryCleanupWorkCollector.run(); IOUtils.closeAll( trees ); @@ -139,7 +140,7 @@ private class CleanLogMonitor implements GBPTree.Monitor AtomicLong accumulatedNumberOfPages = new AtomicLong(); @Override - public void recoveryCompleted( long numberOfPagesVisited, long numberOfCleanedCrashPointers, + public void cleanupFinished( long numberOfPagesVisited, long numberOfCleanedCrashPointers, long durationMillis ) { accumulatedCleanTime.accumulateAndGet( durationMillis, ADD ); diff --git a/community/kernel/src/test/java/org/neo4j/kernel/impl/index/labelscan/NativeLabelScanStoreRebuildTest.java b/community/kernel/src/test/java/org/neo4j/kernel/impl/index/labelscan/NativeLabelScanStoreRebuildTest.java index f64808f828c02..68cc84d4d4c47 100644 --- a/community/kernel/src/test/java/org/neo4j/kernel/impl/index/labelscan/NativeLabelScanStoreRebuildTest.java +++ b/community/kernel/src/test/java/org/neo4j/kernel/impl/index/labelscan/NativeLabelScanStoreRebuildTest.java @@ -43,6 +43,7 @@ import static org.junit.Assert.assertThat; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; +import static org.neo4j.index.internal.gbptree.RecoveryCleanupWorkCollector.IMMEDIATE; import static org.neo4j.kernel.impl.api.scan.FullStoreChangeStream.EMPTY; import static org.neo4j.kernel.impl.api.scan.FullStoreChangeStream.asStream; @@ -76,7 +77,8 @@ public void mustBeDirtyIfFailedDuringRebuild() throws Exception try { nativeLabelScanStore = - new NativeLabelScanStore( pageCache, storeDir, THROWING_STREAM, false, new Monitors() ); + new NativeLabelScanStore( pageCache, storeDir, THROWING_STREAM, false, new Monitors(), + IMMEDIATE ); nativeLabelScanStore.init(); nativeLabelScanStore.start(); @@ -95,7 +97,7 @@ public void mustBeDirtyIfFailedDuringRebuild() throws Exception monitors.addMonitorListener( monitor ); nativeLabelScanStore = - new NativeLabelScanStore( pageCache, storeDir, EMPTY, false, monitors ); + new NativeLabelScanStore( pageCache, storeDir, EMPTY, false, monitors, IMMEDIATE ); nativeLabelScanStore.init(); nativeLabelScanStore.start(); @@ -118,7 +120,7 @@ public void shouldFailOnUnsortedLabelsFromFullStoreChangeStream() throws Excepti try { nativeLabelScanStore = - new NativeLabelScanStore( pageCache, storeDir, changeStream, false, new Monitors() ); + new NativeLabelScanStore( pageCache, storeDir, changeStream, false, new Monitors(), IMMEDIATE ); nativeLabelScanStore.init(); // when