ds.funnel.node

Class NodeBase

java.lang.Object

ds.funnel.node.compnt.NodeComponentImpl

ds.funnel.node.NodeBase

All Implemented Interfaces:

ComponentManager, NodeComponent, Node

Direct Known Subclasses:

FunTestNode, GIPlacementNode, GIResourceNode, GIStreamingNode, IOTestNode, MPTestNodeA, MPTestNodeB, RouterNode, SynapseDHTNode, TimerTestNode, UDPTestNode

public abstract class NodeBase
extends NodeComponentImpl
implements Node, ComponentManager

Nested Class Summary

Nested classes/interfaces inherited from interface ds.funnel.node.Node

Node.NodeState

Constructor Summary

Constructors

Constructor and Description
NodeBase()

Method Summary

Modifier and Type	Method and Description
static void	enterMultiCommands()
NodeComponentImpl	getComponent(NodeComponentKey inKey) Obtain the component registered with the provided key.
NodeDetails	getDetails()
java.lang.String	getName()
static NodeBase	getNode()
Node.NodeState	getState()
void	registerComponent(NodeComponentKey inKey, NodeComponentImpl inComponent) Register a component with this component manager.
boolean	runCommand(java.lang.String... cargs) Pass a command to be executed by the node.
<T> ScheduledTask<T>	runTask(ScheduledTask<T> inTask) Run a task in this node's thread pool.
void	startNode(java.lang.ThreadGroup inThreadGroup) Register this node's message events.
void	stopNode() Interrupt and stop node threads.
java.lang.String	toString()
void	unregisterComponent(NodeComponentImpl inComponent) Unregister a previously registered component.

Methods inherited from class ds.funnel.node.compnt.NodeComponentImpl

getComponentKey, getComponentLink, hashCode, setComponentKey, startComponent, stopComponent

Methods inherited from class java.lang.Object

equals, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

NodeBase

public NodeBase()

Method Detail

getNode

public static NodeBase getNode()

getName

public java.lang.String getName()

Specified by:

getName in interface Node

Returns:

The nickname for the node.

getDetails

public NodeDetails getDetails()

Specified by:

getDetails in interface Node

Returns:

The address and other details of this node.

getState

public Node.NodeState getState()

Specified by:

getState in interface Node

Returns:

The run state of the node.

startNode

public final void startNode(java.lang.ThreadGroup inThreadGroup)
                     throws ComponentException,
                            java.lang.InterruptedException

Register this node's message events.

Specified by:

startNode in interface Node

Parameters:

inDetails -

Throws:

java.lang.InterruptedException

ComponentException

stopNode

public final void stopNode()

Description copied from interface: Node

Interrupt and stop node threads.

Specified by:

stopNode in interface Node

registerComponent

public void registerComponent(NodeComponentKey inKey,
                              NodeComponentImpl inComponent)

Description copied from interface: ComponentManager

Register a component with this component manager.

Specified by:

registerComponent in interface ComponentManager

Parameters:

inKey - - The key used to retrieve this component.

inComponent - - The component being registered.

getComponent

public NodeComponentImpl getComponent(NodeComponentKey inKey)
                               throws ComponentException

Description copied from interface: ComponentManager

Obtain the component registered with the provided key.

Specified by:

getComponent in interface ComponentManager

Parameters:

inKey - - The key associated with a registered component.

Returns:

The component.

Throws:

ComponentException

unregisterComponent

public void unregisterComponent(NodeComponentImpl inComponent)

Description copied from interface: ComponentManager

Unregister a previously registered component.

Specified by:

unregisterComponent in interface ComponentManager

Parameters:

inComponent - - The component to unregister.

runTask

public <T> ScheduledTask<T> runTask(ScheduledTask<T> inTask)

Description copied from interface: Node

Run a task in this node's thread pool.

Specified by:

runTask in interface Node

Parameters:

inTask - - The task to run.

Returns:

The task that was run.

runCommand

public boolean runCommand(java.lang.String... cargs)
                   throws java.lang.Exception

Description copied from interface: Node

Pass a command to be executed by the node.

Specified by:

runCommand in interface Node

Parameters:

cargs - - The command arguments.

Returns:

A boolean returned by the command.

Throws:

java.lang.Exception

enterMultiCommands

public static void enterMultiCommands()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object