org.agilewiki.jfile.transactions.db

Class DB

java.lang.Object

org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jfile.transactions.db.DB

All Implemented Interfaces:

org.agilewiki.jactor.Actor, org.agilewiki.jactor.apc.APCRequestSource, org.agilewiki.jactor.apc.RequestProcessor, org.agilewiki.jactor.lpc.RequestSource, org.agilewiki.jactor.lpc.TargetActor

Direct Known Subclasses:

IMDB

public abstract class DB
extends org.agilewiki.jactor.lpc.JLPCActor

A database must handle checkpoint requests.

Nested Class Summary

Nested classes/interfaces inherited from class org.agilewiki.jactor.lpc.JLPCActor

org.agilewiki.jactor.lpc.JLPCActor.SMBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.file.Path	directoryPath
protected String[]	logFileNames

Constructor Summary

Constructors

Constructor and Description
DB()
DB(org.agilewiki.jactor.MailboxFactory mailboxFactory, org.agilewiki.jactor.Actor parent, java.nio.file.Path directoryPath)

Method Summary

Methods

Modifier and Type	Method and Description
void	checkpoint(long logPosition, long timestamp, String logFileName, org.agilewiki.jactor.RP rp)
void	clearDirectory()
void	closeDbFile()
protected boolean	generateCheckpoints()
DurableTransactionLogger	getDurableTransactionLogger()
LogReader	getLogReader(int maxSize) Returns the transaction log reader.
TransactionAggregator	getTransactionAggregator() Returns the transaction aggregator.
protected void	initializeDb(int logReaderMaxSize)
protected LogReader	newLogReader() Create a transaction log reader.
protected TransactionAggregator	newTransactionAggregator() Create a transaction aggregator.
void	openDbFile(int logReaderMaxSize, org.agilewiki.jactor.RP rp)
void	processLogFile(long position, int fileIndex, org.agilewiki.jactor.RP rp)
void	setDirectoryPath(java.nio.file.Path path)

Methods inherited from class org.agilewiki.jactor.lpc.JLPCActor

acceptEvent, acceptRequest, getActorType, getAncestor, getExceptionHandler, getFactory, getMailbox, getMailboxFactory, getMatch, getParent, hasDataItem, haveEvents, initialize, initialize, initialize, initialize, initialize, requirements, responseFrom, send, send, sendEvent, setExceptionHandler, setInitialBufferCapacity

Methods inherited from class java.lang.Object

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

Field Detail

directoryPath

protected java.nio.file.Path directoryPath

logFileNames

protected String[] logFileNames

Constructor Detail

DB

public DB()

DB

public DB(org.agilewiki.jactor.MailboxFactory mailboxFactory,
  org.agilewiki.jactor.Actor parent,
  java.nio.file.Path directoryPath)
   throws Exception

Throws:

Exception

Method Detail

openDbFile

public void openDbFile(int logReaderMaxSize,
              org.agilewiki.jactor.RP rp)
                throws Exception

Throws:

Exception

initializeDb

protected void initializeDb(int logReaderMaxSize)

processLogFile

public void processLogFile(long position,
                  int fileIndex,
                  org.agilewiki.jactor.RP rp)
                    throws Exception

Throws:

Exception

closeDbFile

public void closeDbFile()

newLogReader

protected LogReader newLogReader()

Create a transaction log reader.

Returns:

A LogReader.

newTransactionAggregator

protected TransactionAggregator newTransactionAggregator()

Create a transaction aggregator.

Returns:

A TransactionAggregator.

getLogReader

public LogReader getLogReader(int maxSize)
                       throws Exception

Returns the transaction log reader.

Parameters:

maxSize - The maximum possible block size.

Returns:

The LogReader

Throws:

Exception

generateCheckpoints

protected boolean generateCheckpoints()

getTransactionAggregator

public TransactionAggregator getTransactionAggregator()
                                               throws Exception

Returns the transaction aggregator.

Returns:

The transaction aggregator.

Throws:

Exception

getDurableTransactionLogger

public DurableTransactionLogger getDurableTransactionLogger()
                                                     throws Exception

Throws:

Exception

checkpoint

public void checkpoint(long logPosition,
              long timestamp,
              String logFileName,
              org.agilewiki.jactor.RP rp)
                throws Exception

Throws:

Exception

setDirectoryPath

public void setDirectoryPath(java.nio.file.Path path)
                      throws Exception

Throws:

Exception

clearDirectory

public void clearDirectory()
                    throws Exception

Throws:

Exception