|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jgroups.stack.Protocol
org.jgroups.stack.MessageProtocol
org.jgroups.stack.RpcProtocol
org.jgroups.protocols.DEADLOCK
Tests the deadlock detection mechanism of RequestCorrelator.
Field Summary |
Fields inherited from class org.jgroups.stack.MessageProtocol |
_corr, members |
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 |
Constructor Summary | |
DEADLOCK()
|
Method Summary | |
int |
getCombinedResults()
Mcasts getResult() to all members (including itself). |
java.lang.String |
getName()
|
static int |
getResult()
Returns a random integer value between 1 and 10 |
boolean |
handleDownEvent(Event evt)
Callback. |
boolean |
handleUpEvent(Event evt)
Callback. |
int |
sendRequest(Address dest)
|
void |
start()
This method is called on a Channel.connect(String) . |
void |
stop()
This method is called on a Channel.disconnect() . |
Methods inherited from class org.jgroups.stack.RpcProtocol |
callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethods, handle |
Methods inherited from class org.jgroups.stack.MessageProtocol |
castMessage, down, sendMessage, up, updateView |
Methods inherited from class org.jgroups.stack.Protocol |
destroy, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, init, isTrace, isWarn, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setObserver, setProperties, setPropertiesInternal, setProtocolStack, setTrace, setUpProtocol, setWarn, startDownHandler, startUpHandler, statsEnabled, stopInternal, upThreadEnabled |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public DEADLOCK()
Method Detail |
public java.lang.String getName()
getName
in class RpcProtocol
public void start() throws java.lang.Exception
Protocol
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.
start
in class MessageProtocol
java.lang.Exception
public void stop()
Protocol
Channel.disconnect()
. Stops work (e.g. by closing multicast socket).
Will be called from top to bottom. This means that at the time of the method invocation the
neighbor protocol below is still working. This method will replace the
STOP, STOP_OK, CLEANUP and CLEANUP_OK events. The ProtocolStack guarantees that
when this method is called all messages in the down queue will have been flushed
stop
in class MessageProtocol
public int sendRequest(Address dest)
public int getCombinedResults()
public static int getResult()
public boolean handleUpEvent(Event evt)
Do not use PassUp
in this method as the event is passed up
by default by the superclass after this method returns !
handleUpEvent
in class RpcProtocol
public boolean handleDownEvent(Event evt)
Do not use PassDown
in this method as the event is passed down
by default by the superclass after this method returns !
handleDownEvent
in class RpcProtocol
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |