rice.scribe.testing
Class DistScribeRegrTest
java.lang.Object
|
+--rice.scribe.testing.DistScribeRegrTest
- public class DistScribeRegrTest
- extends java.lang.Object
- Version:
- $Id: DistScribeRegrTest.java,v 1.18 2002/09/14 18:22:37 druschel Exp $
- Author:
- Animesh Nandi, Atul Singh
Method Summary |
static rice.pastry.NodeId |
generateTopicId(java.lang.String topicName)
|
static int |
getNumUnsubscribed(rice.pastry.NodeId topicId)
|
static void |
incrementNumUnsubscribed(rice.pastry.NodeId topicId)
|
static void |
main(java.lang.String[] args)
Usage: DistScribeRegrTest [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-protocol [wire,rmi]]
[-help]. |
rice.pastry.PastryNode |
makeScribeNode()
Create a Pastry node and add it to pastryNodes. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
distClients
public java.util.Vector distClients
localNodes
public java.util.Vector localNodes
num
public java.lang.Integer num
NUM_TOPICS
public static int NUM_TOPICS
UNSUBSCRIBE_LIMIT
public static int UNSUBSCRIBE_LIMIT
UNSUBSCRIBE_PROBABILITY
public static double UNSUBSCRIBE_PROBABILITY
fractionUnsubscribedAllowed
public static double fractionUnsubscribedAllowed
LOCK
public static java.lang.Object LOCK
IDLE_TIME
public static int IDLE_TIME
protocol
public static int protocol
DistScribeRegrTest
public DistScribeRegrTest()
getNumUnsubscribed
public static int getNumUnsubscribed(rice.pastry.NodeId topicId)
incrementNumUnsubscribed
public static void incrementNumUnsubscribed(rice.pastry.NodeId topicId)
generateTopicId
public static rice.pastry.NodeId generateTopicId(java.lang.String topicName)
makeScribeNode
public rice.pastry.PastryNode makeScribeNode()
- Create a Pastry node and add it to pastryNodes. Also create a client
application for this node, and spawn off a separate thread for it.
- Returns:
- the PastryNode on which the Scribe application exists
main
public static void main(java.lang.String[] args)
- Usage: DistScribeRegrTest [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-protocol [wire,rmi]]
[-help].
Ports p and bsport refer to WIRE/RMI port numbers (default = 5009).
Without -bootstrap bshost[:bsport], only localhost:p is used for bootstrap.
Copyright © 2001 - Rice Pastry.