org.infinispan.transaction
Class TransactionLog

java.lang.Object
  org.infinispan.transaction.TransactionLog

public class TransactionLog
extends Object

Logs transactions and writes for Non-Blocking State Transfer

Author:

Jason T. Greene

Nested Class Summary

static class

TransactionLog.LogEntry

Constructor Summary

TransactionLog()

Method Summary

boolean	activate()
void	deactivate()
boolean	hasPendingPrepare(PrepareCommand command)
boolean	isActive()
void	logCommit(GlobalTransaction gtx)
void	logNoTxWrite(WriteCommand write)
void	logOnePhaseCommit(GlobalTransaction gtx, WriteCommand[] modifications)
void	logPrepare(PrepareCommand command)
void	rollback(GlobalTransaction gtx)
int	size()
void	writeCommitLog(StreamingMarshaller marshaller, ObjectOutput out)
void	writePendingPrepares(StreamingMarshaller marshaller, ObjectOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionLog

public TransactionLog()

Method Detail

logPrepare

public void logPrepare(PrepareCommand command)

logCommit

public void logCommit(GlobalTransaction gtx)

logOnePhaseCommit

public final void logOnePhaseCommit(GlobalTransaction gtx,
                                    WriteCommand[] modifications)

logNoTxWrite

public final void logNoTxWrite(WriteCommand write)

rollback

public void rollback(GlobalTransaction gtx)

isActive

public final boolean isActive()

activate

public final boolean activate()

deactivate

public final void deactivate()

size

public final int size()

writeCommitLog

public void writeCommitLog(StreamingMarshaller marshaller,
                           ObjectOutput out)
                    throws Exception

Throws:

Exception

writePendingPrepares

public void writePendingPrepares(StreamingMarshaller marshaller,
                                 ObjectOutput out)
                          throws Exception

Throws:

Exception

hasPendingPrepare

public boolean hasPendingPrepare(PrepareCommand command)