public interface InternalOperationService extends OperationService
OperationServiceImpl
, but
in the future others can be added.
It exposes methods that will not be called by regular code, like shutdown,
but will only be called by the the SPI management.Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
<V> void |
asyncInvokeOnPartition(String serviceName,
Operation op,
int partitionId,
ExecutionCallback<V> callback) |
void |
execute(PartitionSpecificRunnable task)
Executes a PartitionSpecificRunnable.
|
void |
executeOnPartitions(PartitionTaskFactory taskFactory,
BitSet partitions)
Executes for each of the partitions, a task created by the
taskFactory.
|
long |
getExecutedOperationCount()
Returns the number of executed operations.
|
int |
getGenericThreadCount()
Returns the number of generic threads.
|
int |
getOperationExecutorQueueSize() |
int |
getPartitionThreadCount()
Returns the number of partition threads.
|
int |
getPriorityOperationExecutorQueueSize() |
int |
getRemoteOperationsCount() |
int |
getResponseQueueSize()
Returns the size of the response queue.
|
int |
getRunningOperationsCount() |
List<SlowOperationDTO> |
getSlowOperationDTOs()
Returns information about long running operations.
|
boolean |
isCallTimedOut(Operation op)
Checks if this call is timed out.
|
boolean |
isRunAllowed(Operation op)
Returns true if the given operation is allowed to run on the calling
thread, false otherwise.
|
void |
onCompletionAsyncOperation(Operation op)
Should be called when the asynchronous operation has completed.
|
void |
onEndpointLeft(Address endpoint)
Cleans up heartbeats and fails invocations for the given endpoint.
|
void |
onStartAsyncOperation(Operation op)
Should be called when an asynchronous operations not running on a operation thread is running.
|
createInvocationBuilder, createInvocationBuilder, execute, invokeOnAllPartitions, invokeOnAllPartitionsAsync, invokeOnPartition, invokeOnPartition, invokeOnPartitions, invokeOnPartitions, invokeOnPartitionsAsync, invokeOnTarget, run, send
static final String SERVICE_NAME
int getResponseQueueSize()
int getOperationExecutorQueueSize()
int getPriorityOperationExecutorQueueSize()
int getRunningOperationsCount()
int getRemoteOperationsCount()
long getExecutedOperationCount()
int getPartitionThreadCount()
int getGenericThreadCount()
void onStartAsyncOperation(Operation op)
op
- void onCompletionAsyncOperation(Operation op)
op
- onStartAsyncOperation(Operation)
boolean isCallTimedOut(Operation op)
op
- the operation to check.boolean isRunAllowed(Operation op)
OperationService.run(Operation)
method, otherwise
OperationService.execute(Operation)
should be used.op
- the operation to check.void execute(PartitionSpecificRunnable task)
ClientEngine
when it has received a Packet containing a request that needs to be processed.task
- the task to executevoid executeOnPartitions(PartitionTaskFactory taskFactory, BitSet partitions)
OperationExecutor.executeOnPartitions(PartitionTaskFactory, BitSet)
taskFactory
- the PartitionTaskFactory used to create
operations.partitions
- the partitions to execute an operation on.NullPointerException
- if taskFactory or partitions is null.List<SlowOperationDTO> getSlowOperationDTOs()
SlowOperationDTO
instances.<V> void asyncInvokeOnPartition(String serviceName, Operation op, int partitionId, ExecutionCallback<V> callback)
void onEndpointLeft(Address endpoint)
endpoint
- the endpoint that has leftCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.