bamboo.openhash.multicast
Class MulticastTest

java.lang.Object
  bamboo.util.StandardStage
      bamboo.openhash.multicast.MulticastTest

All Implemented Interfaces:

EventHandlerIF, SingleThreadedEventHandlerIF

public class MulticastTest
extends StandardStage
implements SingleThreadedEventHandlerIF

Test class for implementation of multicast Joins have TTL 60 seconds Clients re-join every 30 seconds, on average

Nested Class Summary

class	MulticastTest.JoinCb
class	MulticastTest.JoinDoneCb
class	MulticastTest.ReadyCb
class	MulticastTest.SendCb
class	MulticastTest.SleepCb

Field Summary

protected ASyncCore	acore
protected static String	APP
protected MulticastClient	client
protected MessageDigest	digest
protected BigInteger	groupname
protected int	interval_sec
protected int	JOIN_TTL
protected int	messageNumber
protected int	nodes
protected Random	rand

Fields inherited from class bamboo.util.StandardStage

classifier, DEBUG, event_types, inb_msg_types, logger, my_node_id, my_sink, outb_msg_types, sim_running

Constructor Summary

MulticastTest()

Method Summary

void	handleEvent(QueueElementIF item)
void	init(ConfigDataIF config)

Methods inherited from class bamboo.util.StandardStage

BUG, BUG, BUG, config_get_boolean, config_get_double, config_get_int, config_get_string, configGetInt, destroy, dispatch, enqueue, handleEvents, lookup_stage, now_ms, timer_ms

Methods inherited from class java.lang.Object

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

Field Detail

APP

protected static final String APP

See Also:

Constant Field Values

client

protected MulticastClient client

rand

protected Random rand

groupname

protected BigInteger groupname

acore

protected ASyncCore acore

digest

protected MessageDigest digest

messageNumber

protected int messageNumber

nodes

protected int nodes

interval_sec

protected int interval_sec

JOIN_TTL

protected final int JOIN_TTL

See Also:

Constant Field Values

Constructor Detail

MulticastTest

public MulticastTest()

Method Detail

init

public void init(ConfigDataIF config)
          throws Exception

Specified by:

init in interface EventHandlerIF

Overrides:

init in class StandardStage

Throws:

Exception

handleEvent

public void handleEvent(QueueElementIF item)

Specified by:

handleEvent in interface EventHandlerIF

Overrides:

handleEvent in class StandardStage