org.jgroups.protocols
Class PERF_TP
java.lang.Object
org.jgroups.stack.Protocol
org.jgroups.protocols.PERF_TP
public class PERF_TP
- extends Protocol
Measures the time for a message to travel from the channel to the transport
- Version:
- $Id: PERF_TP.java,v 1.11 2005/08/11 12:43:47 belaban Exp $
- Author:
- Bela Ban
Fields inherited from class org.jgroups.stack.Protocol |
down_handler, down_prot, down_queue, down_thread, down_thread_prio, log, observer, props, stack, stats, trace, up_handler, up_prot, up_queue, up_thread, up_thread_prio, warn |
Methods inherited from class org.jgroups.stack.Protocol |
destroy, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, isTrace, isWarn, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setObserver, setProperties, setPropertiesInternal, setProtocolStack, setTrace, setUpProtocol, setWarn, startDownHandler, startUpHandler, statsEnabled, stop, stopInternal, upThreadEnabled |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
PERF_TP
public PERF_TP()
getInstance
public static PERF_TP getInstance()
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
done
public boolean done()
getNumMessages
public long getNumMessages()
setExpectedMessages
public void setExpectedMessages(long m)
reset
public void reset()
getTotalTime
public long getTotalTime()
getName
public java.lang.String getName()
- Specified by:
getName
in class Protocol
init
public void init()
throws java.lang.Exception
- Description copied from class:
Protocol
- Called after instance has been created (null constructor) and before protocol is started.
Properties are already set. Other protocols are not yet connected and events cannot yet be sent.
- Overrides:
init
in class Protocol
- Throws:
java.lang.Exception
- Thrown if protocol cannot be initialized successfully. This will cause the
ProtocolStack to fail, so the channel constructor will throw an exception
start
public void start()
throws java.lang.Exception
- Description copied from class:
Protocol
- This method is called on a
Channel.connect(String)
. Starts work.
Protocols are connected and queues are ready to receive events.
Will be called from bottom to top. This call will replace
the START and START_OK events.
- Overrides:
start
in class Protocol
- Throws:
java.lang.Exception
- Thrown if protocol cannot be started successfully. This will cause the ProtocolStack
to fail, so Channel.connect(String)
will throw an exception
down
public void down(Event evt)
- Caller by the layer above this layer. Usually we just put this Message
into the send queue and let one or more worker threads handle it. A worker thread
then removes the Message from the send queue, performs a conversion and adds the
modified Message to the send queue of the layer below it, by calling Down).
- Overrides:
down
in class Protocol
up
public void up(Event evt)
- Description copied from class:
Protocol
- An event was received from the layer below. Usually the current layer will want to examine
the event type and - depending on its type - perform some computation
(e.g. removing headers from a MSG event type, or updating the internal membership list
when receiving a VIEW_CHANGE event).
Finally the event is either a) discarded, or b) an event is sent down
the stack using
passDown()
or c) the event (or another event) is sent up
the stack using passUp()
.
- Overrides:
up
in class Protocol
Copyright ? 1998-2005 Bela Ban. All Rights Reserved.