public class ClientFSM extends java.lang.Object implements akka.actor.Actor, akka.actor.LoggingFSM<ClientFSM.State,ClientFSM.Data>, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>
Player
side: in a first step it registers itself with a symbolic name and its remote
address at the Controller
, then waits for the
Done
message which signals that all other expected test participants have
done the same. After that, it will pass barrier requests to and from the
coordinator and react to the Conductor
’s
requests for failure injection.
Note that you can't perform requests concurrently, e.g. enter barrier from one thread and ask for node address from another thread.
INTERNAL API.
Modifier and Type | Class and Description |
---|---|
static class |
ClientFSM.AwaitDone$ |
static class |
ClientFSM.Connected |
static class |
ClientFSM.Connected$ |
static class |
ClientFSM.Connecting$ |
static class |
ClientFSM.ConnectionFailure |
static class |
ClientFSM.ConnectionFailure$ |
static class |
ClientFSM.Data |
static class |
ClientFSM.Data$ |
static class |
ClientFSM.Disconnected$ |
static class |
ClientFSM.Failed$ |
static interface |
ClientFSM.State |
akka.actor.FSM.$minus$greater$, akka.actor.FSM.CurrentState<S>, akka.actor.FSM.CurrentState$, akka.actor.FSM.Event<D>, akka.actor.FSM.Event$, akka.actor.FSM.Failure, akka.actor.FSM.Failure$, akka.actor.FSM.LogEntry<S,D>, akka.actor.FSM.LogEntry$, akka.actor.FSM.Normal$, akka.actor.FSM.NullFunction$, akka.actor.FSM.Reason, akka.actor.FSM.Shutdown$, akka.actor.FSM.SilentState<S,D>, akka.actor.FSM.State$, akka.actor.FSM.StateTimeout$, akka.actor.FSM.StopEvent<S,D>, akka.actor.FSM.StopEvent$, akka.actor.FSM.SubscribeTransitionCallBack, akka.actor.FSM.SubscribeTransitionCallBack$, akka.actor.FSM.TimeoutMarker, akka.actor.FSM.TimeoutMarker$, akka.actor.FSM.Timer, akka.actor.FSM.Timer$, akka.actor.FSM.TransformHelper, akka.actor.FSM.Transition<S>, akka.actor.FSM.Transition$, akka.actor.FSM.UnsubscribeTransitionCallBack, akka.actor.FSM.UnsubscribeTransitionCallBack$
Constructor and Description |
---|
ClientFSM(RoleName name,
java.net.InetSocketAddress controllerAddr) |
Modifier and Type | Method and Description |
---|---|
PlayerHandler |
handler() |
akka.remote.testconductor.TestConductorExt.Settings$ |
settings() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$events_$eq, akka$actor$LoggingFSM$_setter_$akka$actor$LoggingFSM$$states_$eq, akka$actor$LoggingFSM$_setter_$debugEvent_$eq, akka$actor$LoggingFSM$$events, akka$actor$LoggingFSM$$full_$eq, akka$actor$LoggingFSM$$full, akka$actor$LoggingFSM$$pos_$eq, akka$actor$LoggingFSM$$pos, akka$actor$LoggingFSM$$states, debugEvent, getLog, logDepth, processEvent
$minus$greater, akka$actor$FSM$_setter_$$minus$greater_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$handleEventDefault_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateFunctions_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$stateTimeouts_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timerGen_$eq, akka$actor$FSM$_setter_$akka$actor$FSM$$timers_$eq, akka$actor$FSM$_setter_$Event_$eq, akka$actor$FSM$_setter_$StateTimeout_$eq, akka$actor$FSM$_setter_$StopEvent_$eq, akka$actor$FSM$$currentState_$eq, akka$actor$FSM$$currentState, akka$actor$FSM$$generation_$eq, akka$actor$FSM$$generation, akka$actor$FSM$$handleEvent_$eq, akka$actor$FSM$$handleEvent, akka$actor$FSM$$handleEventDefault, akka$actor$FSM$$nextState_$eq, akka$actor$FSM$$nextState, akka$actor$FSM$$stateFunctions, akka$actor$FSM$$stateTimeouts, akka$actor$FSM$$terminateEvent_$eq, akka$actor$FSM$$terminateEvent, akka$actor$FSM$$timeoutFuture_$eq, akka$actor$FSM$$timeoutFuture, akka$actor$FSM$$timerGen, akka$actor$FSM$$timers, akka$actor$FSM$$transitionEvent_$eq, akka$actor$FSM$$transitionEvent, applyState, cancelTimer, Event, goto, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, setStateTimeout, setTimer, setTimer$default$4, startWith, startWith$default$3, stateData, stateName, StateTimeout, stay, stop, stop, stop, StopEvent, total2pf, transform, when, when$default$2, whenUnhandled
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
public ClientFSM(RoleName name, java.net.InetSocketAddress controllerAddr)
public akka.remote.testconductor.TestConductorExt.Settings$ settings()
public PlayerHandler handler()