| Frames | No Frames | |
Classes implementing org.jgroups.blocks.RequestHandler | |
| class | Based on Protocol, but incorporates RequestCorrelator and GroupRequest: the latter can
be used to mcast messages to all members and receive their reponses. |
| class | Base class for group RMC peer protocols. |
Classes implementing org.jgroups.blocks.RequestHandler | |
| class | Tests the deadlock detection mechanism of RequestCorrelator. |
| class | FLOW_CONTROL provides end-end congestion control and flow control. |
| class | The task of the FLUSH protocol is to flush all pending messages out of the system. |
| class | Group membership protocol. |
| class | |
| class | |
| class | Computes the broadcast messages that are stable, i.e. |
| class | State transfer layer. |
| class |
Total order implementation based on
The Totem Single-Ring Ordering and Membership Protocol
However, this is an adaption of algorithm mentioned in the research paper above since we reuse
our own membership protocol and failure detectors. |
Classes implementing org.jgroups.blocks.RequestHandler | |
| class | Used on top of channel to implement group requests. |
| class | Class to propagate updates to a number of nodes in various ways:
Note: This class is experimental as of Oct 2002 |
| class | Dispatches and receives remote group method calls. |
Constructors with parameter type org.jgroups.blocks.RequestHandler | |
MessageDispatcher.MessageDispatcher(Channel channel, MessageListener l, MembershipListener l2, RequestHandler req_handler) | |
MessageDispatcher.MessageDispatcher(Channel channel, MessageListener l, MembershipListener l2, RequestHandler req_handler, boolean deadlock_detection) | |
MessageDispatcher.MessageDispatcher(Channel channel, MessageListener l, MembershipListener l2, RequestHandler req_handler, boolean deadlock_detection, boolean concurrent_processing) | |
MessageDispatcher.MessageDispatcher(PullPushAdapter adapter, Serializable id, MessageListener l, MembershipListener l2, RequestHandler req_handler) | |
MessageDispatcher.MessageDispatcher(PullPushAdapter adapter, Serializable id, MessageListener l, MembershipListener l2, RequestHandler req_handler, boolean concurrent_processing) | |
Constructor. | |
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection) Constructor. | |
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, boolean concurrent_processing) | |
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr) | |
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, boolean deadlock_detection, Address local_addr, boolean concurrent_processing) | |
RequestCorrelator.RequestCorrelator(String name, Object transport, RequestHandler handler, Address local_addr) | |
Fields of type org.jgroups.blocks.RequestHandler | |
| RequestHandler | |
| RequestHandler | The handler for the incoming requests. |
Methods with parameter type org.jgroups.blocks.RequestHandler | |
| void | |
| void | |