Module graph

Package de.grogra.persistence

Class PersistenceManager

java.lang.Object

de.grogra.util.LockableImpl

de.grogra.persistence.PersistenceManager

All Implemented Interfaces:

Lockable

Direct Known Subclasses:

GraphManager

public abstract class PersistenceManager
extends LockableImpl

Nested Class Summary

Nested classes/interfaces inherited from interface de.grogra.util.Lockable

Lockable.DeadLockException

Field Summary

Fields

Modifier and Type	Field	Description
protected final Object	makeLock
protected long	nextId

Constructor Summary

Constructors

Constructor	Description
PersistenceManager(PersistenceConnection cx, String key, boolean checkLock)

Method Summary

Modifier and Type	Method	Description
final void	addXAListener(XAListener l)
abstract int	allocateBitMark(boolean resetOnDispose)
abstract int	allocateObjectMark(boolean resetOnDispose)
protected void	beginTransaction(Transaction t)
void	close()
protected void	completeTransaction(Transaction t, boolean commit)
abstract void	copy(PersistenceCapable source, PersistenceCapable dest, boolean deep)
protected abstract Transaction	createTransaction(Thread thread)
protected abstract TransactionApplier	createXAApplier()
abstract void	disposeBitMark(int handle, boolean resetAll)
abstract void	disposeObjectMark(int handle, boolean resetAll)
final Transaction	getActiveTransaction()
final PersistenceBindings	getBindings()
final PersistenceConnection	getConnection()
final short	getId()
final LogStore	getLog()
abstract PersistenceCapable	getObject(long id)
int	getStamp()
final Transaction	getTransaction(boolean create)
final Transaction.Data	getTransactionData(Transaction.Key key)
final void	getTransactions(List<? super Transaction> list)
protected final void	idUsed(long id)
void	initNonlocalTransactionNotifier(Runnable notifier)
final void	localTransactionCommitted(Transaction.Key key, long stamp)
final void	localTransactionRolledBack(Transaction.Key key, long stamp)
final void	makePersistent(PersistenceCapable o, long id, Transaction t)
final void	makePersistent(Object o, Transaction t)
protected abstract void	makePersistentImpl(PersistenceCapable o, long id, Transaction t)
final void	makeTransient(PersistenceCapable o, Transaction t)
protected abstract void	makeTransientImpl(PersistenceCapable o, Transaction t)
protected final long	nextId()
protected void	prepareCompletion(Transaction t, boolean commit)
abstract long	prepareId(PersistenceCapable pc)
abstract void	readExtent(PersistenceInputStream in)
boolean	redo(Transaction t)
final void	removeXAListener(XAListener l)
protected void	transactionApplied(Transaction.Data xa, boolean rollback, Transaction t)
final void	transactionCommitted(Transaction.Data xa, long stamp)
boolean	undo(Transaction t)
abstract void	writeExtent(PersistenceOutputStream out)

Methods inherited from class de.grogra.util.LockableImpl

enterWriteLock, execute, execute, executeForcedly, executeForcedly, executeInAllowedThread, getMaxWaitingTime, getQueueLength, invokeRun, isAllowedThread, isLocked, killLock, leaveWriteLock, lock

Methods inherited from class java.lang.Object

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

Field Details

nextId

protected long nextId

makeLock

protected final Object makeLock

Constructor Details

PersistenceManager

public PersistenceManager(PersistenceConnection cx,
 String key,
 boolean checkLock)

Method Details

initNonlocalTransactionNotifier

public void initNonlocalTransactionNotifier(Runnable notifier)

close

public void close()

createXAApplier

protected abstract TransactionApplier createXAApplier()

createTransaction

protected abstract Transaction createTransaction(Thread thread)

getTransactions

public final void getTransactions(List<? super Transaction> list)

getActiveTransaction

public final Transaction getActiveTransaction()

getTransaction

public final Transaction getTransaction(boolean create)

beginTransaction

protected void beginTransaction(Transaction t)

prepareCompletion

protected void prepareCompletion(Transaction t,
 boolean commit)

completeTransaction

protected void completeTransaction(Transaction t,
 boolean commit)

transactionCommitted

public final void transactionCommitted(Transaction.Data xa,
 long stamp)

localTransactionCommitted

public final void localTransactionCommitted(Transaction.Key key,
 long stamp)

localTransactionRolledBack

public final void localTransactionRolledBack(Transaction.Key key,
 long stamp)

getTransactionData

public final Transaction.Data getTransactionData(Transaction.Key key)

getLog

public final LogStore getLog()

getConnection

public final PersistenceConnection getConnection()

getBindings

public final PersistenceBindings getBindings()

getId

public final short getId()

addXAListener

public final void addXAListener(XAListener l)

removeXAListener

public final void removeXAListener(XAListener l)

getStamp

public int getStamp()

transactionApplied

protected void transactionApplied(Transaction.Data xa,
 boolean rollback,
 Transaction t)

makePersistent

public final void makePersistent(Object o,
 Transaction t)

prepareId

public abstract long prepareId(PersistenceCapable pc)

makePersistent

public final void makePersistent(PersistenceCapable o,
 long id,
 Transaction t)

makeTransient

public final void makeTransient(PersistenceCapable o,
 Transaction t)

nextId

protected final long nextId()

idUsed

protected final void idUsed(long id)

makePersistentImpl

protected abstract void makePersistentImpl(PersistenceCapable o,
 long id,
 Transaction t)

makeTransientImpl

protected abstract void makeTransientImpl(PersistenceCapable o,
 Transaction t)

getObject

public abstract PersistenceCapable getObject(long id)

writeExtent

public abstract void writeExtent(PersistenceOutputStream out)
                          throws IOException

Throws:

IOException

readExtent

public abstract void readExtent(PersistenceInputStream in)
                         throws IOException

Throws:

IOException

allocateBitMark

public abstract int allocateBitMark(boolean resetOnDispose)

disposeBitMark

public abstract void disposeBitMark(int handle,
 boolean resetAll)

allocateObjectMark

public abstract int allocateObjectMark(boolean resetOnDispose)

disposeObjectMark

public abstract void disposeObjectMark(int handle,
 boolean resetAll)

undo

public boolean undo(Transaction t)
             throws IOException

Throws:

IOException

redo

public boolean redo(Transaction t)
             throws IOException

Throws:

IOException

copy

public abstract void copy(PersistenceCapable source,
 PersistenceCapable dest,
 boolean deep)