Package | Description |
---|---|
org.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
Modifier and Type | Method and Description |
---|---|
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
MethodCall method_call,
int mode,
long timeout) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
MethodCall method_call,
int mode,
long timeout,
boolean use_anycasting) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
MethodCall method_call,
int mode,
long timeout,
boolean use_anycasting,
boolean oob) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
MethodCall method_call,
int mode,
long timeout,
boolean use_anycasting,
boolean oob,
RspFilter filter) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout,
boolean use_anycasting) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.Class[] types,
int mode,
long timeout,
boolean use_anycasting,
RspFilter filter) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.String[] signature,
int mode,
long timeout) |
RspList |
RpcDispatcher.callRemoteMethods(java.util.Vector dests,
java.lang.String method_name,
java.lang.Object[] args,
java.lang.String[] signature,
int mode,
long timeout,
boolean use_anycasting) |
RspList |
RpcDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout) |
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout) |
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout,
boolean use_anycasting)
Cast a message to all members, and wait for
mode responses. |
RspList |
MessageDispatcher.castMessage(java.util.Vector dests,
Message msg,
int mode,
long timeout,
boolean use_anycasting,
RspFilter filter) |
RspList |
GroupRequest.getResults()
Returns the results as a RspList
|
Modifier and Type | Method and Description |
---|---|
protected void |
DistributedQueue.checkResult(RspList rsp,
java.lang.Object retval) |
boolean |
VotingAdapter.processResponses(RspList responses,
int consensusType,
java.lang.Object decree)
Processes the response list and makes a decision according to the
type of the consensus for current voting.
|
boolean |
DistributedLockManager.processResponses(RspList responses,
int consensusType,
java.lang.Object decree)
Processes the response list and votes like the default processResponses method with the consensusType VOTE_ALL
If the result of the voting is false, but this DistributedLockManager owns the lock, the result is changed to
true and the lock is released, but marked as multiple locked.
|
boolean |
VoteResponseProcessor.processResponses(RspList responses,
int consensusType,
java.lang.Object decree)
Processes the responses returned by the other nodes.
|
Copyright ? 1998-2008 Bela Ban. All Rights Reserved.