public class RecoveredServerTransaction extends ServerTransaction
Modifier and Type | Field and Description |
---|---|
protected Uid |
_originalProcessUid |
_recoveryCoordinator
controlHandle, parentTransaction
failedList, heuristicList, pendingList, preparedList, readonlyList, savedIntentionList
modifyingActions, objectModel, objectUid, usingActions
Constructor and Description |
---|
RecoveredServerTransaction(Uid actionUid)
actionUid is the local transaction identification for the remote
transaction - the name of the store entry which contains the state of the
server transaction.
|
RecoveredServerTransaction(Uid actionUid,
String changedTypeName)
actionUid is the local transaction identification for the remote
transaction - the name of the store entry which contains the state of the
server transaction.
|
Modifier and Type | Method and Description |
---|---|
void |
addResourceRecord(Uid rcUid,
Resource r)
Allows a new Resource to be added to the transaction.
|
boolean |
allCompleted() |
boolean |
assumeComplete()
Tell transaction it is assumed to be complete and should convert itself
to the appropriate assumed complete type.
|
Status |
get_status()
Get the status of the transaction.
|
Date |
getLastActiveTime()
do not admit to being inactive
|
Status |
getOriginalStatus()
Check the status of this transaction state, i.e., that represented by
get_uid and not getSavingUid
|
int |
getRecoveryStatus()
Get the status of recovery for this transaction
|
protected void |
packHeader(OutputObjectState os,
Header hdr)
Override StateManager packHeader so it gets the original processUid, not
this process's
|
void |
removeOldStoreEntry() |
void |
replayPhase2()
Causes phase 2 of the commit protocol to be replayed.
|
boolean |
save_state(OutputObjectState objectState,
int ot)
Redefined version of save_state and restore_state from StateManager.
|
String |
type()
Overloads BasicAction.type()
|
protected void |
unpackHeader(InputObjectState os,
Header hdr)
Override StateManager's unpackHeader to save the processUid of the
original process
|
doAfterCompletion, doBeforeCompletion, doCommit, doForget, doPhase2Abort, doPhase2Commit, doPrepare, finalize, getSavingUid, preparedStatus, register_synchronization, restore_state, rollback, setRecoveryCoordinator, toString, typeName
commit, create_subtransaction, createOTSRecord, createOTSRecord, destroyAction, equals, forgetHeuristics, get_parent_status, get_top_level_status, get_transaction_name, get_txcontext, getControlHandle, getSynchronizations, hash_top_level_tran, hash_transaction, interpositionType, is_ancestor_transaction, is_descendant_transaction, is_related_transaction, is_same_transaction, is_top_level_transaction, register_resource, register_subtran_aware, rollback_only, setControlHandle, topLevelUid, uid
addSynchronization, afterCompletion, afterCompletion, asyncAfterCompletion, beforeCompletion, cancel, end, getDeferredThrowable, running, start, start
Abort, Abort, abortStatus, activate, activate, activeThreads, add, addChildAction, addChildThread, addChildThread, addRecord, async_prepare, Begin, checkForCurrent, childTransactions, commitStatus, criticalEnd, criticalStart, Current, deactivate, destroy, doAbort, doAbort, doCommit, doCommit, doPrepare, End, finalizeInternal, getDeferredThrowables, getHeuristicDecision, getHierarchy, getStore, hashCode, hierarchyDepth, insertRecord, isAncestor, maintainHeuristics, onePhaseCommit, parent, phase2Abort, phase2Cleanup, phase2Commit, prepare, preventCommit, removeChildAction, removeChildThread, removeChildThread, setCheckedAction, setHeuristicDecision, status, topLevelAction, topLevelActionUid, typeOfAction, updateHeuristic, updateState
cleanup, createLists, deactivate, deactivate, disable, forgetAction, get_uid, getMutex, getObjectModel, getStoreRoot, loadObjectState, lockMutex, modified, objectType, persist, print, rememberAction, setStatus, setupStore, setupStore, setupStore, terminate, tryLockMutex, unlockMutex
get_uid, preventCommit
protected Uid _originalProcessUid
public RecoveredServerTransaction(Uid actionUid)
public RecoveredServerTransaction(Uid actionUid, String changedTypeName)
public Status get_status() throws SystemException
get_status
in interface CoordinatorOperations
get_status
in class ArjunaTransactionImple
SystemException
public void addResourceRecord(Uid rcUid, Resource r)
public void replayPhase2()
public int getRecoveryStatus()
public Status getOriginalStatus()
public boolean allCompleted()
public String type()
TwoPhaseCoordinator
type
in class ServerTransaction
public void removeOldStoreEntry()
public boolean assumeComplete()
protected void packHeader(OutputObjectState os, Header hdr) throws IOException
packHeader
in class StateManager
IOException
protected void unpackHeader(InputObjectState os, Header hdr) throws IOException
unpackHeader
in class StateManager
os
- the identity of the transaction that last caused the state to
be written to the object store.IOException
public boolean save_state(OutputObjectState objectState, int ot)
BasicAction
save_state
in class ServerTransaction
true
if successful, false
otherwise.public Date getLastActiveTime()
Copyright © 2021 JBoss by Red Hat. All rights reserved.