net.sf.joafip.btreeplus.service

Class BtreePlusDataManager

java.lang.Object

net.sf.joafip.kvstore.service.AbstractHeapDataManager

net.sf.joafip.btreeplus.service.BtreePlusDataManager

All Implemented Interfaces:

Serializable, IHeapDataManager

@NotStorableClass
public class BtreePlusDataManager
extends AbstractHeapDataManager

Author:

luc peuvrier

See Also:

Serialized Form

Field Summary

Fields inherited from class net.sf.joafip.kvstore.service.AbstractHeapDataManager

CLEAR_STANDBY_MODIFICATION_FAILED, FAILED_READ_DATA_RECORD, FLUSH_FAILED, logger

Constructor Summary

Constructors

Constructor and Description
BtreePlusDataManager(HeapFileSetup setup)

Method Summary

Methods

Modifier and Type	Method and Description
String	backup(long identifier, int maxBackup)
protected void	clearImpl()
protected void	clearStandbyModificationImpl()
protected void	closeHeapManagerAfterException() close heap element manager after exception
protected Iterator<DataRecordIdentifier>	dataRecordIteratorImpl()
protected boolean	deleteDataRecordImpl(DataRecordIdentifier dataRecordIdentifier)
protected void	flushImp() implement all flush action after call to #updateHeapRecordImpl(DataRecordIdentifier, IHeapDataRecord)
protected long	freeSizeImpl()
BtreePlusElementMgr	getBtreePlusElementMgr()
protected Set<DataRecordIdentifier>	getDataRecordIdentifierSetImpl()
long	getLastRecordPositionInFile() for test purpose
protected DataRecordIdentifier	getNewDataRecordIdentifierImpl() to get a new data identifier for future data record creation
protected DataRecordIdentifier	getNextFreeDataRecordIdentifierImpl()
protected int	getNumberOfDataRecordImpl()
protected int	getNumberOfFreeRecordImpl()
long	getRecordPositionInfile(DataRecordIdentifier identifier) for test purpose
String	getStorageFileName()
protected boolean	hasDataRecordImpl(DataRecordIdentifier dataRecordIdentifier)
protected long	heapSizeImpl()
boolean	isDataLost() return true if data lost after file stable state reconstruction.
protected byte[]	readDataRecordImpl(DataRecordIdentifier dataRecordIdentifier)
protected void	removeFiles() remove existing files
protected DataRecordIdentifier	removeFirstDataRecordImpl()
void	setDataRecordKeyManager(IDataRecordKeyManager dataRecordKeyManager)
protected void	setNextFreeDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier)
protected void	startServiceImpl(boolean removeFiles) to implement open actions
protected void	stopServiceImpl(boolean removeFiles) to implement close actions
protected long	usedSizeImpl()
protected boolean	writeDataRecordImpl(DataRecordIdentifier dataRecordIdentifier, byte[] data)

Methods inherited from class net.sf.joafip.kvstore.service.AbstractHeapDataManager

ceilingDataRecordIdentifier, ceilingDataRecordIdentifierImpl, clear, clearStandbyModification, dataRecordIterator, deleteDataRecord, firstDataRecordIdentifier, firstDataRecordIdentifierImpl, floorDataRecordIdentifier, floorDataRecordIdentifierImpl, flush, freeSize, getDataRecordIdentifierSet, getNewDataRecordIdentifier, getNextFreeDataRecordIdentifier, getNumberOfDataRecord, getNumberOfFreeRecord, hasDataRecord, heapSize, higherDataRecordIdentifier, higherDataRecordIdentifierImpl, isServiceStarted, lastDataRecordIdentifier, lastDataRecordIdentifierImpl, lowerDataRecordIdentifier, lowerDataRecordIdentifierImpl, nextDataRecordIdentifier, nextDataRecordIdentifierImpl, readDataRecord, removeFirstDataRecord, setNextFreeDataRecordIdentifier, startService, stopService, stopService, usedSize, writeDataRecord

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BtreePlusDataManager

public BtreePlusDataManager(HeapFileSetup setup)
                     throws HeapException

Throws:

HeapException

Method Detail

getBtreePlusElementMgr

public BtreePlusElementMgr getBtreePlusElementMgr()

isDataLost

public boolean isDataLost()

Description copied from interface: IHeapDataManager

return true if data lost after file stable state reconstruction.
this check is done at heap data file construction

Returns:

true if data lost after file stable state reconstruction

backup

public String backup(long identifier,
            int maxBackup)
              throws HeapException

Throws:

HeapException

getStorageFileName

public String getStorageFileName()
                          throws HeapException

Returns:

data storage file name

Throws:

HeapException

setDataRecordKeyManager

public void setDataRecordKeyManager(IDataRecordKeyManager dataRecordKeyManager)
                             throws HeapException

Throws:

HeapException

removeFiles

protected void removeFiles()
                    throws HeapException

Description copied from class: AbstractHeapDataManager

remove existing files

Specified by:

removeFiles in class AbstractHeapDataManager

Throws:

HeapException

startServiceImpl

protected void startServiceImpl(boolean removeFiles)
                         throws HeapException

Description copied from class: AbstractHeapDataManager

to implement open actions

Specified by:

startServiceImpl in class AbstractHeapDataManager

Throws:

HeapException

stopServiceImpl

protected void stopServiceImpl(boolean removeFiles)
                        throws HeapException

Description copied from class: AbstractHeapDataManager

to implement close actions

Specified by:

stopServiceImpl in class AbstractHeapDataManager

Throws:

HeapException

clearImpl

protected void clearImpl()
                  throws HeapException

Specified by:

clearImpl in class AbstractHeapDataManager

Throws:

HeapException

flushImp

protected void flushImp()
                 throws HeapException

Description copied from class: AbstractHeapDataManager

implement all flush action after call to #updateHeapRecordImpl(DataRecordIdentifier, IHeapDataRecord)

Specified by:

flushImp in class AbstractHeapDataManager

Throws:

HeapException

clearStandbyModificationImpl

protected void clearStandbyModificationImpl()
                                     throws HeapException

Specified by:

clearStandbyModificationImpl in class AbstractHeapDataManager

Throws:

HeapException

closeHeapManagerAfterException

protected void closeHeapManagerAfterException()

Description copied from class: AbstractHeapDataManager

close heap element manager after exception

Specified by:

closeHeapManagerAfterException in class AbstractHeapDataManager

getNextFreeDataRecordIdentifierImpl

protected DataRecordIdentifier getNextFreeDataRecordIdentifierImpl()
                                                            throws HeapException

Specified by:

getNextFreeDataRecordIdentifierImpl in class AbstractHeapDataManager

Throws:

HeapException

setNextFreeDataRecordIdentifierImpl

protected void setNextFreeDataRecordIdentifierImpl(DataRecordIdentifier dataRecordIdentifier)
                                            throws HeapException

Specified by:

setNextFreeDataRecordIdentifierImpl in class AbstractHeapDataManager

Throws:

HeapException

getNewDataRecordIdentifierImpl

protected DataRecordIdentifier getNewDataRecordIdentifierImpl()
                                                       throws HeapException

Description copied from class: AbstractHeapDataManager

to get a new data identifier for future data record creation

Specified by:

getNewDataRecordIdentifierImpl in class AbstractHeapDataManager

Returns:

the new data record identifier

Throws:

HeapException

readDataRecordImpl

protected byte[] readDataRecordImpl(DataRecordIdentifier dataRecordIdentifier)
                             throws HeapException

Specified by:

readDataRecordImpl in class AbstractHeapDataManager

Throws:

HeapException

hasDataRecordImpl

protected boolean hasDataRecordImpl(DataRecordIdentifier dataRecordIdentifier)
                             throws HeapException

Specified by:

hasDataRecordImpl in class AbstractHeapDataManager

Throws:

HeapException

writeDataRecordImpl

protected boolean writeDataRecordImpl(DataRecordIdentifier dataRecordIdentifier,
                          byte[] data)
                               throws HeapException

Specified by:

writeDataRecordImpl in class AbstractHeapDataManager

Returns:

true if data record created

Throws:

HeapException

deleteDataRecordImpl

protected boolean deleteDataRecordImpl(DataRecordIdentifier dataRecordIdentifier)
                                throws HeapException

Specified by:

deleteDataRecordImpl in class AbstractHeapDataManager

Throws:

HeapException

removeFirstDataRecordImpl

protected DataRecordIdentifier removeFirstDataRecordImpl()
                                                  throws HeapException

Specified by:

removeFirstDataRecordImpl in class AbstractHeapDataManager

Throws:

HeapException

getNumberOfDataRecordImpl

protected int getNumberOfDataRecordImpl()
                                 throws HeapException

Specified by:

getNumberOfDataRecordImpl in class AbstractHeapDataManager

Returns:

number of data record in heap file

Throws:

HeapException

getNumberOfFreeRecordImpl

protected int getNumberOfFreeRecordImpl()
                                 throws HeapException

Specified by:

getNumberOfFreeRecordImpl in class AbstractHeapDataManager

Throws:

HeapException

heapSizeImpl

protected long heapSizeImpl()
                     throws HeapException

Specified by:

heapSizeImpl in class AbstractHeapDataManager

Throws:

HeapException

freeSizeImpl

protected long freeSizeImpl()
                     throws HeapException

Specified by:

freeSizeImpl in class AbstractHeapDataManager

Throws:

HeapException

usedSizeImpl

protected long usedSizeImpl()
                     throws HeapException

Specified by:

usedSizeImpl in class AbstractHeapDataManager

Throws:

HeapException

getDataRecordIdentifierSetImpl

@Fortest
protected Set<DataRecordIdentifier> getDataRecordIdentifierSetImpl()
                                                            throws HeapException

Specified by:

getDataRecordIdentifierSetImpl in class AbstractHeapDataManager

Throws:

HeapException

dataRecordIteratorImpl

protected Iterator<DataRecordIdentifier> dataRecordIteratorImpl()
                                                         throws HeapException

Specified by:

dataRecordIteratorImpl in class AbstractHeapDataManager

Throws:

HeapException

getRecordPositionInfile

@Fortest
public long getRecordPositionInfile(DataRecordIdentifier identifier)
                             throws HeapException

Description copied from interface: IHeapDataManager

for test purpose

Returns:

Throws:

HeapException

getLastRecordPositionInFile

@Fortest
public long getLastRecordPositionInFile()
                                 throws HeapException

Description copied from interface: IHeapDataManager

for test purpose

Returns:

Throws:

HeapException