com.hazelcast.spi.impl.operationservice.impl

Class InvocationRegistry

java.lang.Object

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

public class InvocationRegistry
extends Object

The InvocationsRegistry is 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 idea's: - use an 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(NodeEngineImpl nodeEngine, ILogger logger, BackpressureRegulator backpressureRegulator, int concurrencyLevel)

Method Summary

Methods

Modifier and Type	Method and Description
void	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.
long	getLastCallId()
Collection<Invocation>	invocations()
void	notify(Response response, Address sender) Notifies the invocation that a Response is available.
void	notifyBackupComplete(long callId)
void	register(Invocation invocation) Registers an invocation.
void	reset()
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

Constructor Detail

InvocationRegistry

public InvocationRegistry(NodeEngineImpl nodeEngine,
                  ILogger logger,
                  BackpressureRegulator backpressureRegulator,
                  int concurrencyLevel)

Method Detail

getLastCallId

public long getLastCallId()

register

public void register(Invocation invocation)

Registers an invocation.

Parameters:

invocation - The invocation to register.

deregister

public void deregister(Invocation invocation)

Deregisters an invocation.

If the invocation registration was skipped, the call is ignored.

Parameters:

invocation - The Invocation to deregister.

size

public int size()

Returns the number of pending invocations.

Returns:

the number of pending invocations.

invocations

public Collection<Invocation> invocations()

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 callId.

Returns:

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

notify

public void notify(Response response,
          Address sender)

Notifies the invocation that a Response is available.

Parameters:

response - The response that is available.

sender - Endpoint who sent the response

notifyBackupComplete

public void notifyBackupComplete(long callId)

reset

public void reset()

shutdown

public void shutdown()