rice.scribe.testing
Class DistScribeRegrTest

java.lang.Object
  rice.scribe.testing.DistScribeRegrTest

public class DistScribeRegrTest

extends java.lang.Object

Field Summary

java.util.Vector	distClients
static double	fractionUnsubscribedAllowed
static int	IDLE_TIME
java.util.Vector	localNodes
static java.lang.Object	LOCK
java.lang.Integer	num
static int	NUM_TOPICS
static int	protocol
static int	UNSUBSCRIBE_LIMIT
static double	UNSUBSCRIBE_PROBABILITY

Constructor Summary

DistScribeRegrTest()

Method Summary

static NodeId	generateTopicId(java.lang.String topicName)
static int	getNumUnsubscribed(NodeId topicId)
static void	incrementNumUnsubscribed(NodeId topicId)
static void	main(java.lang.String[] args) Usage: DistScribeRegrTest [-nodes n] [-port p] [-bootstrap bshost[:bsport]] [-protocol [wire,rmi]] [-help].
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

Field Detail

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

Constructor Detail

DistScribeRegrTest

public DistScribeRegrTest()

Method Detail

getNumUnsubscribed

public static int getNumUnsubscribed(NodeId topicId)

incrementNumUnsubscribed

public static void incrementNumUnsubscribed(NodeId topicId)

generateTopicId

public static NodeId generateTopicId(java.lang.String topicName)

makeScribeNode

public 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.