rice.p2p.scribe.testing
Class ScribeRegrTest

java.lang.Object
  rice.p2p.commonapi.testing.CommonAPITest
      rice.p2p.scribe.testing.ScribeRegrTest

Direct Known Subclasses:

RawScribeRegrTest

public class ScribeRegrTest
extends CommonAPITest

Version:

$Id: ScribeRegrTest.java 4221 2008-05-19 16:41:19Z jeffh $

Author:

Alan Mislove

Nested Class Summary

protected static class	ScribeRegrTest.TestRouteMessage Utility class which simulates a route message
protected class	ScribeRegrTest.TestScribeClient DESCRIBE THE CLASS
protected static class	ScribeRegrTest.TestScribeContent Utility class for past content objects
class	ScribeRegrTest.TestScribePolicy

Field Summary

static java.lang.String	INSTANCE DESCRIBE THE FIELD
protected ScribeRegrTest.TestScribePolicy[]	policies The scribe policies
protected ScribeImpl[]	scribes DESCRIBE THE FIELD

Fields inherited from class rice.p2p.commonapi.testing.CommonAPITest

BOOTSTRAP, BOOTSTRAP_PORT, environment, factory, FACTORY, FAILURE, idFactory, INSTANCE_NAME, LEASE_PERIOD, logger, nodes, NUM_NODES, PAD_SIZE, params, PORT, PROTOCOL, PROTOCOL_DIRECT, PROTOCOL_RENDEZVOUS, PROTOCOL_SOCKET, simulator, SIMULATOR, SIMULATOR_EUCLIDEAN, SIMULATOR_GT_ITM, SIMULATOR_SPHERE, SUCCESS, TIME_TO_FIND_FAULTY

Constructor Summary

ScribeRegrTest(Environment env)
Constructor which sets up all local variables

Method Summary

static java.util.List<Topic>	buildListOf1(Topic topic)
ScribeRegrTest.TestScribeContent	buildTestScribeContent(Topic topic, int numMessages)
static void	main(java.lang.String[] args) Usage: DistScribeRegrTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]
protected void	processNode(int num, Node node) Method which should process the given newly-created node
protected void	runTest() Method which should run the test - this is called once all of the nodes have been created and are ready.
void	setupParams(Environment env)
protected void	testAddNode()
protected void	testAPI() Tests basic publish functionality
protected void	testBasic(int skip, java.lang.String name) Tests basic functionality
protected void	testFailureNotification() Tests failure notification
protected void	testMaintenance() Tests basic publish functionality
protected void	testMultiSubscribe(int skip, java.lang.String name) Makes sure that if you subscribe to multiple topics at once that they end up on different nodes.
protected void	testSingleRoot(java.lang.String name)

Methods inherited from class rice.p2p.commonapi.testing.CommonAPITest

assertEquals, assertTrue, createNode, createNodes, getBootstrap, kill, parseArgs, pause, sectionDone, sectionStart, simulate, simulate, start, stepDone, stepDone, stepDone, stepException, stepStart, waitOnClock, waitToRecoverFromKilling

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

INSTANCE

public static java.lang.String INSTANCE

DESCRIBE THE FIELD

scribes

protected ScribeImpl[] scribes

DESCRIBE THE FIELD

policies

protected ScribeRegrTest.TestScribePolicy[] policies

The scribe policies

Constructor Detail

ScribeRegrTest

public ScribeRegrTest(Environment env)
               throws java.io.IOException

Constructor which sets up all local variables

Throws:

java.io.IOException

Method Detail

buildTestScribeContent

public ScribeRegrTest.TestScribeContent buildTestScribeContent(Topic topic,
                                                               int numMessages)

setupParams

public void setupParams(Environment env)

Overrides:

setupParams in class CommonAPITest

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException

Usage: DistScribeRegrTest [-port p] [-bootstrap host[:port]] [-nodes n] [-protocol (rmi|wire)] [-help]

Parameters:

args - DESCRIBE THE PARAMETER

Throws:

java.io.IOException

processNode

protected void processNode(int num,
                           Node node)

Method which should process the given newly-created node

Specified by:

processNode in class CommonAPITest

Parameters:

node - The newly created node

num - The number of this node

runTest

protected void runTest()

Method which should run the test - this is called once all of the nodes have been created and are ready.

Specified by:

runTest in class CommonAPITest

testAddNode

protected void testAddNode()

testBasic

protected void testBasic(int skip,
                         java.lang.String name)

Tests basic functionality

testMultiSubscribe

protected void testMultiSubscribe(int skip,
                                  java.lang.String name)

Makes sure that if you subscribe to multiple topics at once that they end up on different nodes.

testAPI

protected void testAPI()

Tests basic publish functionality

testFailureNotification

protected void testFailureNotification()

Tests failure notification

testSingleRoot

protected void testSingleRoot(java.lang.String name)

testMaintenance

protected void testMaintenance()

Tests basic publish functionality

buildListOf1

public static java.util.List<Topic> buildListOf1(Topic topic)