|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object rice.pastry.client.PastryAppl rice.pastry.standard.PeriodicLeafSetProtocol
An implementation of a periodic-style leafset protocol
Nested Class Summary | |
static class |
PeriodicLeafSetProtocol.PLSPMessageDeserializer
DESCRIBE THE CLASS |
Field Summary | |
int |
CHECK_LIVENESS_PERIOD
DESCRIBE THE FIELD |
protected java.util.WeakHashMap |
lastTimeReceivedBLS
NodeHandle -> Long remembers the TIME when we received a BLS from that NodeHandle |
protected LeafSet |
leafSet
DESCRIBE THE FIELD |
protected NodeHandle |
localHandle
DESCRIBE THE FIELD |
protected PastryNode |
localNode
DESCRIBE THE FIELD |
int |
PING_NEIGHBOR_PERIOD
Related to rapidly determining direct neighbor liveness. |
protected RoutingTable |
routeTable
DESCRIBE THE FIELD |
Fields inherited from class rice.pastry.client.PastryAppl |
address, deserializer, instance, logger, receiver, thePastryNode |
Constructor Summary | |
PeriodicLeafSetProtocol(PastryNode ln,
NodeHandle local,
LeafSet ls,
RoutingTable rt)
Builds a periodic leafset protocol |
Method Summary | |
protected void |
broadcastAll()
Broadcast the leaf set to all members of the local leaf set. |
boolean |
deliverWhenNotReady()
We always want to receive messages. |
void |
destroy()
DESCRIBE THE METHOD |
void |
messageForAppl(Message msg)
Should not be called becasue we are overriding the receiveMessage() interface anyway. |
void |
receiveMessage(Message msg)
Receives messages. |
Methods inherited from class rice.pastry.client.PastryAppl |
accept, connect, enrouteMessage, getAddress, getLeafSet, getNodeHandle, getNodeId, getRoutingTable, isClosest, leafSetChange, notifyReady, receiveMessageInternal, receiveSocket, register, routeMsg, routeMsgDirect, routeSetChange, setDeserializer, update |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected NodeHandle localHandle
protected PastryNode localNode
protected LeafSet leafSet
protected RoutingTable routeTable
protected java.util.WeakHashMap lastTimeReceivedBLS
public final int PING_NEIGHBOR_PERIOD
public final int CHECK_LIVENESS_PERIOD
Constructor Detail |
public PeriodicLeafSetProtocol(PastryNode ln, NodeHandle local, LeafSet ls, RoutingTable rt)
ln
- DESCRIBE THE PARAMETERlocal
- DESCRIBE THE PARAMETERls
- DESCRIBE THE PARAMETERrt
- DESCRIBE THE PARAMETERMethod Detail |
public void receiveMessage(Message msg)
receiveMessage
in class PastryAppl
msg
- the message.protected void broadcastAll()
public void messageForAppl(Message msg)
messageForAppl
in class PastryAppl
msg
- DESCRIBE THE PARAMETERpublic boolean deliverWhenNotReady()
deliverWhenNotReady
in class PastryAppl
public void destroy()
destroy
in class PastryAppl
|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |