| Package | Description |
|---|---|
| com.hazelcast.spi.impl.operationservice.impl |
Contains the code for the
InternalOperationService implementation. |
| Modifier and Type | Class and Description |
|---|---|
class |
PartitionInvocation
A
Invocation evaluates a Operation Invocation for a particular partition running on top of the
OperationServiceImpl. |
class |
TargetInvocation
A
Invocation evaluates a Operation Invocation for a particular target running on top of the
OperationServiceImpl. |
| Modifier and Type | Method and Description |
|---|---|
Invocation |
InvocationRegistry.get(long callId)
Gets the invocation for the given call id.
|
| Modifier and Type | Method and Description |
|---|---|
Set<Map.Entry<Long,Invocation>> |
InvocationRegistry.entrySet()
Intention to expose the entry set is to mutate it.
|
Collection<Invocation> |
InvocationRegistry.invocations() |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
CallIdSequence.complete(Invocation invocation) |
void |
CallIdSequence.CallIdSequenceWithoutBackpressure.complete(Invocation invocation) |
void |
CallIdSequence.CallIdSequenceWithBackpressure.complete(Invocation invocation) |
void |
InvocationRegistry.deregister(Invocation invocation)
Deregisters an invocation.
|
boolean |
IsStillRunningService.isOperationExecuting(Invocation invocation)
Checks if an operation is still running.
|
abstract long |
CallIdSequence.next(Invocation invocation)
Creates the next call-id.
|
long |
CallIdSequence.CallIdSequenceWithoutBackpressure.next(Invocation invocation) |
long |
CallIdSequence.CallIdSequenceWithBackpressure.next(Invocation invocation) |
void |
InvocationRegistry.register(Invocation invocation)
Registers an invocation.
|
protected boolean |
CallIdSequence.skipRegistration(Invocation invocation)
Not every call needs to be registered.
|
void |
IsStillRunningService.timeoutInvocationIfNotExecuting(Invocation invocation)
Sets operation timeout to invocation result if the operation is not running.
|
Copyright © 2016. All Rights Reserved.