com.hazelcast.spi.impl.operationservice.impl

Class InvocationRegistry

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.InvocationRegistry

All Implemented Interfaces:

MetricsProvider, Iterable<Invocation>

public class InvocationRegistry
extends Object
implements Iterable<Invocation>, MetricsProvider

Responsible for the registration of all pending invocations.

Using the InvocationRegistry the Invocation and its response(s) can be linked to each other.

When an invocation is registered, a callId is determined. Based on this call ID, when a Response comes in, the appropriate invocation can be looked up.

Some ideas:

• Use a ringbuffer to store all invocations instead of a CHM. The call ID can be used as sequence ID for this ringbuffer. It can be that you run in slots that have not been released; if that happens, just keep increasing the sequence (although you now get sequence-gaps).
• Pre-allocate all invocations. Because the ringbuffer has a fixed capacity, pre-allocation should be easy. Also the PartitionInvocation and TargetInvocation can be folded into Invocation.

Constructor Summary

Constructors

Constructor and Description
InvocationRegistry(ILogger logger, CallIdSequence callIdSequence)

Method Summary

Modifier and Type	Method and Description
boolean	deregister(Invocation invocation) Deregisters an invocation.
Set<Map.Entry<Long,Invocation>>	entrySet() Intention to expose the entry set is to mutate it.
Invocation	get(long callId) Gets the invocation for the given call ID.
Iterator<Invocation>	iterator()
void	provideMetrics(MetricsRegistry registry)
boolean	register(Invocation invocation) Registers an invocation.
void	reset(Throwable cause)
void	shutdown()
int	size() Returns the number of pending invocations.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

InvocationRegistry

public InvocationRegistry(ILogger logger,
                          CallIdSequence callIdSequence)

Method Detail

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

register

public boolean register(Invocation invocation)

Registers an invocation.

Parameters:

invocation - The invocation to register.

Returns:

false when InvocationRegistry is not alive and registration is not successful, true otherwise

deregister

public boolean deregister(Invocation invocation)

Deregisters an invocation. If the associated operation is inactive, takes no action and returns false. This ensures the idempotency of deregistration.

Parameters:

invocation - The Invocation to deregister.

Returns:

true if this call deregistered the invocation; false if the invocation wasn't registered

size

public int size()

Returns the number of pending invocations.

Returns:

the number of pending invocations

iterator

public Iterator<Invocation> iterator()

Specified by:

iterator in interface Iterable<Invocation>

entrySet

public Set<Map.Entry<Long,Invocation>> entrySet()

Intention to expose the entry set is to mutate it.

Returns:

set of invocations in this registry

get

public Invocation get(long callId)

Gets the invocation for the given call ID.

Parameters:

callId - the call ID

Returns:

the Invocation for the given call ID, or null if no invocation was found.

reset

public void reset(Throwable cause)

shutdown

public void shutdown()