Methods
Modifier and Type |
Method and Description |
protected void |
assertTxIsStillValid(Transaction tx) |
protected Object |
attachGtxAndPassUpChain(InvocationContext ctx,
VisitableCommand command) |
protected PrepareCommand |
buildPrepareCommand(GlobalTransaction gtx,
List modifications,
boolean onePhaseCommit) |
protected void |
cleanupStaleLocks(InvocationContext ctx) |
protected Transaction |
createLocalTx()
Creates and starts a local tx
|
Map<String,Object> |
dumpStatistics() |
long |
getCommits() |
int |
getNumberOfSyncsRegistered() |
long |
getPrepares() |
long |
getRollbacks() |
boolean |
getStatisticsEnabled() |
Object |
handleDefault(InvocationContext ctx,
VisitableCommand command)
Tests if we already have a tx running.
|
void |
intialize(RPCManager rpcManager,
ContextFactory contextFactory,
Notifier notifier,
InvocationContextContainer icc,
TransactionLog transactionLog,
CommandsFactory factory,
ComponentRegistry componentRegistry,
LockManager lockManager) |
protected void |
replayModifications(InvocationContext ctx,
Transaction ltx,
PrepareCommand command)
Replays modifications
|
void |
resetStatistics() |
protected void |
runCommitPhase(InvocationContext ctx,
GlobalTransaction gtx,
List modifications,
boolean onePhaseCommit)
creates a commit()
|
Object |
runPreparePhase(InvocationContext ctx,
GlobalTransaction gtx,
List<WriteCommand> modifications)
Handles a local prepare - invoked by the sync handler.
|
protected void |
runRollbackPhase(InvocationContext ctx,
GlobalTransaction gtx,
Transaction tx)
creates a rollback()
|
void |
setStatisticsEnabled(boolean enabled) |
Object |
visitCommitCommand(InvocationContext ctx,
CommitCommand command)
Visits a CommitCommand.
|
Object |
visitInvalidateCommand(InvocationContext ctx,
InvalidateCommand command)
Visits a InvalidateCommand.
|
Object |
visitPrepareCommand(InvocationContext ctx,
PrepareCommand command)
Visits a PrepareCommand.
|
Object |
visitRollbackCommand(InvocationContext ctx,
RollbackCommand command)
Visits a RollbackCommand.
|