org.jboss.jbossts.xts.recovery.participant.at

Class XTSATRecoveryManagerImple

java.lang.Object

org.jboss.jbossts.xts.recovery.participant.at.XTSATRecoveryManager

org.jboss.jbossts.xts.recovery.participant.at.XTSATRecoveryManagerImple

public class XTSATRecoveryManagerImple
extends XTSATRecoveryManager

A class which manages the table of recovered participant records.

Field Summary

Fields inherited from class org.jboss.jbossts.xts.recovery.participant.at.XTSATRecoveryManager

theRecoveryManager

Constructor Summary

Constructors

Constructor and Description
XTSATRecoveryManagerImple(com.arjuna.ats.arjuna.objectstore.TxLog txLog) constructor for use by ATParticipantRecoveryModule and ATCoordinatorRecoveryModule

Method Summary

Modifier and Type	Method and Description
void	addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid, ATParticipantRecoveryRecord participantRecoveryRecord) add a recovered participant record to the table of unrecovered participants which need to be recreated following recovery
boolean	deleteParticipantRecoveryRecord(String id) remove any participant recovery record with the supplied id from persistent storage
ATParticipantRecoveryRecord	findParticipantRecoveryRecord(String id) see if a participant recovery record with a given id exists in the table of participants which need to be recreated following recovery
boolean	isCoordinatorRecoveryStarted() test whether the first AT coordinator recovery scan has completed.
boolean	isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid) test whether the supplied uid identifies an active participant or a recovered but inactive participant n.b.
boolean	isParticipantRecoveryStarted() test whether the first AT participant recovery scan has completed.
static boolean	isRecoveryManagerInitialised()
boolean	isSubordinateCoordinatorRecoveryStarted() test whether the first AT subordinate coordinator recovery scan has completed.
void	recoverParticipants() process all entries in the recovered participant map and attempt to recreate the application participant and activate it
void	registerRecoveryModule(XTSATRecoveryModule module) register an application specific recovery module which acts as a helper to recreate a WS-AT durable participant from the participant's recovery data saved at prepare
void	setCoordinatorRecoveryStarted() record the fact that the first AT coordinator recovery scan has completed.
void	setSubordinateCoordinatorRecoveryStarted() record the fact that the first AT subordinate coordinator recovery scan has completed.
void	unregisterRecoveryModule(XTSATRecoveryModule module) unregister an application specific recovery module previously registered as a helper to recretae WS-AT durable participants
boolean	writeParticipantRecoveryRecord(ATParticipantRecoveryRecord participantRecoveryRecord) save the supplied participant recovery record to persistent storage

Methods inherited from class org.jboss.jbossts.xts.recovery.participant.at.XTSATRecoveryManager

getRecoveryManager, setRecoveryManager

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

XTSATRecoveryManagerImple

public XTSATRecoveryManagerImple(com.arjuna.ats.arjuna.objectstore.TxLog txLog)

constructor for use by ATParticipantRecoveryModule and ATCoordinatorRecoveryModule

Parameters:

txLog -

Method Detail

isRecoveryManagerInitialised

public static boolean isRecoveryManagerInitialised()

registerRecoveryModule

public void registerRecoveryModule(XTSATRecoveryModule module)
                            throws NullPointerException

register an application specific recovery module which acts as a helper to recreate a WS-AT durable participant from the participant's recovery data saved at prepare

Specified by:

registerRecoveryModule in class XTSATRecoveryManager

Parameters:

module - the module which will be used to identify and recreate participants for the application

Throws:

NullPointerException - if the supplied module is null

unregisterRecoveryModule

public void unregisterRecoveryModule(XTSATRecoveryModule module)
                              throws NoSuchElementException

unregister an application specific recovery module previously registered as a helper to recretae WS-AT durable participants

Specified by:

unregisterRecoveryModule in class XTSATRecoveryManager

Parameters:

module - the module to be unregistered

Throws:

NoSuchElementException - if the module is not currently registered

writeParticipantRecoveryRecord

public boolean writeParticipantRecoveryRecord(ATParticipantRecoveryRecord participantRecoveryRecord)

save the supplied participant recovery record to persistent storage

Specified by:

writeParticipantRecoveryRecord in class XTSATRecoveryManager

Parameters:

participantRecoveryRecord -

deleteParticipantRecoveryRecord

public boolean deleteParticipantRecoveryRecord(String id)

remove any participant recovery record with the supplied id from persistent storage

Specified by:

deleteParticipantRecoveryRecord in class XTSATRecoveryManager

Parameters:

id - the id of the participant whose recovery details are being deleted

isParticipantPresent

public boolean isParticipantPresent(com.arjuna.ats.arjuna.common.Uid uid)

test whether the supplied uid identifies an active participant or a recovered but inactive participant n.b. this method is not synchronized because of two assumptions: first, that uids are never reused; and second that only recovery scanning (as a minimum, for a given recovery record type) is single-threaded. Correctness of the first assumption ensures there are no races with participant processor threads, the second races between recovery threads.

Specified by:

isParticipantPresent in class XTSATRecoveryManager

Parameters:

uid -

addParticipantRecoveryRecord

public void addParticipantRecoveryRecord(com.arjuna.ats.arjuna.common.Uid uid,
                                         ATParticipantRecoveryRecord participantRecoveryRecord)

add a recovered participant record to the table of unrecovered participants which need to be recreated following recovery

Specified by:

addParticipantRecoveryRecord in class XTSATRecoveryManager

Parameters:

uid - the uid under which the participant was saved in the file store

participantRecoveryRecord - the in-memory representation of the recovery record saved to disk

findParticipantRecoveryRecord

public ATParticipantRecoveryRecord findParticipantRecoveryRecord(String id)

see if a participant recovery record with a given id exists in the table of participants which need to be recreated following recovery

Specified by:

findParticipantRecoveryRecord in class XTSATRecoveryManager

Parameters:

id - the identifier of the participant being sought

Returns:

the participant recovery record with the supplied id or null if it is not found

recoverParticipants

public void recoverParticipants()

process all entries in the recovered participant map and attempt to recreate the application participant and activate it

Specified by:

recoverParticipants in class XTSATRecoveryManager

isParticipantRecoveryStarted

public boolean isParticipantRecoveryStarted()

test whether the first AT participant recovery scan has completed. this indicates whether there may or may not still be unknown participant recovery records on disk. If the first scan has not yet completed then a commit or rollback message for an unknown participant must be dropped. If it has then a commit or rollback for an unknown participant must be acknowledged with, respectively, a committed or aborted message.

Specified by:

isParticipantRecoveryStarted in class XTSATRecoveryManager

isCoordinatorRecoveryStarted

public boolean isCoordinatorRecoveryStarted()

test whether the first AT coordinator recovery scan has completed. this indicates whether there may or may not still be unknown AT transcation records on disk. If the first scan has not yet completed then a prepare message for an unknown participant must be dropped. If it has then a perpare for an unknown participant must be acknowledged with a rollback message.

Specified by:

isCoordinatorRecoveryStarted in class XTSATRecoveryManager

isSubordinateCoordinatorRecoveryStarted

public boolean isSubordinateCoordinatorRecoveryStarted()

test whether the first AT subordinate coordinator recovery scan has completed. this indicates whether there may or may not still be unknown AT subtransaction records on disk. If the first scan has not yet completed then a commit for an unknown subtransaction must raise an exception delaying commit of the parent transaction.

Specified by:

isSubordinateCoordinatorRecoveryStarted in class XTSATRecoveryManager

setCoordinatorRecoveryStarted

public void setCoordinatorRecoveryStarted()

record the fact that the first AT coordinator recovery scan has completed.

Specified by:

setCoordinatorRecoveryStarted in class XTSATRecoveryManager

setSubordinateCoordinatorRecoveryStarted

public void setSubordinateCoordinatorRecoveryStarted()

record the fact that the first AT subordinate coordinator recovery scan has completed.

Specified by:

setSubordinateCoordinatorRecoveryStarted in class XTSATRecoveryManager