| java.lang.Object
 com.mckoi.store.AbstractStore
com.mckoi.store.JournalledFileStore
| JournalledFileStore | | final public class JournalledFileStore extends AbstractStore (Code) | | An implementation of AbstractStore that persists to an underlying data
format via a robust journalling system that supports check point and crash
recovery. Note that this object is a bridge between the Store API and the
journalled behaviour defined in LoggingBufferManager, JournalledSystem and
the StoreDataAccessor implementations.
Note that access to the resources is abstracted via a 'resource_name'
string. The LoggingBufferManager object converts the resource name into a
concrete object that accesses the actual data.
author:
Tobias Downer |
| JournalledFileStore | | public JournalledFileStore(String resource_name, LoggingBufferManager buffer_manager, boolean read_only)(Code) | | Constructs the ScatteringFileStore.
|
| delete | | public boolean delete() throws IOException(Code) | | Deletes this store from the file system. This operation should only be
used when the store is NOT open.
|
| exists | | public boolean exists() throws IOException(Code) | | Returns true if this store exists in the file system.
|
| internalClose | | protected void internalClose() throws IOException(Code) | | Internally closes the backing area.
|
| internalOpen | | protected void internalOpen(boolean read_only) throws IOException(Code) | | Internally opens the backing area. If 'read_only' is true then the
store is opened in read only mode.
|
| lockForWrite | | public void lockForWrite()(Code) | | |
| readByteArrayFrom | | protected int readByteArrayFrom(long position, byte[] buf, int off, int len) throws IOException(Code) | | |
| setDataAreaSize | | protected void setDataAreaSize(long new_size) throws IOException(Code) | | |
| unlockForWrite | | public void unlockForWrite()(Code) | | |
| writeByteArrayTo | | protected void writeByteArrayTo(long position, byte[] buf, int off, int len) throws IOException(Code) | | |
| Methods inherited from com.mckoi.store.AbstractStore | protected void checkPointer(long pointer) throws IOException(Code)(Java Doc)
public synchronized void close() throws IOException(Code)(Java Doc)
protected void coalescArea(long pointer, long size) throws IOException(Code)(Java Doc)
public synchronized AreaWriter createArea(long size) throws IOException(Code)(Java Doc)
public synchronized void deleteArea(long id) throws IOException(Code)(Java Doc)
abstract protected long endOfDataAreaPointer() throws IOException(Code)(Java Doc)
protected long expandDataArea(long minimum_size) throws IOException(Code)(Java Doc)
public ArrayList findAllocatedAreasNotIn(ArrayList list) throws IOException(Code)(Java Doc)
public List getAllAreas() throws IOException(Code)(Java Doc)
public Area getArea(long id) throws IOException(Code)(Java Doc)
protected void getAreaHeader(long pointer, long[] header) throws IOException(Code)(Java Doc)
public InputStream getAreaInputStream(long id) throws IOException(Code)(Java Doc)
public MutableArea getMutableArea(long id) throws IOException(Code)(Java Doc)
protected long getNextAreaHeader(long pointer, long[] header) throws IOException(Code)(Java Doc)
protected long getPreviousAreaHeader(long pointer, long[] header) throws IOException(Code)(Java Doc)
abstract protected void internalClose() throws IOException(Code)(Java Doc)
abstract protected void internalOpen(boolean read_only) throws IOException(Code)(Java Doc)
protected static boolean isValidBoundarySize(long size)(Code)(Java Doc)
public boolean lastCloseClean()(Code)(Java Doc)
public synchronized boolean open() throws IOException(Code)(Java Doc)
public synchronized void openScanAndFix(UserTerminal terminal) throws IOException(Code)(Java Doc)
protected void readBins() throws IOException(Code)(Java Doc)
abstract protected int readByteArrayFrom(long position, byte[] buf, int off, int len) throws IOException(Code)(Java Doc)
abstract protected int readByteFrom(long position) throws IOException(Code)(Java Doc)
protected void reboundArea(long pointer, long[] header, boolean write_headers) throws IOException(Code)(Java Doc)
abstract protected void setDataAreaSize(long length) throws IOException(Code)(Java Doc)
protected void splitArea(long pointer, long new_boundary) throws IOException(Code)(Java Doc)
public synchronized void statsScan(HashMap properties) throws IOException(Code)(Java Doc)
public synchronized long totalAllocatedSinceStart()(Code)(Java Doc)
protected void writeAllBins() throws IOException(Code)(Java Doc)
protected void writeBinIndex(int index) throws IOException(Code)(Java Doc)
abstract protected void writeByteArrayTo(long position, byte[] buf, int off, int len) throws IOException(Code)(Java Doc)
abstract protected void writeByteTo(long position, int b) throws IOException(Code)(Java Doc)
|
|
|