org.mapdb

Class StoreDirectAbstract

org.mapdb.StoreDirectAbstract

All Implemented Interfaces:

ConcurrencyAware, Store, StoreImmutable, Verifiable

Direct Known Subclasses:

StoreDirect, StoreWAL

public class StoreDirectAbstract
implements Store

Common utils for StoreDirect, StoreWAL and StoreCached

Nested Class Summary

Nested classes/interfaces inherited from interface org.mapdb.ConcurrencyAware

ConcurrencyAware.DefaultImpls

Constructor Summary

Constructors

Constructor and Description
StoreDirectAbstract(java.lang.String file, VolumeFactory volumeFactory, boolean isThreadSafe, int concShift, boolean fileDeleteAfterClose, boolean checksum, boolean checksumHeader, boolean checksumHeaderBypass) Common utils for StoreDirect, StoreWAL and StoreCached

Method Summary

Modifier and Type	Method and Description
long	allocateData(int size, boolean recursive)
long	allocateNewIndexPage()
long	allocateNewPage()
long	allocateRecid()
void	assertNotClosed()
long	calculateChecksum()
int	calculateHeaderChecksum()
void	checkThreadSafe() checks all subcomponents, if this component is really thread safe, and throws an exception if not thread safe
<R> R	deserialize(Serializer<R> serializer, DataInput2 di, long size)
void	fileHeaderCheck()
long	fileHeaderCompose()
void	freeSizeIncrement(long increment)
boolean	getChecksum()
boolean	getChecksumHeader()
boolean	getChecksumHeaderBypass()
java.util.concurrent.atomic.AtomicBoolean	getClosed()
int	getConcShift()
long	getDataTail() end of last record
java.lang.String	getFile()
boolean	getFileDeleteAfterClose()
long	getFileTail$module() end of file (last allocated page)
Volume	getHeadVol()
NonExistentClass	getIndexPages()
long	getIndexVal(long recid)
java.util.concurrent.locks.ReadWriteLock[]	getLocks()
long	getMaxRecid() maximal allocated recid
int	getSegmentCount()
long	getSegmentMask()
java.util.concurrent.locks.Lock	getStructuralLock()
Volume	getVolume()
boolean	getVolumeExistsAtStart()
VolumeFactory	getVolumeFactory()
long	indexValCompose(long size, long offset, int linked, int unused, int archive)
boolean	indexValFlagArchive(long indexValue)
boolean	indexValFlagLinked(long indexValue)
boolean	indexValFlagUnused(long indexValue)
boolean	isClosed()
boolean	isThreadSafe() returns true if this is configured to be thread safe
void	loadIndexPages(NonExistentClass indexPages)
long	longStackMasterLinkOffset(long size)
void	longStackPut(long masterLinkOffset, long value, boolean recursive)
long	longStackTake(long masterLinkOffset, boolean recursive)
long	recidToOffset(long recid2)
int	recidToSegment(long recid)
void	releaseData(long size, long offset, boolean recursive)
void	releaseRecid(long recid)
<R> DataOutput2	serialize(R record, Serializer<R> serializer)
void	setDataTail(long v) end of last record
void	setFileTail$module(long v) end of file (last allocated page)
void	setIndexVal(long recid, long value)
void	setMaxRecid(long v) maximal allocated recid
int	storeHeaderCompose()

Methods inherited from interface org.mapdb.Store

close, commit, compact, compareAndSwap, delete, fileLoad, isClosed, isReadOnly, preallocate, put, update, verify

Methods inherited from interface org.mapdb.StoreImmutable

get, getAllFiles, getAllRecids

Methods inherited from interface org.mapdb.Verifiable

verify

Methods inherited from interface org.mapdb.ConcurrencyAware

checkThreadSafe, isThreadSafe

Constructor Detail

StoreDirectAbstract

public StoreDirectAbstract(java.lang.String file,
                           VolumeFactory volumeFactory,
                           boolean isThreadSafe,
                           int concShift,
                           boolean fileDeleteAfterClose,
                           boolean checksum,
                           boolean checksumHeader,
                           boolean checksumHeaderBypass)

Common utils for StoreDirect, StoreWAL and StoreCached

Parameters:

isThreadSafe - returns true if this is configured to be thread safe

Method Detail

getVolume

public Volume getVolume()

getHeadVol

public Volume getHeadVol()

getSegmentCount

public int getSegmentCount()

getSegmentMask

public long getSegmentMask()

getLocks

public java.util.concurrent.locks.ReadWriteLock[] getLocks()

getStructuralLock

public java.util.concurrent.locks.Lock getStructuralLock()

getVolumeExistsAtStart

public boolean getVolumeExistsAtStart()

getIndexPages

public NonExistentClass getIndexPages()

recidToOffset

public long recidToOffset(long recid2)

getClosed

public java.util.concurrent.atomic.AtomicBoolean getClosed()

isClosed

public boolean isClosed()

assertNotClosed

public void assertNotClosed()

getDataTail

public long getDataTail()

end of last record

setDataTail

public void setDataTail(long v)

end of last record

getMaxRecid

public long getMaxRecid()

maximal allocated recid

setMaxRecid

public void setMaxRecid(long v)

maximal allocated recid

getFileTail$module

public long getFileTail$module()

end of file (last allocated page)

setFileTail$module

public void setFileTail$module(long v)

end of file (last allocated page)

fileHeaderCheck

public void fileHeaderCheck()

fileHeaderCompose

public long fileHeaderCompose()

storeHeaderCompose

public int storeHeaderCompose()

getIndexVal

public long getIndexVal(long recid)

setIndexVal

public void setIndexVal(long recid,
                        long value)

loadIndexPages

public void loadIndexPages(NonExistentClass indexPages)

indexValCompose

public long indexValCompose(long size,
                            long offset,
                            int linked,
                            int unused,
                            int archive)

indexValFlagLinked

public boolean indexValFlagLinked(long indexValue)

indexValFlagUnused

public boolean indexValFlagUnused(long indexValue)

indexValFlagArchive

public boolean indexValFlagArchive(long indexValue)

recidToSegment

public int recidToSegment(long recid)

deserialize

public <R> R deserialize(Serializer<R> serializer,
                         DataInput2 di,
                         long size)

serialize

public <R> DataOutput2 serialize(R record,
                                 Serializer<R> serializer)

allocateRecid

public long allocateRecid()

allocateNewIndexPage

public long allocateNewIndexPage()

allocateData

public long allocateData(int size,
                         boolean recursive)

releaseData

public void releaseData(long size,
                        long offset,
                        boolean recursive)

releaseRecid

public void releaseRecid(long recid)

freeSizeIncrement

public void freeSizeIncrement(long increment)

longStackPut

public void longStackPut(long masterLinkOffset,
                         long value,
                         boolean recursive)

longStackTake

public long longStackTake(long masterLinkOffset,
                          boolean recursive)

longStackMasterLinkOffset

public long longStackMasterLinkOffset(long size)

allocateNewPage

public long allocateNewPage()

calculateChecksum

public long calculateChecksum()

calculateHeaderChecksum

public int calculateHeaderChecksum()

getFile

public java.lang.String getFile()

getVolumeFactory

public VolumeFactory getVolumeFactory()

isThreadSafe

public boolean isThreadSafe()

returns true if this is configured to be thread safe

getConcShift

public int getConcShift()

getFileDeleteAfterClose

public boolean getFileDeleteAfterClose()

getChecksum

public boolean getChecksum()

getChecksumHeader

public boolean getChecksumHeader()

getChecksumHeaderBypass

public boolean getChecksumHeaderBypass()

checkThreadSafe

public void checkThreadSafe()

checks all subcomponents, if this component is really thread safe, and throws an exception if not thread safe