com.bigdata.rwstore

Interface IStore

All Superinterfaces:

IAllocationManager, IHistoryManager, IStreamStore

All Known Subinterfaces:

IMemoryManager

All Known Implementing Classes:

AllocationContext, MemoryManager, RWStore

public interface IStore
extends IAllocationManager, IStreamStore, IHistoryManager

The IStore interface provides persistent storage abstraction for fixed size allocations and allocation recycling.

Method Summary

Methods

Modifier and Type	Method and Description
long	alloc(byte[] buf, int size, IAllocationContext context) Writes data on the store.
void	close() Close the backing storage.
void	commit() Global commit on the backing store.
void	free(long addr, int size) Frees allocated storage (clears the bit to enable recycling after the next commit).
int	getAssociatedSlotSize(int addr)
Lock	getCommitLock() Optionally return a Lock that must be used (when non- null) to make the commit() / postCommit() strategy atomic.
void	getData(long addr, byte[] buf) Read data of a known size from the store.
File	getStoreFile() Retrieves store file.
void	postCommit() Hook that supports synchronization with an external commit before which a rollback to "pre-commit" state is supported.

Methods inherited from interface com.bigdata.rwstore.IAllocationManager

abortContext, detachContext, newAllocationContext

Methods inherited from interface com.bigdata.rawstore.IStreamStore

getInputStream, getOutputStream

Methods inherited from interface com.bigdata.rwstore.IHistoryManager

checkDeferredFrees, getLastReleaseTime, newTx, registerExternalCache, saveDeferrals

Method Detail

alloc

long alloc(byte[] buf,
         int size,
         IAllocationContext context)

Writes data on the store.

Returns:

the allocated address

free

void free(long addr,
        int size)

Frees allocated storage (clears the bit to enable recycling after the next commit).

Parameters:

addr - the storage address to be freed

getCommitLock

Lock getCommitLock()

Optionally return a Lock that must be used (when non- null) to make the commit() / postCommit() strategy atomic.

commit

void commit()

Global commit on the backing store. Previously committed data which has been marked as free(long, int) is now available for recycling. However, recycling can not occur if session protection is active.

postCommit

void postCommit()

Hook that supports synchronization with an external commit before which a rollback to "pre-commit" state is supported.

getData

void getData(long addr,
           byte[] buf)

Read data of a known size from the store.

Parameters:

addr - the address of the data

buf - the buffer of the size required!

getAssociatedSlotSize

int getAssociatedSlotSize(int addr)

Parameters:

addr - - the address

Returns:

the size of the slot associated

close

void close()

Close the backing storage.

getStoreFile

File getStoreFile()

Retrieves store file. Can be used to delete the store after the IStore has been released

Returns:

the File object