Package org.infinispan.extendedstats.wrappers

Class ExtendedStatisticRpcManager

java.lang.Object

org.infinispan.extendedstats.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	Description
ExtendedStatisticRpcManager(RpcManager actual, CacheStatisticManager cacheStatisticManager, TimeService timeService, StreamingMarshaller marshaller)

Method Summary

Modifier and Type	Method	Description
<T> T	blocking(CompletionStage<T> request)	Block on a request and return its result.
Address	getAddress()	Returns the address associated with this RpcManager or null if not part of the cluster.
List<Address>	getMembers()	Returns members of a cluster scoped to the cache owning this RpcManager.
RpcOptions	getSyncRpcOptions()
int	getTopologyId()	Returns the current topology id.
RpcOptions	getTotalSyncRpcOptions()
Transport	getTransport()
<T> CompletionStage<T>	invokeCommand(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of node and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	invokeCommand(Address target, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a single node and pass the response to a ResponseCollector.
<T> CompletionStage<T>	invokeCommandOnAll(ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	invokeCommands(Collection<Address> targets, Function<Address,ReplicableCommand> commandGenerator, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector.
<T> CompletionStage<T>	invokeCommandStaggered(Collection<Address> targets, ReplicableCommand command, ResponseCollector<T> collector, RpcOptions rpcOptions)	Invoke a command on a collection of nodes and pass the responses to a ResponseCollector.
CompletableFuture<Map<Address,Response>>	invokeRemotelyAsync(Collection<Address> recipients, ReplicableCommand rpc, RpcOptions options)	Invokes a command on remote nodes.
<O> XSiteResponse<O>	invokeXSite(org.infinispan.xsite.XSiteBackup backup, XSiteCacheRequest<O> command)	Sends the XSiteCacheRequest to a remote site.
void	sendTo(Address destination, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.
void	sendToAll(ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the entire cluster.
void	sendToMany(Collection<Address> destinations, ReplicableCommand command, org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)	Asynchronously sends the ReplicableCommand to the set of destination using the specified DeliverOrder.

Methods inherited from class java.lang.Object

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

Constructor Details

ExtendedStatisticRpcManager

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

Method Details

invokeCommand

public <T> CompletionStage<T> invokeCommand(Address target,
 ReplicableCommand command,
 ResponseCollector<T> collector,
 RpcOptions rpcOptions)

Description copied from interface: RpcManager

Invoke a command on a single node and pass the response to a ResponseCollector. If the target is the local node, the command is never executed and ResponseCollector.finish() is called directly.

Specified by:

invokeCommand in interface RpcManager

invokeCommand

public <T> CompletionStage<T> invokeCommand(Collection<Address> targets,
 ReplicableCommand command,
 ResponseCollector<T> collector,
 RpcOptions rpcOptions)

Description copied from interface: RpcManager

Invoke a command on a collection of node and pass the responses to a ResponseCollector. If one of the targets is the local node, it is ignored. The command is only executed on the remote nodes.

Specified by:

invokeCommand in interface RpcManager

invokeCommandOnAll

public <T> CompletionStage<T> invokeCommandOnAll(ReplicableCommand command,
 ResponseCollector<T> collector,
 RpcOptions rpcOptions)

Description copied from interface: RpcManager

Invoke a command on all the nodes in the cluster and pass the responses to a ResponseCollector. The command is not executed locally and it is not sent across RELAY2 bridges to remote sites.

Specified by:

invokeCommandOnAll in interface RpcManager

invokeCommandStaggered

public <T> CompletionStage<T> invokeCommandStaggered(Collection<Address> targets,
 ReplicableCommand command,
 ResponseCollector<T> collector,
 RpcOptions rpcOptions)

Description copied from interface: RpcManager

Invoke a command on a collection of nodes and pass the responses to a ResponseCollector. The command is only sent immediately to the first target, and there is an implementation-dependent delay before sending the command to each target. There is no delay if the target responds or leaves the cluster. The remaining targets are skipped if ResponseCollector.addResponse(Address, Response) returns a non-null value. The command is only executed on the remote nodes.

Specified by:

invokeCommandStaggered in interface RpcManager

invokeCommands

public <T> CompletionStage<T> invokeCommands(Collection<Address> targets,
 Function<Address,ReplicableCommand> commandGenerator,
 ResponseCollector<T> collector,
 RpcOptions rpcOptions)

Description copied from interface: RpcManager

Invoke different commands on a collection of nodes and pass the responses to a ResponseCollector. The command is only executed on the remote nodes and it is not executed in the local node even if it is in the targets.

Specified by:

invokeCommands in interface RpcManager

blocking

public <T> T blocking(CompletionStage<T> request)

Description copied from interface: RpcManager

Block on a request and return its result.

Specified by:

blocking in interface RpcManager

invokeRemotelyAsync

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

Description copied from interface: RpcManager

Invokes a command on remote nodes.

Specified by:

invokeRemotelyAsync in interface RpcManager

Parameters:

recipients - A list of nodes, or null to invoke the command on all the members of the cluster

rpc - The command to invoke

options - The invocation options

Returns:

A future that, when completed, returns the responses from the remote nodes.

sendTo

public void sendTo(Address destination,
 ReplicableCommand command,
 org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Description copied from interface: RpcManager

Asynchronously sends the ReplicableCommand to the destination using the specified DeliverOrder.

Specified by:

sendTo in interface RpcManager

Parameters:

destination - the destination's Address.

command - the ReplicableCommand to send.

deliverOrder - the DeliverOrder to use.

sendToMany

public void sendToMany(Collection<Address> destinations,
 ReplicableCommand command,
 org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Description copied from interface: RpcManager

Asynchronously sends the ReplicableCommand to the set of destination using the specified DeliverOrder.

Specified by:

sendToMany in interface RpcManager

Parameters:

destinations - the collection of destination's Address. If null, it sends to all the members in the cluster.

command - the ReplicableCommand to send.

deliverOrder - the DeliverOrder to use.

sendToAll

public void sendToAll(ReplicableCommand command,
 org.infinispan.remoting.inboundhandler.DeliverOrder deliverOrder)

Description copied from interface: RpcManager

Asynchronously sends the ReplicableCommand to the entire cluster.

Specified by:

sendToAll in interface RpcManager

invokeXSite

public <O> XSiteResponse<O> invokeXSite(org.infinispan.xsite.XSiteBackup backup,
 XSiteCacheRequest<O> command)

Description copied from interface: RpcManager

Sends the XSiteCacheRequest to a remote site.

If XSiteBackup.isSync() returns false, the XSiteResponse is only completed when the an ACK from the remote site is received. The invoker needs to make sure not to wait for the XSiteResponse.

Specified by:

invokeXSite in interface RpcManager

Parameters:

backup - The site to where the command is sent.

command - The command to send.

Returns:

A XSiteResponse that is completed when the request is completed.

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

getSyncRpcOptions

public RpcOptions getSyncRpcOptions()

Specified by:

getSyncRpcOptions in interface RpcManager

Returns:

The default options for synchronous remote invocations.

getTotalSyncRpcOptions

public RpcOptions getTotalSyncRpcOptions()

Specified by:

getTotalSyncRpcOptions in interface RpcManager

Returns:

The default options for total order remote invocations.