ds.funnel.node

Interface Node

All Superinterfaces:

ComponentManager

All Known Implementing Classes:

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

public interface Node
extends ComponentManager

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Node.NodeState

Method Summary

Modifier and Type	Method and Description
NodeDetails	getDetails()
java.lang.String	getName()
Node.NodeState	getState()
boolean	runCommand(java.lang.String... inArgs) 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) Start the node threads.
void	stopNode() Interrupt and stop node threads.

Methods inherited from interface ds.funnel.node.compnt.ComponentManager

getComponent, registerComponent, unregisterComponent

Method Detail

startNode

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

Start the node threads.

Parameters:

inThreadGroup - - The thread group to start threads in. Null for current thread.

Throws:

ComponentException

java.lang.InterruptedException

stopNode

void stopNode()

Interrupt and stop node threads.

getName

java.lang.String getName()

Returns:

The nickname for the node.

getDetails

NodeDetails getDetails()

Returns:

The address and other details of this node.

getState

Node.NodeState getState()

Returns:

The run state of the node.

runTask

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

Run a task in this node's thread pool.

Parameters:

inTask - - The task to run.

Returns:

The task that was run.

runCommand

boolean runCommand(java.lang.String... inArgs)
            throws java.lang.Exception

Pass a command to be executed by the node.

Parameters:

inArgs - - The command arguments.

Returns:

A boolean returned by the command.

Throws:

java.lang.Exception