org.infinispan.stats.wrappers

Class ExtendedStatisticRpcManager

java.lang.Object

org.infinispan.stats.wrappers.ExtendedStatisticRpcManager

All Implemented Interfaces:

RpcManager

public class ExtendedStatisticRpcManager
extends Object
implements RpcManager

Takes statistics about the RPC invocations.

Since:

6.0

Author:

Roberto Palmieri, Sebastiano Peluso, Diego Didona, Pedro Ruivo

Constructor Summary

Constructors

Constructor and Description
ExtendedStatisticRpcManager(RpcManager actual, CacheStatisticManager cacheStatisticManager, TimeService timeService)

Method Summary

Methods

Modifier and Type	Method and Description
void	broadcastRpcCommand(ReplicableCommand rpc, boolean sync) Broadcasts an RPC command to the entire cluster.
void	broadcastRpcCommand(ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Broadcasts an RPC command to the entire cluster.
void	broadcastRpcCommandInFuture(ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean) except that the task is passed to the transport executor and a Future is returned.
void	broadcastRpcCommandInFuture(ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
Address	getAddress() Returns the address associated with this RpcManager or null if not part of the cluster.
RpcOptions	getDefaultRpcOptions(boolean sync) See RpcManager.getDefaultRpcOptions(boolean, boolean).
RpcOptions	getDefaultRpcOptions(boolean sync, boolean fifoOrder) Builds a RpcOptions based on the parameters
List<Address>	getMembers() Returns members of a cluster scoped to the cache owning this RpcManager.
RpcOptionsBuilder	getRpcOptionsBuilder(ResponseMode responseMode) This method is equivalent to getRpcOptionsBuilder(responseMode, true)
RpcOptionsBuilder	getRpcOptionsBuilder(ResponseMode responseMode, boolean fifoOrder)
int	getTopologyId() Returns the current topology id.
Transport	getTransport()
Map<Address,Response>	invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync) Broadcasts an RPC command to a specified set of recipients
Map<Address,Response>	invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, boolean sync, boolean usePriorityQueue) Broadcasts an RPC command to a specified set of recipients
Map<Address,Response>	invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	invokeRemotely(Collection<Address> recipients, ReplicableCommand rpcCommand, ResponseMode mode, long timeout, boolean usePriorityQueue, ResponseFilter responseFilter) Invokes an RPC call on other caches in the cluster.
Map<Address,Response>	invokeRemotely(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options) Invokes an RPC call on other caches in the cluster.
void	invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
void	invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout) The same as #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout.
void	invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, boolean usePriorityQueue, NotifyingNotifiableFuture<Object> future, long timeout, boolean ignoreLeavers) The same as #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture, long) except that you can specify a response mode.
void	invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned.
void	invokeRemotelyInFuture(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options, NotifyingNotifiableFuture<Object> future) The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) except that the task is passed to the transport executor and a Future is returned.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExtendedStatisticRpcManager

public ExtendedStatisticRpcManager(RpcManager actual,
                           CacheStatisticManager cacheStatisticManager,
                           TimeService timeService)

Method Detail

invokeRemotely

public Map<Address,Response> invokeRemotely(Collection<Address> recipients,
                                   ReplicableCommand rpcCommand,
                                   ResponseMode mode,
                                   long timeout,
                                   boolean usePriorityQueue,
                                   ResponseFilter responseFilter)

Description copied from interface: RpcManager

Invokes an RPC call on other caches in the cluster.

Specified by:

invokeRemotely in interface RpcManager

Parameters:

recipients - a list of Addresses to invoke the call on. If this is null, the call is broadcast to the entire cluster.

rpcCommand - the cache command to invoke

mode - the response mode to use

timeout - a timeout after which to throw a replication exception.

usePriorityQueue - if true, a priority queue is used to deliver messages. May not be supported by all implementations.

responseFilter - a response filter with which to filter out failed/unwanted/invalid responses.

Returns:

a map of responses from each member contacted.

invokeRemotely

public Map<Address,Response> invokeRemotely(Collection<Address> recipients,
                                   ReplicableCommand rpcCommand,
                                   ResponseMode mode,
                                   long timeout,
                                   boolean usePriorityQueue)

Description copied from interface: RpcManager

Invokes an RPC call on other caches in the cluster.

Specified by:

invokeRemotely in interface RpcManager

Parameters:

recipients - a list of Addresses to invoke the call on. If this is null, the call is broadcast to the entire cluster.

rpcCommand - the cache command to invoke

mode - the response mode to use

timeout - a timeout after which to throw a replication exception.

usePriorityQueue - if true, a priority queue is used to deliver messages. May not be supported by all implementations.

Returns:

a map of responses from each member contacted.

invokeRemotely

public Map<Address,Response> invokeRemotely(Collection<Address> recipients,
                                   ReplicableCommand rpcCommand,
                                   ResponseMode mode,
                                   long timeout)

Description copied from interface: RpcManager

Invokes an RPC call on other caches in the cluster.

Specified by:

invokeRemotely in interface RpcManager

Parameters:

recipients - a list of Addresses to invoke the call on. If this is null, the call is broadcast to the entire cluster.

rpcCommand - the cache command to invoke

mode - the response mode to use

timeout - a timeout after which to throw a replication exception.

Returns:

a map of responses from each member contacted.

broadcastRpcCommand

public void broadcastRpcCommand(ReplicableCommand rpc,
                       boolean sync)
                         throws RpcException

Description copied from interface: RpcManager

Broadcasts an RPC command to the entire cluster.

Specified by:

broadcastRpcCommand in interface RpcManager

Parameters:

rpc - command to execute remotely

sync - if true, the transport will operate in sync mode. Otherwise, it will operate in async mode.

Throws:

RpcException - in the event of problems

broadcastRpcCommand

public void broadcastRpcCommand(ReplicableCommand rpc,
                       boolean sync,
                       boolean usePriorityQueue)
                         throws RpcException

Description copied from interface: RpcManager

Broadcasts an RPC command to the entire cluster.

Specified by:

broadcastRpcCommand in interface RpcManager

Parameters:

rpc - command to execute remotely

sync - if true, the transport will operate in sync mode. Otherwise, it will operate in async mode.

usePriorityQueue - if true, a priority queue is used

Throws:

RpcException - in the event of problems

broadcastRpcCommandInFuture

public void broadcastRpcCommandInFuture(ReplicableCommand rpc,
                               NotifyingNotifiableFuture<Object> future)

Description copied from interface: RpcManager

The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned. The transport always deals with this synchronously.

Specified by:

broadcastRpcCommandInFuture in interface RpcManager

Parameters:

rpc - command to execute remotely

future - the future which will be passed back to the user

broadcastRpcCommandInFuture

public void broadcastRpcCommandInFuture(ReplicableCommand rpc,
                               boolean usePriorityQueue,
                               NotifyingNotifiableFuture<Object> future)

Description copied from interface: RpcManager

The same as RpcManager.broadcastRpcCommand(org.infinispan.commands.ReplicableCommand, boolean, boolean) except that the task is passed to the transport executor and a Future is returned. The transport always deals with this synchronously.

Specified by:

broadcastRpcCommandInFuture in interface RpcManager

Parameters:

rpc - command to execute remotely

usePriorityQueue - if true, a priority queue is used

future - the future which will be passed back to the user

invokeRemotely

public Map<Address,Response> invokeRemotely(Collection<Address> recipients,
                                   ReplicableCommand rpc,
                                   boolean sync)
                                     throws RpcException

Description copied from interface: RpcManager

Broadcasts an RPC command to a specified set of recipients

Specified by:

invokeRemotely in interface RpcManager

Parameters:

recipients - recipients to invoke remote command on

rpc - command to execute remotely

sync - if true, the transport will operate in sync mode. Otherwise, it will operate in async mode.

Throws:

RpcException - in the event of problems

invokeRemotely

public Map<Address,Response> invokeRemotely(Collection<Address> recipients,
                                   ReplicableCommand rpc,
                                   boolean sync,
                                   boolean usePriorityQueue)
                                     throws RpcException

Description copied from interface: RpcManager

Broadcasts an RPC command to a specified set of recipients

Specified by:

invokeRemotely in interface RpcManager

Parameters:

recipients - recipients to invoke remote command on

rpc - command to execute remotely

sync - if true, the transport will operate in sync mode. Otherwise, it will operate in async mode.

usePriorityQueue - if true, a priority queue is used

Throws:

RpcException - in the event of problems

invokeRemotelyInFuture

public void invokeRemotelyInFuture(Collection<Address> recipients,
                          ReplicableCommand rpc,
                          NotifyingNotifiableFuture<Object> future)

Description copied from interface: RpcManager

The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned. The transport always deals with this synchronously.

Specified by:

invokeRemotelyInFuture in interface RpcManager

Parameters:

recipients - recipients to invoke remote call on

rpc - command to execute remotely

future - the future which will be passed back to the user

invokeRemotelyInFuture

public void invokeRemotelyInFuture(Collection<Address> recipients,
                          ReplicableCommand rpc,
                          boolean usePriorityQueue,
                          NotifyingNotifiableFuture<Object> future)

Description copied from interface: RpcManager

The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean) except that the task is passed to the transport executor and a Future is returned. The transport always deals with this synchronously.

Specified by:

invokeRemotelyInFuture in interface RpcManager

Parameters:

recipients - recipients to invoke remote call on

rpc - command to execute remotely

usePriorityQueue - if true, a priority queue is used

future - the future which will be passed back to the user

invokeRemotelyInFuture

public void invokeRemotelyInFuture(Collection<Address> recipients,
                          ReplicableCommand rpc,
                          boolean usePriorityQueue,
                          NotifyingNotifiableFuture<Object> future,
                          long timeout)

Description copied from interface: RpcManager

The same as #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture) except that you can specify a timeout.

Specified by:

invokeRemotelyInFuture in interface RpcManager

Parameters:

recipients - recipients to invoke remote call on

rpc - command to execute remotely

usePriorityQueue - if true, a priority queue is used

future - the future which will be passed back to the user

timeout - after which to give up (in millis)

invokeRemotelyInFuture

public void invokeRemotelyInFuture(Collection<Address> recipients,
                          ReplicableCommand rpc,
                          boolean usePriorityQueue,
                          NotifyingNotifiableFuture<Object> future,
                          long timeout,
                          boolean ignoreLeavers)

Description copied from interface: RpcManager

The same as #invokeRemotelyInFuture(java.util.Collection, org.infinispan.commands.ReplicableCommand, boolean, org.infinispan.util.concurrent.NotifyingNotifiableFuture, long) except that you can specify a response mode.

Specified by:

invokeRemotelyInFuture in interface RpcManager

Parameters:

recipients - recipients to invoke remote call on

rpc - command to execute remotely

usePriorityQueue - if true, a priority queue is used

future - the future which will be passed back to the user

timeout - after which to give up (in millis)

ignoreLeavers - if true, recipients that leave or have already left the cluster are ignored if false, a SuspectException is thrown when a leave is detected

invokeRemotely

public Map<Address,Response> invokeRemotely(Collection<Address> recipients,
                                   ReplicableCommand rpc,
                                   RpcOptions options)

Description copied from interface: RpcManager

Invokes an RPC call on other caches in the cluster.

Specified by:

invokeRemotely in interface RpcManager

Parameters:

recipients - a list of Addresses to invoke the call on. If this is null, the call is broadcast to the entire cluster.

rpc - command to execute remotely.

options - it configures the invocation. The same instance can be re-used since RpcManager does not change it. Any change in RpcOptions during a remote invocation can lead to unpredictable behavior.

Returns:

a map of responses from each member contacted.

invokeRemotelyInFuture

public void invokeRemotelyInFuture(Collection<Address> recipients,
                          ReplicableCommand rpc,
                          RpcOptions options,
                          NotifyingNotifiableFuture<Object> future)

Description copied from interface: RpcManager

The same as RpcManager.invokeRemotely(java.util.Collection, org.infinispan.commands.ReplicableCommand, RpcOptions) except that the task is passed to the transport executor and a Future is returned. The transport always deals with this synchronously.

Specified by:

invokeRemotelyInFuture in interface RpcManager

Parameters:

recipients - recipients to invoke remote call on. If this is null, the call is broadcast to the entire cluster.

rpc - command to execute remotely.

options - it configures the invocation. The same instance can be re-used since RpcManager does not change it. Any change in RpcOptions during a remote invocation can lead to unpredictable behavior.

future - the future which will be passed back to the user.

getRpcOptionsBuilder

public RpcOptionsBuilder getRpcOptionsBuilder(ResponseMode responseMode)

Description copied from interface: RpcManager

This method is equivalent to getRpcOptionsBuilder(responseMode, true)

Specified by:

getRpcOptionsBuilder in interface RpcManager

Returns:

a new RpcOptionsBuilder with the default options, the response mode set by and FIFO deliver order.

getRpcOptionsBuilder

public RpcOptionsBuilder getRpcOptionsBuilder(ResponseMode responseMode,
                                     boolean fifoOrder)

Specified by:

getRpcOptionsBuilder in interface RpcManager

Returns:

a new RpcOptionsBuilder with the default options, the response mode set by and the deliver order as fifo if the is true.

getDefaultRpcOptions

public RpcOptions getDefaultRpcOptions(boolean sync)

Description copied from interface: RpcManager

See RpcManager.getDefaultRpcOptions(boolean, boolean). It is equivalent to getDefaultRpcOptions(sync, true)

Specified by:

getDefaultRpcOptions in interface RpcManager

Parameters:

sync - true for Synchronous RpcOptions

Returns:

the default Synchronous/Asynchronous RpcOptions

getDefaultRpcOptions

public RpcOptions getDefaultRpcOptions(boolean sync,
                              boolean fifoOrder)

Description copied from interface: RpcManager

Builds a RpcOptions based on the parameters

Specified by:

getDefaultRpcOptions in interface RpcManager

Parameters:

sync - true for Synchronous RpcOptions

Returns:

the default Synchronous/Asynchronous RpcOptions with the deliver order set by

getTransport

public Transport getTransport()

Specified by:

getTransport in interface RpcManager

Returns:

a reference to the underlying transport.

getMembers

public List<Address> getMembers()

Description copied from interface: RpcManager

Returns members of a cluster scoped to the cache owning this RpcManager. Note that this List is always a subset of Transport.getMembers()

Specified by:

getMembers in interface RpcManager

Returns:

a list of cache scoped cluster members

getAddress

public Address getAddress()

Description copied from interface: RpcManager

Returns the address associated with this RpcManager or null if not part of the cluster.

Specified by:

getAddress in interface RpcManager

getTopologyId

public int getTopologyId()

Description copied from interface: RpcManager

Returns the current topology id. As opposed to the viewId which is updated whenever the cluster changes, the topologyId is updated when a new cache instance is started or removed - this doesn't necessarily coincide with a node being added/removed to the cluster.

Specified by:

getTopologyId in interface RpcManager