ostore.archive
Class TputGenerateFragsTest
java.lang.Object
|
+--ostore.archive.TputGenerateFragsTest
- All Implemented Interfaces:
- EventHandlerIF, SingleThreadedEventHandlerIF
- public class TputGenerateFragsTest
- extends Object
- implements SingleThreadedEventHandlerIF, EventHandlerIF
TODO
- Version:
- $Id: TputGenerateFragsTest.java,v 1.4 2004/03/23 02:42:29 hweather Exp $
- Author:
- Sean C. Rhea & Jeremy Stribling
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
msgstart
protected int msgstart
rcvcnt
protected int rcvcnt
desired_queue_size
protected int desired_queue_size
start
protected boolean start
start_time
protected long start_time
classifier
protected Classifier classifier
node_id
protected NodeId node_id
TputGenerateFragsTest
public TputGenerateFragsTest()
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
init_block
protected void init_block()
fill_queue
protected void fill_queue()
got_msg
protected void got_msg(GenerateFragsBlkResp msg)