weblogic.wtc.jatmi

Class TuxXidRply

java.lang.Object

weblogic.wtc.jatmi.TuxXidRply

public final class TuxXidRply
extends java.lang.Object

Excluded in public API Reference.

This is a reply object upon which replies can be enqueued

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	TuxXidRply.LockReqXid

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.LinkedList	genWaiters
private TXidERFactory	myERFactory
private java.util.HashMap	myMap
private java.util.LinkedList	specWaiters

Constructor Summary

Constructors

Constructor and Description
TuxXidRply()
TuxXidRply(TXidERFactory anERFactory)

Method Summary

Modifier and Type	Method and Description
void	add_reply(gwatmi where_from, Txid txid, tfmh message)
ReqXidMsg	get_reply(boolean block)
tfmh	get_specific_reply(ReqXidOid request_oid, boolean block)
private TuxXidRply.LockReqXid	getEligibleWaiter(ReqXidOid reqXidOid)

Methods inherited from class java.lang.Object

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

Field Detail

myMap

private java.util.HashMap myMap

genWaiters

private java.util.LinkedList genWaiters

specWaiters

private java.util.LinkedList specWaiters

myERFactory

private TXidERFactory myERFactory

Constructor Detail

TuxXidRply

public TuxXidRply()

TuxXidRply

public TuxXidRply(TXidERFactory anERFactory)

Method Detail

add_reply

public void add_reply(gwatmi where_from,
                      Txid txid,
                      tfmh message)

Parameters:

where_from - From which gwatmi object did this request come from

reqid - The gwatmi instance request id associated with this message

txid - The transaction key associated with this message

message - The reply message

Excluded in public API Reference.

adds a reply message from a previous request

get_reply

public ReqXidMsg get_reply(boolean block)

Parameters:

block - Should I block until this message arrives?

Returns:

A ReqXidMsg object that fully describes the reply or null if block is false and there are no messages to retrieve

Excluded in public API Reference.

Gets a reply message

get_specific_reply

public tfmh get_specific_reply(ReqXidOid request_oid,
                               boolean block)

Parameters:

request_oid - The request object identifier for this request

block - Should we block waiting for this reply

Returns:

The reply message, or null if there is none (and we are not blocking)

Excluded in public API Reference.

Gets a specific reply message

getEligibleWaiter

private TuxXidRply.LockReqXid getEligibleWaiter(ReqXidOid reqXidOid)

Parameters:

reqXidOid - the id of the reply for which a waiters is to be found

Returns:

The LockReqXid identifying the matched waiter.

Excluded in public API Reference.

Gets a suitable waiter for the reply identified by reqXidOid. The waiter could be one waiting specifically for this reqXidOid (specific waiter) or one waiting for any reqXidOid (generic waiter). Preference given to specific waiter. Selected waiter is removed from appropriate waiter list and returned.