avnmp.java.lp
Class AvnmpSndQueue

java.lang.Object
  |
  +--java.util.AbstractCollection
        |
        +--java.util.AbstractSet
              |
              +--java.util.TreeSet
                    |
                    +--avnmp.java.lp.AvnmpQueue
                          |
                          +--avnmp.java.lp.AvnmpSndQueue

All Implemented Interfaces:

java.lang.Cloneable, java.util.Collection, java.util.Comparator, java.io.Serializable, java.util.Set, java.util.SortedSet

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 avnmp.java.lp.AvnmpQueue

QueueName

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 avnmp.java.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 java.util.TreeSet

addAll, clear, clone, comparator, contains, first, headSet, isEmpty, iterator, last, size, subSet, tailSet

Methods inherited from class java.util.AbstractSet

equals, hashCode, removeAll

Methods inherited from class java.util.AbstractCollection

containsAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Comparator

equals

Methods inherited from interface java.util.Set

containsAll, equals, hashCode, removeAll, retainAll, toArray, toArray

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.