Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderPrepare(Collection<Address> recipients,
PrepareCommand prepareCommand,
TimeoutValidationResponseFilter responseFilter)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TxDistributionInterceptor.checkTxCommandResponses(Map<Address,Response> responseMap,
TransactionBoundaryCommand command,
LocalTxInvocationContext context,
Collection<Address> recipients)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
Response |
LocalInvocation.call() |
Modifier and Type | Field and Description |
---|---|
protected Response |
BaseBlockingRunnable.response |
Modifier and Type | Method and Description |
---|---|
protected Response |
BaseBlockingRunnable.beforeInvoke() |
protected Response |
DefaultTopologyRunnable.beforeInvoke() |
Modifier and Type | Class and Description |
---|---|
class |
CacheNotFoundResponse
A response that signals the named cache is not running on the target node.
|
class |
ExceptionResponse
A response that encapsulates an exception
|
class |
InvalidResponse
An invalid response
|
class |
SuccessfulResponse
A successful response
|
class |
UnsuccessfulResponse
An unsuccessful response
|
class |
UnsureResponse
An unsure response - used with Dist - essentially asks the caller to check the next response from the next node since
the sender is in a state of flux (probably in the middle of rebalancing)
|
class |
ValidResponse
A valid response
|
Modifier and Type | Method and Description |
---|---|
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Modifier and Type | Method and Description |
---|---|
boolean |
KeysValidateFilter.isAcceptable(Response response,
Address sender) |
boolean |
SelfDeliverFilter.isAcceptable(Response response,
Address sender) |
boolean |
IgnoreExtraResponsesValidityFilter.isAcceptable(Response response,
Address address) |
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
RpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Map<Address,Response> |
RpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs,
RpcOptions options) |
Map<Address,Response> |
RpcManagerImpl.invokeRemotely(Map<Address,ReplicableCommand> rpcs,
RpcOptions options) |
CompletableFuture<Map<Address,Response>> |
RpcManager.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Invokes a command on remote nodes.
|
CompletableFuture<Map<Address,Response>> |
RpcManagerImpl.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Modifier and Type | Method and Description |
---|---|
boolean |
ResponseFilter.isAcceptable(Response response,
Address sender)
Determines whether a response from a given sender should be added to the response list of the request
|
Modifier and Type | Method and Description |
---|---|
void |
RpcManager.invokeRemotelyInFuture(NotifyingNotifiableFuture<Map<Address,Response>> future,
Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options)
Deprecated.
Use
RpcManager.invokeRemotelyAsync(Collection, ReplicableCommand, RpcOptions) instead.
Same as RpcManager.invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand,
RpcOptions, org.infinispan.commons.util.concurrent.NotifyingNotifiableFuture) but with a different
NotifyingNotifiableFuture type. |
void |
RpcManagerImpl.invokeRemotelyInFuture(NotifyingNotifiableFuture<Map<Address,Response>> future,
Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Modifier and Type | Method and Description |
---|---|
Response |
AbstractTransport.checkResponse(Object responseObject,
Address sender,
boolean ignoreCacheNotFoundResponse) |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
AbstractDelegatingTransport.afterInvokeRemotely(ReplicableCommand command,
Map<Address,Response> responseMap)
method invoked after a successful remote invocation.
|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast)
Invokes an RPC call on other caches in the cluster.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast)
Deprecated.
|
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
Transport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
AbstractDelegatingTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
Transport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
AbstractDelegatingTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
AbstractDelegatingTransport.afterInvokeRemotely(ReplicableCommand command,
Map<Address,Response> responseMap)
method invoked after a successful remote invocation.
|
Modifier and Type | Field and Description |
---|---|
static org.jgroups.util.RspList<Response> |
CommandAwareRpcDispatcher.EMPTY_RESPONSES_LIST |
Modifier and Type | Method and Description |
---|---|
protected Response |
JGroupsTransport.checkRsp(org.jgroups.util.Rsp<Response> rsp,
Address sender,
boolean ignoreTimeout,
boolean ignoreLeavers) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<org.jgroups.util.RspList<Response>> |
CommandAwareRpcDispatcher.invokeRemoteCommands(List<org.jgroups.Address> recipients,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
org.jgroups.blocks.RspFilter filter,
DeliverOrder deliverOrder) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Map<Address,ReplicableCommand> rpcCommands,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
CompletableFuture<Map<Address,Response>> |
JGroupsTransport.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
ResponseFilter responseFilter,
DeliverOrder deliverOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
protected Response |
JGroupsTransport.checkRsp(org.jgroups.util.Rsp<Response> rsp,
Address sender,
boolean ignoreTimeout,
boolean ignoreLeavers) |
void |
SingleResponseFuture.futureDone(Future<Response> future) |
void |
RspListFuture.futureDone(Future<org.jgroups.util.RspList<Response>> future) |
Modifier and Type | Method and Description |
---|---|
void |
JavaLog_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
JavaLog_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
void |
JavaLog_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
JavaLog_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin)
If there is an state transfer happening at the moment, this method forwards the supplied
command to the nodes that are new owners of the data, in order to assure consistency.
|
Map<Address,Response> |
StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Map<Address,Response> |
ExtendedStatisticRpcManager.invokeRemotely(Map<Address,ReplicableCommand> rpcs,
RpcOptions options) |
CompletableFuture<Map<Address,Response>> |
ExtendedStatisticRpcManager.invokeRemotelyAsync(Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
ExtendedStatisticRpcManager.invokeRemotelyInFuture(NotifyingNotifiableFuture<Map<Address,Response>> future,
Collection<Address> recipients,
ReplicableCommand rpc,
RpcOptions options) |
Modifier and Type | Method and Description |
---|---|
static void |
WriteSkewHelper.readVersionsFromResponse(Response r,
CacheTransaction ct) |
Modifier and Type | Method and Description |
---|---|
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address arg0,
Response arg1) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address arg0,
Response arg1) |
Modifier and Type | Method and Description |
---|---|
void |
Log.unsuccessfulResponseForClusterListeners(Address address,
Response response) |
void |
Log_$logger.unsuccessfulResponseForClusterListeners(Address address,
Response response) |
void |
Log.unsuccessfulResponseRetrievingTransactionsForSegments(Address address,
Response response) |
void |
Log_$logger.unsuccessfulResponseRetrievingTransactionsForSegments(Address address,
Response response) |
Modifier and Type | Method and Description |
---|---|
void |
Log.expectedJustOneResponse(Map<Address,Response> lr) |
void |
Log.unknownResponsesFromRemoteCache(Collection<Response> responses) |
Copyright © 2023 JBoss, a division of Red Hat. All rights reserved.