|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Nested Class Summary | |
static class |
ScribePolicy.DefaultScribePolicy
The default policy for Scribe, which always allows new children to join and adds children in the order in which they are provided, implicitly providing a depth-first search. |
static class |
ScribePolicy.LimitedScribePolicy
An optional policy for Scribe, which allows up to a specified number of children per topic. |
Method Summary | |
boolean |
allowSubscribe(rice.p2p.scribe.messaging.SubscribeMessage message,
rice.p2p.scribe.ScribeClient[] clients,
rice.p2p.commonapi.NodeHandle[] children)
This method is called when the newChild is about to become our child, and the policy should return whether or not the child should be allowed to become our child. |
void |
directAnycast(rice.p2p.scribe.messaging.AnycastMessage message,
rice.p2p.commonapi.NodeHandle parent,
rice.p2p.commonapi.NodeHandle[] children)
This method is called when an anycast is received which is not satisfied at the local node. |
Method Detail |
public boolean allowSubscribe(rice.p2p.scribe.messaging.SubscribeMessage message, rice.p2p.scribe.ScribeClient[] clients, rice.p2p.commonapi.NodeHandle[] children)
message
- The subscribe message in questionchildren
- The list of children who are currently subscribed to this topicclients
- The list of clients are are currently subscribed to this topic
public void directAnycast(rice.p2p.scribe.messaging.AnycastMessage message, rice.p2p.commonapi.NodeHandle parent, rice.p2p.commonapi.NodeHandle[] children)
message
- The anycast message in questionparent
- Our current parent for this message's topicchildren
- Our current children for this message's topic
|
Rice Pastry API | ||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |