|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object lime.TransDescriptor lime.InitiatorTransDescriptor
A descriptor of a transaction for the host that initiated the transaction.
Field Summary | |
(package private) AgentID |
agent
The agent that initiated the transaction (AGENT_HELLO,AGENT_BYE). |
static java.lang.String |
AGENT
|
static short |
AGENT_BYE
|
static java.lang.String |
AGENT_GONE
|
static short |
AGENT_HELLO
|
static int |
AGENT_ID_TAG
|
static short |
AGENT_LOCALHOST
|
static short |
AGENT_NOTINSYS
|
static short |
AGENT_REMOTE
|
static short |
AGENT_UNSPECIFIED
|
(package private) java.util.Hashtable |
agents
Hashtable of agents. |
static short |
DATA
|
static short |
DECLARE_LEADER
|
static short |
DISENGAGE_AGENT
|
static short |
DISENGAGE_HOST
|
static short |
ENGAGE_AGENT
|
static short |
ENGAGE_HOST
|
static short |
GO
|
static java.lang.String |
HOST
|
static int |
HOST_ADDR_TAG
|
static short |
HOST_BYE
|
static java.lang.String |
HOST_GONE
|
static short |
HOST_HELLO
|
static short |
HOST_LOCALHOST
|
static short |
HOST_NOTINSYS
|
static short |
HOST_REMOTE
|
static int |
HOST_TUPLE_HOST_TAG
|
static short |
HOST_UNSPECIFIED
|
(package private) java.util.Hashtable |
hostsAgents
The hashtable from each host to a hashtable of its agents and TSs. |
(package private) java.util.Vector |
hostsDataReceived
LimeServers from which a DATA message has been received. |
(package private) java.util.Vector |
hostsDataSent
LimeServers to which DATA message has been sent This is used only during host engagements. |
static short |
ING
|
static short |
INITIATOR_REQ
|
static short |
INST_REACTS_TO
|
static short |
INST_REM_UPON_LISTENER
|
static short |
INST_UPON_LISTENER
|
static short |
LOCAL_SYS_TAKE
|
(package private) Result |
lock
The lock used by the transaction. |
(package private) java.util.Hashtable |
lstsHostAgents
|
(package private) LimeTupleSpace[] |
lts
The tuple spaces owned by the agent involved in the transaction |
private java.util.Hashtable |
ltsH
Maps a name of the tuple space to the LimeTupleSpace (which contains the ITupleSpace). |
static int |
MAX_ROUNDS
|
private java.util.Hashtable |
namedTS
Maps a name of the tuple space to the ITupleSpace. |
static short |
OUTG
|
static short |
RDG
|
static short |
REACTS_TO
|
static short |
READ
|
static short |
READY
|
static short |
READY_SPECIAL
|
static short |
REM_ING
|
static short |
REM_OUTG
|
static short |
REM_OUTG_ACK
|
static short |
REM_RDG
|
static short |
REM_SYS_READ
|
static short |
REM_SYS_TAKE
|
static short |
REMOVE_REACTS_TO
|
static short |
REMOVE_REM_UPON_LISTENER
|
static short |
REMOVE_UPON
|
static short |
REQUEST_TRANSACTION
|
static short |
SET_HOST
|
static short |
SET_SHARED
|
static short |
SETUP
|
static short |
SETUP_SPECIAL
|
(package private) LimeServerID |
source
The ID of the LimeServer on which this transaction was created. |
static short |
START
|
static short |
SYS_READ
|
static short |
SYS_REPLY
|
static short |
SYS_TAKE
|
static short |
TAKE
|
(package private) TransactionID |
tid
The transaction identifier. |
static short |
TRANSACTION_GRANTED
|
(package private) short |
transType
AGENT_HELLO, AGENT_BYE, HOST_HELLO, HOST_BYE |
static java.lang.String |
TS
|
static java.lang.String |
TS_GONE
|
static int |
TS_ID_TAG
|
static int |
TYPE_TAG
|
static short |
UPON
|
static short |
UPON_EVENT
|
static java.lang.String |
VERSION
|
static short |
WAIT_TO_READ
|
static short |
WAIT_TO_TAKE
|
static short |
WRITE
|
Constructor Summary | |
(package private) |
InitiatorTransDescriptor(TransactionOpDescriptor desc,
LimeTupleSpace[] lts,
Result lock)
Creates an InitiatorTransDescriptor for the specified transaction. |
Method Summary | |
(package private) void |
addEngagingTuples(java.lang.String tsName,
lights.interfaces.ITuple[] newTups)
|
(package private) AgentID[] |
getDepartingAgents()
Returns an array of AgentIDs that represent the agents that are departing. |
(package private) lights.interfaces.ITuple[] |
getEngagingTuples(java.lang.String tsName)
returns the tuples that are to be added as a result of the current transaction. |
(package private) LimeServerID[] |
getHostsDataExpected()
Returns an array of LimeServerIDs representing the hosts from which this transaction is expecting data from. |
(package private) Result |
getLock()
Returns the lock held within this object. |
(package private) java.util.Hashtable |
getLTS()
Returns a hashtable that maps the name of the tuple space to the LimeTupleSpace. |
(package private) java.util.Hashtable |
getNamedTS()
Returns a hashtable that maps the name of the tuple space to the ITupleSpace. |
(package private) boolean |
isSource()
Returns true if the LimeServer on this JVM is the one that initiated the transaction. |
(package private) boolean |
isTransDone()
Returns true if the transaction is completed. |
(package private) int |
numHostsDataExpected()
Returns the number of hosts this transaction is expecting data messges from. |
(package private) void |
setHostsDataExpected(LimeServerID[] ids)
Sets the host data expected variable within this calss. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
LimeTupleSpace[] lts
Result lock
java.util.Hashtable lstsHostAgents
private java.util.Hashtable namedTS
private java.util.Hashtable ltsH
short transType
LimeServerID source
TransactionID tid
AgentID agent
java.util.Hashtable agents
java.util.Vector hostsDataReceived
java.util.Vector hostsDataSent
java.util.Hashtable hostsAgents
public static final java.lang.String VERSION
public static final short WRITE
public static final short OUTG
public static final short REM_OUTG_ACK
public static final short TAKE
public static final short WAIT_TO_TAKE
public static final short ING
public static final short READ
public static final short WAIT_TO_READ
public static final short RDG
public static final short REACTS_TO
public static final short UPON
public static final short REMOVE_REACTS_TO
public static final short REMOVE_UPON
public static final short INST_REACTS_TO
public static final short INST_UPON_LISTENER
public static final short INST_REM_UPON_LISTENER
public static final short REMOVE_REM_UPON_LISTENER
public static final short REM_SYS_TAKE
public static final short REM_SYS_READ
public static final short REM_ING
public static final short REM_RDG
public static final short SYS_TAKE
public static final short SYS_READ
public static final short REM_OUTG
public static final short UPON_EVENT
public static final short SYS_REPLY
public static final short LOCAL_SYS_TAKE
public static final short SET_SHARED
public static final short SET_HOST
public static final short DECLARE_LEADER
public static final short ENGAGE_AGENT
public static final short ENGAGE_HOST
public static final short DISENGAGE_AGENT
public static final short DISENGAGE_HOST
public static final short GO
public static final short INITIATOR_REQ
public static final short SETUP
public static final short READY
public static final short START
public static final short DATA
public static final short SETUP_SPECIAL
public static final short READY_SPECIAL
public static final short REQUEST_TRANSACTION
public static final short TRANSACTION_GRANTED
public static final short HOST_BYE
public static final short HOST_HELLO
public static final short AGENT_BYE
public static final short AGENT_HELLO
public static final short HOST_LOCALHOST
public static final short HOST_REMOTE
public static final short HOST_NOTINSYS
public static final short HOST_UNSPECIFIED
public static final short AGENT_LOCALHOST
public static final short AGENT_REMOTE
public static final short AGENT_NOTINSYS
public static final short AGENT_UNSPECIFIED
public static final int TYPE_TAG
public static final int HOST_TUPLE_HOST_TAG
public static final int HOST_ADDR_TAG
public static final int AGENT_ID_TAG
public static final int TS_ID_TAG
public static final java.lang.String HOST
public static final java.lang.String AGENT
public static final java.lang.String TS
public static final java.lang.String HOST_GONE
public static final java.lang.String AGENT_GONE
public static final java.lang.String TS_GONE
public static final int MAX_ROUNDS
Constructor Detail |
InitiatorTransDescriptor(TransactionOpDescriptor desc, LimeTupleSpace[] lts, Result lock)
desc
- the transaction's descriptor.lts
- the LimeTupleSpaces involved in this transaction.lock
- the lock used by the transaction.Method Detail |
Result getLock()
java.util.Hashtable getLTS()
java.util.Hashtable getNamedTS()
LimeServerID[] getHostsDataExpected()
void setHostsDataExpected(LimeServerID[] ids)
int numHostsDataExpected()
boolean isSource()
void addEngagingTuples(java.lang.String tsName, lights.interfaces.ITuple[] newTups)
lights.interfaces.ITuple[] getEngagingTuples(java.lang.String tsName)
tsName
- the tuple space name
boolean isTransDone()
AgentID[] getDepartingAgents()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |