org.siebengeisslein.core
Class CoreTransaction

java.lang.Object
  org.siebengeisslein.core.CoreTransaction

public class CoreTransaction
extends java.lang.Object

Field Summary

static java.lang.String	EXT
static java.lang.String	PREFIX

Constructor Summary

CoreTransaction(java.io.File directory, TransactionManager transactionManager, WriteBufferPool writePool, DataStoreImpl store, GCState gcState)

CoreTransaction(java.lang.String filename, BTree btree, DataStoreImpl store, GCState gcState, TransactionManager transactionManager)
Recovery Constructor.

Method Summary

void	abort()
void	addTask(Task task)
void	commit(FlushThread flushThread, CoreTransactionSequence seq)
java.io.File	getFile()
java.util.List<Task>	getTasks()
boolean	isCommitted()
boolean	isEmpty()
boolean	isGCActive()
void	join()
static Task	readTask(java.io.DataInputStream in, BTree btree, DataStoreImpl store, GCState gcState)
static void	recover(Config config, BTree btree, DataStoreImpl store, GCState gcState, TransactionManager transactionManager, FlushThread flushThread)

Methods inherited from class java.lang.Object

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

Field Detail

EXT

public static final java.lang.String EXT

See Also:

Constant Field Values

PREFIX

public static final java.lang.String PREFIX

See Also:

Constant Field Values

Constructor Detail

CoreTransaction

public CoreTransaction(java.lang.String filename,
                       BTree btree,
                       DataStoreImpl store,
                       GCState gcState,
                       TransactionManager transactionManager)
                throws java.io.IOException

Recovery Constructor.

Throws:

java.io.IOException

CoreTransaction

public CoreTransaction(java.io.File directory,
                       TransactionManager transactionManager,
                       WriteBufferPool writePool,
                       DataStoreImpl store,
                       GCState gcState)
                throws java.io.IOException

Throws:

java.io.IOException

Method Detail

readTask

public static Task readTask(java.io.DataInputStream in,
                            BTree btree,
                            DataStoreImpl store,
                            GCState gcState)
                     throws java.io.IOException

Throws:

java.io.IOException

getFile

public java.io.File getFile()

getTasks

public java.util.List<Task> getTasks()

isCommitted

public boolean isCommitted()

addTask

public void addTask(Task task)
             throws java.io.IOException

Throws:

java.io.IOException

commit

public void commit(FlushThread flushThread,
                   CoreTransactionSequence seq)
            throws java.io.IOException,
                   UnknownOIDException

Throws:

java.io.IOException

UnknownOIDException

abort

public void abort()
           throws java.io.IOException

Throws:

java.io.IOException

isEmpty

public boolean isEmpty()

recover

public static void recover(Config config,
                           BTree btree,
                           DataStoreImpl store,
                           GCState gcState,
                           TransactionManager transactionManager,
                           FlushThread flushThread)
                    throws java.io.IOException,
                           UnknownOIDException

Throws:

java.io.IOException

UnknownOIDException

join

public void join()
          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

isGCActive

public boolean isGCActive()