com.hazelcast.spi.impl.operationservice.impl

Class CallIdSequence.CallIdSequenceWithBackpressure

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.CallIdSequence

com.hazelcast.spi.impl.operationservice.impl.CallIdSequence.CallIdSequenceWithBackpressure

Enclosing class:

CallIdSequence

public static final class CallIdSequence.CallIdSequenceWithBackpressure
extends CallIdSequence

A CallIdSequence that provided backpressure by taking the number in flight operations into account when a call-id needs to be determined. It is possible to temporary exceed the capacity: - due to system operations - due to racy nature of checking if space is available and getting the next sequence. The last cause is not a problem since the capacity is exceeded temporary and it isn't sustainable. So perhaps there are a few threads that at the same time see that the there is space and do a next. But any following invocation needs to wait till there is is capacity.

Nested Class Summary

Nested classes/interfaces inherited from class com.hazelcast.spi.impl.operationservice.impl.CallIdSequence

CallIdSequence.CallIdSequenceWithBackpressure, CallIdSequence.CallIdSequenceWithoutBackpressure

Constructor Summary

Constructors

Constructor and Description
CallIdSequence.CallIdSequenceWithBackpressure(int maxConcurrentInvocations, long backoffTimeoutMs)

Method Summary

Methods

Modifier and Type	Method and Description
void	complete(com.hazelcast.spi.impl.operationservice.impl.Invocation invocation)
long	getLastCallId()
int	getMaxConcurrentInvocations() Returns the maximum concurrent invocations supported.
long	next(com.hazelcast.spi.impl.operationservice.impl.Invocation invocation) Creates the next call-id.

Methods inherited from class com.hazelcast.spi.impl.operationservice.impl.CallIdSequence

skipRegistration

Methods inherited from class java.lang.Object

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

Constructor Detail

CallIdSequence.CallIdSequenceWithBackpressure

public CallIdSequence.CallIdSequenceWithBackpressure(int maxConcurrentInvocations,
                                             long backoffTimeoutMs)

Method Detail

getLastCallId

public long getLastCallId()

getMaxConcurrentInvocations

public int getMaxConcurrentInvocations()

Description copied from class: CallIdSequence

Returns the maximum concurrent invocations supported. Integer.MAX_VALUE means there is no max.

Specified by:

getMaxConcurrentInvocations in class CallIdSequence

Returns:

the maximum concurrent invocation.

next

public long next(com.hazelcast.spi.impl.operationservice.impl.Invocation invocation)

Description copied from class: CallIdSequence

Creates the next call-id.

Operation.CALL_ID_LOCAL_SKIPPED is returned if local registration in the InvocationRegistry can be skipped.

Specified by:

next in class CallIdSequence

Parameters:

invocation - the Invocation to create a call-id for.

Returns:

the generated callId.

complete

public void complete(com.hazelcast.spi.impl.operationservice.impl.Invocation invocation)

Specified by:

complete in class CallIdSequence