org.opendaylight.controller.cluster.example

Class TestDriver

java.lang.Object

org.opendaylight.controller.cluster.example.TestDriver

public class TestDriver
extends Object

This is a test driver for testing akka-raft implementation Its uses ExampleActors and threads to push content(key-vals) to these actors Each ExampleActor can have one or more ClientActors. Each ClientActor spawns a thread and starts push logs to the actor its assigned to.

Constructor Summary

Constructors

Constructor and Description
TestDriver()

Method Summary

Modifier and Type	Method and Description
void	addClients(int num)
void	addClientsToNode(String actorName, int num)
static akka.actor.ActorRef	createExampleActor(String name)
void	createNodes(int num)
akka.actor.ActorRef	getLeader()
static void	main(String[] args) Create nodes, add clients and start logging.
void	printNodes()
void	printState()
void	reinstateNode(String actorName)
void	startAllLogging()
void	startLoggingForClient(akka.actor.ActorRef client)
void	stopAllLogging()
void	stopLoggingForClient(akka.actor.ActorRef client)
void	stopNode(String actorName)

Methods inherited from class java.lang.Object

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

Constructor Detail

TestDriver

public TestDriver()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Create nodes, add clients and start logging. Commands bye createNodes:{num} stopNode:{nodeName} reinstateNode:{nodeName} addClients:{num} addClientsToNode:{nodeName, num} startLogging stopLogging startLoggingForClient:{nodeName} stopLoggingForClient:{nodeName} printNodes printState

Note: when run on IDE and on debug log level, the debug logs in AbstractUptypedActor and AbstractUptypedPersistentActor would need to be commented out. Also RaftActor handleCommand(), debug log which prints for every command other than AE/AER

Throws:

Exception

createExampleActor

public static akka.actor.ActorRef createExampleActor(String name)

createNodes

public void createNodes(int num)

addClients

public void addClients(int num)

addClientsToNode

public void addClientsToNode(String actorName,
                             int num)

stopNode

public void stopNode(String actorName)

reinstateNode

public void reinstateNode(String actorName)

startAllLogging

public void startAllLogging()

startLoggingForClient

public void startLoggingForClient(akka.actor.ActorRef client)

stopAllLogging

public void stopAllLogging()

stopLoggingForClient

public void stopLoggingForClient(akka.actor.ActorRef client)

printState

public void printState()

printNodes

public void printNodes()

getLeader

public akka.actor.ActorRef getLeader()