bamboo.openhash.multicast
Class MulticastTest

java.lang.Object
  extended by bamboo.util.StandardStage
      extended by 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