Skip to content

Commit

Permalink
Renames NO_HEADER -> NO_HEADER_READER in GBPTree
Browse files Browse the repository at this point in the history
  • Loading branch information
tinwelint committed Jun 26, 2017
1 parent 8e71181 commit 131dbf3
Show file tree
Hide file tree
Showing 6 changed files with 16 additions and 12 deletions.
Expand Up @@ -139,6 +139,9 @@ public class GBPTree<KEY,VALUE> implements Closeable
*/
public interface Monitor
{
/**
* Adapter for {@link Monitor}.
*/
class Adaptor implements Monitor
{
@Override
Expand Down Expand Up @@ -199,7 +202,7 @@ public void startupState( boolean clean )
/**
* No-op header reader.
*/
static final Header.Reader NO_HEADER = (cursor,length) -> {};
static final Header.Reader NO_HEADER_READER = (cursor,length) -> {};

/**
* No-op header writer.
Expand Down
Expand Up @@ -49,7 +49,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.GBPTree.NO_HEADER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_READER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_WRITER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_MONITOR;
import static org.neo4j.test.rule.PageCacheRule.config;
Expand Down Expand Up @@ -98,7 +98,7 @@ public void shouldDetectFormatChange() throws Throwable
// THEN everything should work, otherwise there has likely been a format change
PageCache pageCache = pageCacheRule.getPageCache( fsRule.get() );
try ( GBPTree<MutableLong,MutableLong> tree = new GBPTree<>( pageCache, storeFile, new SimpleLongLayout(), 0,
NO_MONITOR, NO_HEADER, NO_HEADER_WRITER ) )
NO_MONITOR, NO_HEADER_READER, NO_HEADER_WRITER ) )
{
try
{
Expand Down Expand Up @@ -174,7 +174,7 @@ private void createAndZipTree( File storeFile ) throws IOException
{
PageCache pageCache = pageCacheRule.getPageCache( fsRule.get() );
try ( GBPTree<MutableLong,MutableLong> tree = new GBPTree<>( pageCache, storeFile, new SimpleLongLayout(), 0,
NO_MONITOR, NO_HEADER, NO_HEADER_WRITER ) )
NO_MONITOR, NO_HEADER_READER, NO_HEADER_WRITER ) )
{
MutableLong insertKey = new MutableLong();
MutableLong insertValue = new MutableLong();
Expand Down
Expand Up @@ -60,7 +60,7 @@
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import static org.junit.rules.RuleChain.outerRule;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_READER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_WRITER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_MONITOR;
import static org.neo4j.test.rule.PageCacheRule.config;
Expand Down Expand Up @@ -107,7 +107,7 @@ private GBPTree<MutableLong,MutableLong> createIndex( GBPTree.Monitor monitor )
PageCache pageCache =
pageCacheRule.getPageCache( fs.get(), config().withPageSize( pageSize ).withAccessChecks( true ) );
return index = new GBPTree<>( pageCache, directory.file( "index" ),
layout, 0/*use whatever page cache says*/, monitor, NO_HEADER, NO_HEADER_WRITER );
layout, 0/*use whatever page cache says*/, monitor, NO_HEADER_READER, NO_HEADER_WRITER );
}

@After
Expand Down
Expand Up @@ -45,7 +45,7 @@
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import static org.junit.rules.RuleChain.outerRule;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_READER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_WRITER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_MONITOR;
import static org.neo4j.test.rule.PageCacheRule.config;
Expand Down Expand Up @@ -76,7 +76,7 @@ private GBPTree<MutableLong,MutableLong> createIndex( int pageSize, GBPTree.Moni
{
pageCache = pageCacheRule.getPageCache( fs.get(), config().withPageSize( pageSize ).withAccessChecks( true ) );
return index = new GBPTree<>( pageCache, directory.file( "index" ),
layout, 0/*use whatever page cache says*/, monitor, NO_HEADER, NO_HEADER_WRITER );
layout, 0/*use whatever page cache says*/, monitor, NO_HEADER_READER, NO_HEADER_WRITER );
}

@After
Expand Down
Expand Up @@ -43,7 +43,7 @@
import static org.junit.Assert.assertFalse;
import static org.junit.Assert.assertTrue;
import static org.junit.rules.RuleChain.outerRule;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_READER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_WRITER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_MONITOR;
import static org.neo4j.index.internal.gbptree.ThrowingRunnable.throwing;
Expand Down Expand Up @@ -382,7 +382,8 @@ private long[] modificationData( int min, int max )

private static GBPTree<MutableLong,MutableLong> createIndex( PageCache pageCache, File file ) throws IOException
{
return new GBPTree<>( pageCache, file, new SimpleLongLayout(), 0, NO_MONITOR, NO_HEADER, NO_HEADER_WRITER );
return new GBPTree<>( pageCache, file, new SimpleLongLayout(), 0, NO_MONITOR,
NO_HEADER_READER, NO_HEADER_WRITER );
}

private PageCache createPageCache()
Expand Down
Expand Up @@ -73,7 +73,7 @@
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
import static org.junit.rules.RuleChain.outerRule;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_READER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_HEADER_WRITER;
import static org.neo4j.index.internal.gbptree.GBPTree.NO_MONITOR;
import static org.neo4j.index.internal.gbptree.ThrowingRunnable.throwing;
Expand Down Expand Up @@ -1261,7 +1261,7 @@ private class GBPTreeBuilder
private int pageCachePageSize = 256;
private int tentativePageSize = 0;
private Monitor monitor = NO_MONITOR;
private Header.Reader headerReader = NO_HEADER;
private Header.Reader headerReader = NO_HEADER_READER;
private Layout<MutableLong,MutableLong> layout = GBPTreeTest.layout;
private PageCache specificPageCache;
private Consumer<PageCursor> headerWriter = NO_HEADER_WRITER;
Expand Down

0 comments on commit 131dbf3

Please sign in to comment.