Package | Description |
---|---|
org.infinispan.interceptors.base |
Base interceptors containing common, reusable behavior.
|
org.infinispan.remoting.responses |
Abstractions of the different response types allowed during RPC.
|
org.infinispan.remoting.rpc |
Remote Procedure Call (RPC) interfaces and components used to invoke remote methods on cache instances.
|
org.infinispan.remoting.transport |
Transports handle the low-level networking, used by the remoting components.
|
org.infinispan.remoting.transport.jgroups |
A transport implementation based on JGroups.
|
org.infinispan.statetransfer |
Transfer of state to new caches in a cluster.
|
org.infinispan.transaction |
JTA transaction support.
|
org.infinispan.util.logging |
Infinispan's logging abstractions that delegate to either JDK or Log4J logging engines.
|
Modifier and Type | Method and Description |
---|---|
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderAnycastPrepare(Collection<Address> recipients,
PrepareCommand prepareCommand,
ResponseFilter responseFilter) |
protected Map<Address,Response> |
BaseRpcInterceptor.totalOrderBroadcastPrepare(PrepareCommand prepareCommand,
ResponseFilter responseFilter) |
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 |
DefaultResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
ResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
Response |
DistributionResponseGenerator.getResponse(CacheRpcCommand command,
Object returnValue) |
protected Response |
NoReturnValuesDistributionResponseGenerator.handleWriteCommand(WriteCommand wc,
Object returnValue) |
protected Response |
DistributionResponseGenerator.handleWriteCommand(WriteCommand wc,
Object returnValue) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusteredGetResponseValidityFilter.isAcceptable(Response response,
Address address) |
boolean |
SelfDeliverFilter.isAcceptable(Response response,
Address sender) |
boolean |
KeysValidateFilter.isAcceptable(Response response,
Address sender) |
boolean |
IgnoreExtraResponsesValidityFilter.isAcceptable(Response response,
Address address) |
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 |
---|---|
Map<Address,Response> |
Transport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
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,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
AbstractTransport.parseResponseAndAddToResponseList(Object responseObject,
Throwable exception,
Map<Address,Response> responseListToAddTo,
boolean wasSuspected,
boolean wasReceived,
Address sender,
boolean usedResponseFilter,
boolean ignoreLeavers) |
Modifier and Type | Method and Description |
---|---|
Response |
CommandAwareRpcDispatcher.invokeRemoteCommand(org.jgroups.Address recipient,
ReplicableCommand command,
org.jgroups.blocks.ResponseMode mode,
long timeout,
boolean oob,
boolean asyncMarshalling) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
JGroupsTransport.invokeRemotely(Collection<Address> recipients,
ReplicableCommand rpcCommand,
ResponseMode mode,
long timeout,
boolean usePriorityQueue,
ResponseFilter responseFilter,
boolean totalOrder,
boolean anycast) |
Modifier and Type | Method and Description |
---|---|
Map<Address,Response> |
StateTransferManagerImpl.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin,
boolean sync) |
Map<Address,Response> |
StateTransferManager.forwardCommandIfNeeded(TopologyAffectedCommand command,
Set<Object> affectedKeys,
Address origin,
boolean sync)
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.
|
Modifier and Type | Method and Description |
---|---|
static void |
WriteSkewHelper.readVersionsFromResponse(Response r,
CacheTransaction ct) |
Modifier and Type | Method and Description |
---|---|
void |
Log.expectedJustOneResponse(Map<Address,Response> lr) |
void |
Log.unknownResponsesFromRemoteCache(Collection<Response> responses) |
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.