ds.funnel.samples

Class TimerTestNode

java.lang.Object

ds.funnel.node.compnt.NodeComponentImpl

ds.funnel.node.NodeBase

ds.funnel.samples.TimerTestNode

All Implemented Interfaces:

ComponentManager, NodeComponent, Node

public class TimerTestNode
extends NodeBase

Nested Class Summary

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

Node.NodeState

Field Summary

Fields

Modifier and Type	Field and Description
static java.text.DecimalFormat	df
static java.util.concurrent.atomic.AtomicLong	mTime
static java.util.concurrent.atomic.AtomicInteger	recvCt
static java.util.concurrent.atomic.AtomicInteger	sendCt
static int	size
static java.util.concurrent.atomic.AtomicLong	tTime

Constructor Summary

Constructors

Constructor and Description
TimerTestNode(java.lang.String... xargs)

Method Summary

Modifier and Type	Method and Description
static void	main(java.lang.String[] args)
void	onPing(MsgLinkTestping inMsg)

Methods inherited from class ds.funnel.node.NodeBase

enterMultiCommands, getComponent, getDetails, getName, getNode, getState, registerComponent, runCommand, runTask, startNode, stopNode, toString, unregisterComponent

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

Field Detail

sendCt

public static java.util.concurrent.atomic.AtomicInteger sendCt

recvCt

public static java.util.concurrent.atomic.AtomicInteger recvCt

mTime

public static java.util.concurrent.atomic.AtomicLong mTime

tTime

public static java.util.concurrent.atomic.AtomicLong tTime

df

public static java.text.DecimalFormat df

size

public static volatile int size

Constructor Detail

TimerTestNode

public TimerTestNode(java.lang.String... xargs)

Method Detail

main

public static void main(java.lang.String[] args)
                 throws ComponentException,
                        java.lang.InterruptedException

Throws:

ComponentException

java.lang.InterruptedException

onPing

public void onPing(MsgLinkTestping inMsg)
            throws LinkException

Throws:

LinkException