atropos.lp
Class AvnmpSndQueue

java.lang.Object
  |
  +--java.util.AbstractCollection
        |
        +--java.util.AbstractList
              |
              +--java.util.Vector
                    |
                    +--atropos.util.OrderedList
                          |
                          +--atropos.lp.AvnmpQueue
                                |
                                +--atropos.lp.AvnmpSndQueue

All Implemented Interfaces:

java.lang.Cloneable, java.util.Collection, java.util.List, java.io.Serializable

public class AvnmpSndQueue

extends AvnmpQueue

This class implements the send queue for the AVNMP LP.

This research is funded by DARPA/ITO Contract Number: F30602-98-C-0230 supported by the Air Force Research Laboratory/IF.

Version:

$Revision: 1.1.1.1 $ $State: Exp $

Author:

Steve Bush

See Also:

Serialized Form

Fields inherited from class atropos.lp.AvnmpQueue

QueueName

Fields inherited from class java.util.Vector

capacityIncrement, elementCount, elementData

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

AvnmpSndQueue()
Construct an empty send queue.

Method Summary

AvnmpPacket	rbq(long rt, AvnmpLP mylp) Send Anti-messages from a time equal or greater than the parameter.
void	RemoveFossils(long t) Remove messages with a value less than the given time.
AvnmpPacket	sendvm(AvnmpPacket ap, AvnmpLP mylp, AvnmpTime lvt) Cache a virtual message which is to be sent.

Methods inherited from class atropos.lp.AvnmpQueue

add, addMessage, append, cancel, compare, deleteMessage, getClosestTime, getGreaterOrEqualRecTime, getGreaterOrEqualSndTime, getGreaterRecTime, getGreaterSndTime, getLessOrEqualRecTime, getLessOrEqualSndTime, getLessRecTime, getLessSndTime, getMessage, getReal, getVirtual, numReal, numVirtual, plotQueue, QtoString, queueSize, remove

Methods inherited from class atropos.util.OrderedList

clear, get, remove

Methods inherited from class java.util.Vector

add, addAll, addAll, addElement, capacity, clone, contains, containsAll, copyInto, elementAt, elements, ensureCapacity, equals, firstElement, hashCode, indexOf, indexOf, insertElementAt, isEmpty, lastElement, lastIndexOf, lastIndexOf, removeAll, removeAllElements, removeElement, removeElementAt, removeRange, retainAll, set, setElementAt, setSize, size, subList, toArray, toArray, toString, trimToSize

Methods inherited from class java.util.AbstractList

iterator, listIterator, listIterator

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.List

iterator, listIterator, listIterator

Constructor Detail

AvnmpSndQueue

public AvnmpSndQueue()

Construct an empty send queue.

Method Detail

sendvm

public AvnmpPacket sendvm(AvnmpPacket ap,
                          AvnmpLP mylp,
                          AvnmpTime lvt)

Cache a virtual message which is to be sent.

Parameters:

ap - The packet being sent

mylp - The current logical process.

lvt - The local virtual time of this logical process

Returns:

The packet being sent

RemoveFossils

public void RemoveFossils(long t)

Remove messages with a value less than the given time. Clean out fossils.

Parameters:

t - Remove values less than this time.

rbq

public AvnmpPacket rbq(long rt,
                       AvnmpLP mylp)

Send Anti-messages from a time equal or greater than the parameter. Call repeatedly and send anti-messages until null returned.

Parameters:

rt - The time to which the process rolled back.

mylp - The current logical process.

Returns:

The next anti-message to send.