org.iids.aos.kernel.ac
Class ShipmentRendezvousTable

java.lang.Object
  org.iids.aos.kernel.ac.ShipmentRendezvousTable

public class ShipmentRendezvousTable
extends java.lang.Object

Table to do the synchronization between "client" threads receiving ACs via waitAgentContainer() and the threads reading the ACs from the network.

Author:

arno

Field Summary

protected AgentContainerTable	agentContainerTable The list of agent containers
protected static org.apache.commons.logging.Log	log
protected java.util.ArrayList<Shipment>	shipments List of arrived shipments

Constructor Summary

ShipmentRendezvousTable(AgentContainerTable agentContainerTable)

Method Summary

boolean	dropoffShipment(Shipment s) Used by network reader thread to signal the presence of a new shipment
org.iids.aos.kernel.ac.ShipmentRendezvousTable.AckedShipment[]	getAckedShipments() REBOOT Return the list of succesfully received ACs for reboot purposes.
Shipment	pickupShipment(java.util.HashMap<TransactionID,TIDRecord> tidrecs, int blockTime) Used by client thread to pickup a shipment, which may have been unsuccesful

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.apache.commons.logging.Log log

shipments

protected java.util.ArrayList<Shipment> shipments

List of arrived shipments

agentContainerTable

protected AgentContainerTable agentContainerTable

The list of agent containers

Constructor Detail

ShipmentRendezvousTable

public ShipmentRendezvousTable(AgentContainerTable agentContainerTable)

Method Detail

pickupShipment

public Shipment pickupShipment(java.util.HashMap<TransactionID,TIDRecord> tidrecs,
                               int blockTime)
                        throws UnknownRoleException,
                               ACTPTimeoutException

Used by client thread to pickup a shipment, which may have been unsuccesful

Throws:

UnknownRoleException

ACTPTimeoutException

dropoffShipment

public boolean dropoffShipment(Shipment s)

Used by network reader thread to signal the presence of a new shipment

getAckedShipments

public org.iids.aos.kernel.ac.ShipmentRendezvousTable.AckedShipment[] getAckedShipments()

REBOOT Return the list of succesfully received ACs for reboot purposes.