tapestry.impl.test
Class TputTest

java.lang.Object
  |
  +--tapestry.impl.test.TputTest
All Implemented Interfaces:
EventHandlerIF, SingleThreadedEventHandlerIF

public class TputTest
extends Object
implements SingleThreadedEventHandlerIF, EventHandlerIF

Throughput test for Tapestry messages, adapted from Sean's tput test

Version:
$Id: TputTest.java,v 1.1.1.1 2004/03/26 19:57:07 hweather Exp $
Author:
Ben Y. Zhao

Nested Class Summary
static class TputTest.AlarmEvent
           
static class TputTest.Msg
           
 
Field Summary
protected  Classifier classifier
           
protected static boolean DEBUG
           
protected  int desired_queue_size
           
static byte[] dummy
           
protected  int msgcnt
           
protected  int msgnum
           
protected  int msgstart
           
protected  int msgsz
           
protected  SinkIF netsink
           
protected  NodeId peer
           
protected  SecureHash peerguid
           
protected  int rcvcnt
           
protected  boolean start
           
protected  long start_time
           
protected  String TAG
           
protected  SinkIF this_sink
           
 
Constructor Summary
TputTest()
           
 
Method Summary
protected static void BUG(String msg)
           
 void destroy()
           
protected  void fill_queue()
           
protected  void got_msg(TputTest.Msg msg)
           
 void handleEvent(QueueElementIF item)
           
 void handleEvents(QueueElementIF[] items)
           
 void init(ConfigDataIF config)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TAG

protected String TAG

DEBUG

protected static final boolean DEBUG
See Also:
Constant Field Values

this_sink

protected SinkIF this_sink

netsink

protected SinkIF netsink

msgnum

protected int msgnum

msgcnt

protected int msgcnt

rcvcnt

protected int rcvcnt

msgsz

protected int msgsz

msgstart

protected int msgstart

desired_queue_size

protected int desired_queue_size

start

protected boolean start

start_time

protected long start_time

classifier

protected Classifier classifier

peer

protected NodeId peer

peerguid

protected SecureHash peerguid

dummy

public static byte[] dummy
Constructor Detail

TputTest

public TputTest()
Method Detail

init

public void init(ConfigDataIF config)
          throws Exception
Specified by:
init in interface EventHandlerIF
Exception

handleEvent

public void handleEvent(QueueElementIF item)
                 throws EventHandlerException
Specified by:
handleEvent in interface EventHandlerIF
EventHandlerException

handleEvents

public void handleEvents(QueueElementIF[] items)
                  throws EventHandlerException
Specified by:
handleEvents in interface EventHandlerIF
EventHandlerException

destroy

public void destroy()
             throws Exception
Specified by:
destroy in interface EventHandlerIF
Exception

fill_queue

protected void fill_queue()

got_msg

protected void got_msg(TputTest.Msg msg)

BUG

protected static final void BUG(String msg)