com.arjuna.ats.internal.jts

Class ControlWrapper

java.lang.Object

com.arjuna.ats.internal.jts.ControlWrapper

All Implemented Interfaces:

Reapable

Direct Known Subclasses:

ServerControlWrapper

public class ControlWrapper
extends Object
implements Reapable

This class attempts to mask the local/remote control issue. We try to use local controls directly as much as possible and not register them with the ORB until the last minute. This improves performance *significantly*. At present we only do this for top-level transactions, but extending for nested transactions is straightforward. It also acts as a convenience class for ease of use. Therefore, some Coordinator and Terminator methods may be found directly on this class. Because of the way in which the implementation works, however, some of their signatures may be slightly different.

Since:

JTS 2.0.

Version:

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

Author:

Mark Little (mark_little@hp.com)

Constructor Summary

Constructors

Constructor and Description
ControlWrapper(Control c)
ControlWrapper(Control c, ControlImple impl)
ControlWrapper(ControlImple impl)
ControlWrapper(Control c, Uid u)

Method Summary

Methods

Modifier and Type	Method and Description
int	cancel()
void	commit(boolean report_heuristics)
ControlWrapper	create_subtransaction()
void	determineLocality() Determine whether or not we are a local control.
boolean	equals(Object e) Overrides Object.equals Does not compare Uids because a foreign transaction may have been imported more than once and given different local ids.
Control	get_control()
Coordinator	get_coordinator()
Status	get_status()
Terminator	get_terminator()
String	get_transaction_name()
Uid	get_uid()
Control	getControl()
ControlImple	getImple()
Map<Uid,String>	getSynchronizations()
int	hash_transaction()
int	hashCode() Override Object.hashCode.
boolean	isLocal()
boolean	preventCommit()
RecoveryCoordinator	register_resource(Resource r)
void	register_subtran_aware(SubtransactionAwareResource sr)
void	register_synchronization(Synchronization sync)
void	rollback_only()
void	rollback()
boolean	running()
String	toString() Override Object.toString.

Methods inherited from class java.lang.Object

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

Constructor Detail

ControlWrapper

public ControlWrapper(Control c)

ControlWrapper

public ControlWrapper(ControlImple impl)

ControlWrapper

public ControlWrapper(Control c,
              ControlImple impl)

ControlWrapper

public ControlWrapper(Control c,
              Uid u)

Method Detail

running

public boolean running()

Specified by:

running in interface Reapable

preventCommit

public boolean preventCommit()

Specified by:

preventCommit in interface Reapable

cancel

public int cancel()

Specified by:

cancel in interface Reapable

get_uid

public Uid get_uid()

Specified by:

get_uid in interface Reapable

create_subtransaction

public ControlWrapper create_subtransaction()
                                     throws Unavailable,
                                            Inactive,
                                            SubtransactionsUnavailable,
                                            SystemException

Throws:

Unavailable

Inactive

SubtransactionsUnavailable

SystemException

commit

public final void commit(boolean report_heuristics)
                  throws Unavailable,
                         HeuristicMixed,
                         HeuristicHazard,
                         SystemException

Throws:

Unavailable

HeuristicMixed

HeuristicHazard

SystemException

rollback

public final void rollback()
                    throws Unavailable,
                           NoTransaction,
                           SystemException

Throws:

Unavailable

NoTransaction

SystemException

rollback_only

public final void rollback_only()
                         throws Unavailable,
                                NoTransaction,
                                Inactive,
                                SystemException

Throws:

Unavailable

NoTransaction

Inactive

SystemException

register_resource

public final RecoveryCoordinator register_resource(Resource r)
                                            throws Inactive,
                                                   SystemException

Throws:

Inactive

SystemException

register_subtran_aware

public final void register_subtran_aware(SubtransactionAwareResource sr)
                                  throws Inactive,
                                         NotSubtransaction,
                                         SystemException

Throws:

Inactive

NotSubtransaction

SystemException

register_synchronization

public final void register_synchronization(Synchronization sync)
                                    throws Inactive,
                                           SynchronizationUnavailable,
                                           SystemException

Throws:

Inactive

SynchronizationUnavailable

SystemException

getSynchronizations

public Map<Uid,String> getSynchronizations()

get_status

public final Status get_status()
                        throws SystemException

Throws:

SystemException

get_transaction_name

public final String get_transaction_name()
                                  throws SystemException

Throws:

SystemException

get_control

public final Control get_control()
                          throws Unavailable,
                                 SystemException

Throws:

Unavailable

SystemException

get_coordinator

public final Coordinator get_coordinator()
                                  throws SystemException,
                                         Unavailable

Throws:

SystemException

Unavailable

get_terminator

public final Terminator get_terminator()
                                throws SystemException,
                                       Unavailable

Throws:

SystemException

Unavailable

hash_transaction

public final int hash_transaction()
                           throws SystemException

Throws:

SystemException

equals

public boolean equals(Object e)

Overrides Object.equals Does not compare Uids because a foreign transaction may have been imported more than once and given different local ids.

Overrides:

equals in class Object

toString

public String toString()

Override Object.toString.

Overrides:

toString in class Object

Since:

JTS 2.1.1.

hashCode

public int hashCode()

Override Object.hashCode. We always return a positive value.

Overrides:

hashCode in class Object

getControl

public final Control getControl()

getImple

public final ControlImple getImple()

isLocal

public final boolean isLocal()

determineLocality

public final void determineLocality()

Determine whether or not we are a local control. Only do this once since locality is not likely to change!