com.arjuna.ats.internal.jts.recovery.transactions

Class RecoveredServerTransaction

java.lang.Object

com.arjuna.ats.arjuna.StateManager

com.arjuna.ats.arjuna.coordinator.BasicAction

com.arjuna.ats.arjuna.coordinator.TwoPhaseCoordinator

com.arjuna.ats.internal.jts.orbspecific.coordinator.ArjunaTransactionImple

com.arjuna.ats.internal.jts.orbspecific.interposition.coordinator.ServerTransaction

com.arjuna.ats.internal.jts.recovery.transactions.RecoveredServerTransaction

All Implemented Interfaces:

ArjunaTransactionOperations, UidCoordinatorOperations, Reapable, CoordinatorOperations, TerminatorOperations

Direct Known Subclasses:

AssumedCompleteServerTransaction

public class RecoveredServerTransaction
extends ServerTransaction

Transaction type only instantiated at recovery time. This is used to re-activate the state of a server transaction that did not terminate correctly due to failure.

Version:

$Id: RecoveredServerTransaction.java 2342 2006-03-30 13:06:17Z $

Author:

Dave Ingham (dave@arjuna.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected Uid	_originalProcessUid

Fields inherited from class com.arjuna.ats.internal.jts.orbspecific.interposition.coordinator.ServerTransaction

_recoveryCoordinator

Fields inherited from class com.arjuna.ats.internal.jts.orbspecific.coordinator.ArjunaTransactionImple

controlHandle, parentTransaction

Fields inherited from class com.arjuna.ats.arjuna.coordinator.BasicAction

failedList, heuristicList, pendingList, preparedList, readonlyList, savedIntentionList

Fields inherited from class com.arjuna.ats.arjuna.StateManager

modifyingActions, objectModel, objectUid, usingActions

Constructor Summary

Constructors

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.

Method Summary

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

Methods inherited from class com.arjuna.ats.internal.jts.orbspecific.interposition.coordinator.ServerTransaction

doAfterCompletion, doBeforeCompletion, doCommit, doForget, doPhase2Abort, doPhase2Commit, doPrepare, finalize, getSavingUid, preparedStatus, register_synchronization, restore_state, rollback, setRecoveryCoordinator, toString, typeName

Methods inherited from class com.arjuna.ats.internal.jts.orbspecific.coordinator.ArjunaTransactionImple

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

Methods inherited from class com.arjuna.ats.arjuna.coordinator.TwoPhaseCoordinator

addSynchronization, afterCompletion, afterCompletion, asyncAfterCompletion, beforeCompletion, cancel, end, getDeferredThrowable, running, start, start

Methods inherited from class com.arjuna.ats.arjuna.coordinator.BasicAction

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, 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

Methods inherited from class com.arjuna.ats.arjuna.StateManager

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

Methods inherited from class java.lang.Object

clone, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.arjuna.ats.arjuna.coordinator.Reapable

get_uid, preventCommit

Field Detail

_originalProcessUid

protected Uid _originalProcessUid

Constructor Detail

RecoveredServerTransaction

public 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. The actual main transaction id is only obtained when we activate the transaction.

RecoveredServerTransaction

public 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. The actual main transaction id is only obtained when we activate the transaction.

Method Detail

get_status

public Status get_status()
                  throws SystemException

Get the status of the transaction. If we successfully activated the transaction then we return whatever the transaction reports otherwise we return RolledBack as we're using presumed abort.

Specified by:

get_status in interface CoordinatorOperations

Overrides:

get_status in class ArjunaTransactionImple

Throws:

SystemException

addResourceRecord

public void addResourceRecord(Uid rcUid,
                              Resource r)

Allows a new Resource to be added to the transaction. Typically this is used to replace a Resource that has failed and cannot be recovered on it's original IOR.

replayPhase2

public void replayPhase2()

Causes phase 2 of the commit protocol to be replayed.

getRecoveryStatus

public int getRecoveryStatus()

Get the status of recovery for this transaction

getOriginalStatus

public Status getOriginalStatus()

Check the status of this transaction state, i.e., that represented by get_uid and not getSavingUid

allCompleted

public boolean allCompleted()

type

public String type()

Description copied from class: TwoPhaseCoordinator

Overloads BasicAction.type()

Overrides:

type in class ServerTransaction

removeOldStoreEntry

public void removeOldStoreEntry()

assumeComplete

public boolean assumeComplete()

Tell transaction it is assumed to be complete and should convert itself to the appropriate assumed complete type.

packHeader

protected void packHeader(OutputObjectState os,
                          Header hdr)
                   throws IOException

Override StateManager packHeader so it gets the original processUid, not this process's

Overrides:

packHeader in class StateManager

Throws:

IOException

Since:

JTS 2.1.

unpackHeader

protected void unpackHeader(InputObjectState os,
                            Header hdr)
                     throws IOException

Override StateManager's unpackHeader to save the processUid of the original process

Overrides:

unpackHeader in class StateManager

Throws:

IOException

Since:

JTS 2.1.

save_state

public boolean save_state(OutputObjectState objectState,
                          int ot)

Description copied from class: BasicAction

Redefined version of save_state and restore_state from StateManager. Normal operation (no crashes): BasicAction.save_state is called after a successful prepare. This causes and BasicAction object to be saved in the object store. This object contains primarily the "intentions list" of the BasicAction. After successfully completing phase 2 of the commit protocol, the BasicAction object is deleted from the store. Failure cases: If a server crashes after successfully preparing, then upon recovery the action must be resolved (either committed or aborted) depending upon whether the co-ordinating atomic action committed or aborted. Upon server recovery, the crash recovery mechanism detects ServerBasicAction objects in the object store and attempts to activate the BasicAction object of the co-ordinating action. If this is successful then the SAA is committed else aborted. If, when processing phase 2 of the commit protocol, the co-ordinator experiences a failure to commit from one of the records then the BasicAction object is NOT deleted. It is rewritten when a new state which contains a list of the records that failed during phase 2 commit. This list is called the "failedList". The crash recovery manager will detect local BasicAction objects in addition to SAA objects in the objectstore. An attempt will be made to commit these actions. If the action contained a call to a now dead server, this action can never be resolved and the AA object can never be removed. However, if the action is purely local then after the processing is complete the removed by crash recovery.

Overrides:

save_state in class ServerTransaction

Returns:

true if successful, false otherwise.

getLastActiveTime

public Date getLastActiveTime()

do not admit to being inactive