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

Class AssumedCompleteTransaction

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.recovery.transactions.RecoveredTransaction

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

All Implemented Interfaces:

ArjunaTransactionOperations, UidCoordinatorOperations, Reapable, CoordinatorOperations, TerminatorOperations

public class AssumedCompleteTransaction
extends RecoveredTransaction

Transaction relic of a committed transaction that did not get committed responses from all resources/subordinates. Recovery will not be attempted unless a replay completion is received, in which case it is reactivated.

Several of the methods of OTS_Transaction could be simplified for an AssumedCompleteTransaction (e.g. the status must be committed), but they are kept the same to simplify maintenance

Version:

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

Author:

Peter Furniss (peter.furniss@arjuna.com)

Field Summary

Fields inherited from class com.arjuna.ats.internal.jts.recovery.transactions.RecoveredTransaction

_originalProcessUid

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
AssumedCompleteTransaction(Uid actionUid)

Method Summary

Modifier and Type	Method and Description
boolean	assumeComplete() This T is already assumed complete, so return false
Date	getLastActiveTime() do not admit to being inactive
Status	getOriginalStatus() the original process must be deceased if we are assumed complete
boolean	restore_state(InputObjectState objectState, int ot) This assumes the various lists are zero length when it is called.
boolean	save_state(OutputObjectState os, int ot) Redefined version of save_state and restore_state from StateManager.
String	toString() Overloads Object.toString()
String	type() Overloads BasicAction.type()
static String	typeName() typeName differs from original to force the ActionStore to keep AssumedCompleteTransactions separate

Methods inherited from class com.arjuna.ats.internal.jts.recovery.transactions.RecoveredTransaction

addResourceRecord, allCompleted, get_status, getRecoveryStatus, packHeader, removeOldStoreEntry, replayPhase2, unpackHeader

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

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, 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, getSavingUid, getStore, hashCode, hierarchyDepth, insertRecord, isAncestor, maintainHeuristics, onePhaseCommit, parent, phase2Abort, phase2Cleanup, phase2Commit, prepare, preparedStatus, 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

Constructor Detail

AssumedCompleteTransaction

public AssumedCompleteTransaction(Uid actionUid)

Method Detail

getOriginalStatus

public Status getOriginalStatus()

the original process must be deceased if we are assumed complete

Overrides:

getOriginalStatus in class RecoveredTransaction

type

public String type()

Description copied from class: TwoPhaseCoordinator

Overloads BasicAction.type()

Overrides:

type in class RecoveredTransaction

typeName

public static String typeName()

typeName differs from original to force the ActionStore to keep AssumedCompleteTransactions separate

toString

public String toString()

Description copied from class: BasicAction

Overloads Object.toString()

Overrides:

toString in class ArjunaTransactionImple

assumeComplete

public boolean assumeComplete()

This T is already assumed complete, so return false

Overrides:

assumeComplete in class RecoveredTransaction

getLastActiveTime

public Date getLastActiveTime()

Description copied from class: RecoveredTransaction

do not admit to being inactive

Overrides:

getLastActiveTime in class RecoveredTransaction

restore_state

public boolean restore_state(InputObjectState objectState,
                             int ot)

Description copied from class: BasicAction

This assumes the various lists are zero length when it is called.

Overrides:

restore_state in class BasicAction

Returns:

true if successful, false otherwise.

save_state

public boolean save_state(OutputObjectState os,
                          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 RecoveredTransaction

Returns:

true if successful, false otherwise.