rice.p2p.scribe
Class ScribePolicy.DefaultScribePolicy
java.lang.Object
rice.p2p.scribe.ScribePolicy.DefaultScribePolicy
- All Implemented Interfaces:
- ScribePolicy
- Direct Known Subclasses:
- RawScribeRegrTest.TestScribePolicy, ScribePolicy.LimitedScribePolicy, ScribeRegrTest.TestScribePolicy
- Enclosing interface:
- ScribePolicy
public static class ScribePolicy.DefaultScribePolicy
- extends java.lang.Object
- implements ScribePolicy
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.
- Version:
- $Id: ScribePolicy.java 3524 2007-01-09 14:09:27Z jeffh $
- Author:
- amislove
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
environment
protected Environment environment
ScribePolicy.DefaultScribePolicy
public ScribePolicy.DefaultScribePolicy(Environment env)
allowSubscribe
public boolean allowSubscribe(SubscribeMessage message,
ScribeClient[] clients,
NodeHandle[] children)
- This method always return true;
- Specified by:
allowSubscribe
in interface ScribePolicy
- Parameters:
message
- The subscribe message in questionchildren
- The list of children who are currently subscribedclients
- The list of clients are are currently subscribed
- Returns:
- True.
directAnycast
public void directAnycast(AnycastMessage message,
NodeHandle parent,
NodeHandle[] children)
- Simply adds the parent and children in order, which implements a depth-first-search.
- Specified by:
directAnycast
in interface ScribePolicy
- Parameters:
message
- The anycast message in questionparent
- Our current parent for this message's topicchildren
- Our current children for this message's topic
childAdded
public void childAdded(Topic topic,
NodeHandle child)
- Informs this policy that a child was added to a topic - the topic is free to ignore this
upcall if it doesn't care.
- Specified by:
childAdded
in interface ScribePolicy
- Parameters:
topic
- The topic to unsubscribe fromchild
- The child that was added
childRemoved
public void childRemoved(Topic topic,
NodeHandle child)
- Informs this policy that a child was removed from a topic - the topic is free to ignore this
upcall if it doesn't care.
- Specified by:
childRemoved
in interface ScribePolicy
- Parameters:
topic
- The topic to unsubscribe fromchild
- The child that was removed
Copyright © 2001-2005 - Rice Pastry.