org.javagroups.protocols
Class DEADLOCK

java.lang.Object
  |
  +--org.javagroups.stack.Protocol
        |
        +--org.javagroups.stack.MessageProtocol
              |
              +--org.javagroups.stack.RpcProtocol
                    |
                    +--org.javagroups.protocols.DEADLOCK

All Implemented Interfaces:

RequestHandler

public class DEADLOCK

extends RpcProtocol

Tests the deadlock detection mechanism of RequestCorrelator.

Field Summary

Fields inherited from class org.javagroups.stack.MessageProtocol

_corr, members

Fields inherited from class org.javagroups.stack.Protocol

down_handler, down_prot, down_queue, down_thread, down_thread_prio, observer, props, stack, up_handler, up_prot, up_queue, up_thread, up_thread_prio

Constructor Summary

DEADLOCK()

Method Summary

int	getCombinedResults() Mcasts getResult() to all members (including itself).
java.lang.String	getName()
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.javagroups.stack.RpcProtocol

callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethod, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, callRemoteMethods, handle

Methods inherited from class org.javagroups.stack.MessageProtocol

castMessage, down, sendMessage, up, updateView

Methods inherited from class org.javagroups.stack.Protocol

destroy, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, init, passDown, passUp, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, setDownProtocol, setObserver, setProperties, setPropertiesInternal, setProtocolStack, setUpProtocol, startDownHandler, startUpHandler, stopInternal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DEADLOCK

public DEADLOCK()

Method Detail

getName

public java.lang.String getName()

Overrides:

getName in class RpcProtocol

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 MessageProtocol

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

stop

public void stop()

Description copied from class: Protocol

This method is called on a 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

Overrides:

stop in class MessageProtocol

sendRequest

public int sendRequest(Address dest)

getCombinedResults

public int getCombinedResults()

Mcasts getResult() to all members (including itself). Returns the sum of all results.

getResult

public int getResult()

Returns a random integer value between 1 and 10

handleUpEvent

public boolean handleUpEvent(Event evt)

Callback. Called by superclass when event may be handled.

Do not use PassUp in this method as the event is passed up by default by the superclass after this method returns !

Overrides:

handleUpEvent in class RpcProtocol

Returns:

boolean Defaults to true. If false, event will not be passed up the stack.

handleDownEvent

public boolean handleDownEvent(Event evt)

Callback. Called by superclass when event may be handled.

Do not use PassDown in this method as the event is passed down by default by the superclass after this method returns !

Overrides:

handleDownEvent in class RpcProtocol

Returns:

boolean Defaults to true. If false, event will not be passed down the stack.