Package com.arjuna.ats.internal.arjuna.coordinator

Class ReaperElement

java.lang.Object

com.arjuna.ats.internal.arjuna.coordinator.ReaperElement

All Implemented Interfaces:

Comparable<ReaperElement>

public class ReaperElement
extends Object
implements Comparable<ReaperElement>

Field Summary

Fields

Modifier and Type	Field	Description
final Reapable	_control
int	_status
int	_timeout
Thread	_worker
static final int	CANCEL
static final int	CANCEL_INTERRUPTED
static final int	COMPLETE
static final int	FAIL
static final int	RUN
static final int	SCHEDULE_CANCEL
static final int	TRACE	status of a reaper element which has been queued for stack trace capture by a reaper worker.
static final int	ZOMBIE

Constructor Summary

Constructors

Constructor	Description
ReaperElement(Reapable control, int cancelIntervalSeconds)
ReaperElement(Reapable control, int cancelIntervalSeconds, long traceGracePeriodMills)

Method Summary

Modifier and Type	Method	Description
int	compareTo(ReaperElement other)	Order by absoluteTimeout first, then by Uid.
boolean	equals(Object o)
long	getNextCheckAbsoluteMillis()	Returns the absolute time of the next status check, in milliseconds
long	getTransactionTimeoutAbsoluteMillis()	Returns the absolute time of the transaction expiry, in milliseconds
int	hashCode()
void	setNextCheckAbsoluteMillis(long nextCheckAbsoluteMillis)	Sets the absolute time of the next status check (i.e.
final String	statusName()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

_control

public final Reapable _control

_timeout

public int _timeout

_status

public int _status

_worker

public Thread _worker

RUN

public static final int RUN

See Also:

• Constant Field Values

SCHEDULE_CANCEL

public static final int SCHEDULE_CANCEL

See Also:

• Constant Field Values

CANCEL

public static final int CANCEL

See Also:

• Constant Field Values

CANCEL_INTERRUPTED

public static final int CANCEL_INTERRUPTED

See Also:

• Constant Field Values

FAIL

public static final int FAIL

See Also:

• Constant Field Values

COMPLETE

public static final int COMPLETE

See Also:

• Constant Field Values

ZOMBIE

public static final int ZOMBIE

See Also:

• Constant Field Values

TRACE

public static final int TRACE

status of a reaper element which has been queued for stack trace capture by a reaper worker.

See Also:

• Constant Field Values

Constructor Details

ReaperElement

public ReaperElement(Reapable control,
 int cancelIntervalSeconds)

ReaperElement

public ReaperElement(Reapable control,
 int cancelIntervalSeconds,
 long traceGracePeriodMills)

Method Details

toString

public String toString()

Overrides:

toString in class Object

compareTo

public int compareTo(ReaperElement other)

Order by absoluteTimeout first, then by Uid. This is required so that the set maintained by the TransactionReaper is in timeout order for efficient processing.

Specified by:

compareTo in interface Comparable<ReaperElement>

Parameters:

other - the ReaperElement to compare

Returns:

0 if equal, 1 if this is greater, -1 if this is smaller

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

statusName

public final String statusName()

getNextCheckAbsoluteMillis

public long getNextCheckAbsoluteMillis()

Returns the absolute time of the next status check, in milliseconds

Returns:

The absolute wakeup time, in millis

setNextCheckAbsoluteMillis

public void setNextCheckAbsoluteMillis(long nextCheckAbsoluteMillis)

Sets the absolute time of the next status check (i.e. wakeup) for this element.

Parameters:

nextCheckAbsoluteMillis - value in milliseconds

getTransactionTimeoutAbsoluteMillis

public long getTransactionTimeoutAbsoluteMillis()

Returns the absolute time of the transaction expiry, in milliseconds

Returns:

The absolute timeout time, in millis