public class RecoveredTransaction extends ArjunaTransactionImple
Modifier and Type | Field and Description |
---|---|
protected Uid |
_originalProcessUid |
controlHandle, parentTransaction
failedList, heuristicList, pendingList, preparedList, readonlyList, savedIntentionList
modifyingActions, objectModel, objectUid, usingActions
Constructor and Description |
---|
RecoveredTransaction(Uid actionUid) |
RecoveredTransaction(Uid actionUid,
String changedTypeName) |
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() |
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
|
commit, create_subtransaction, createOTSRecord, createOTSRecord, destroyAction, doAfterCompletion, doBeforeCompletion, equals, finalize, 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, register_synchronization, rollback_only, rollback, setControlHandle, topLevelUid, toString, typeName, 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, getSavingUid, getStore, hashCode, hierarchyDepth, insertRecord, isAncestor, maintainHeuristics, onePhaseCommit, parent, phase2Abort, phase2Cleanup, phase2Commit, prepare, preparedStatus, preventCommit, removeChildAction, removeChildThread, removeChildThread, restore_state, 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 RecoveredTransaction(Uid actionUid)
public Status get_status() throws SystemException
get_status
in interface CoordinatorOperations
get_status
in class ArjunaTransactionImple
SystemException
public Status getOriginalStatus()
public void addResourceRecord(Uid rcUid, Resource r)
public void replayPhase2()
public int getRecoveryStatus()
public boolean allCompleted()
public String type()
TwoPhaseCoordinator
type
in class ArjunaTransactionImple
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 BasicAction
true
if successful, false
otherwise.public Date getLastActiveTime()
Copyright © 2021 JBoss by Red Hat. All rights reserved.