public interface InternalOperationService extends OperationService, PacketHandler
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 | Method and Description |
---|---|
<V> void |
asyncInvokeOnPartition(String serviceName,
Operation op,
int partitionId,
ExecutionCallback<V> callback) |
void |
execute(PartitionSpecificRunnable task)
Executes a PartitionSpecificRunnable.
|
List<SlowOperationDTO> |
getSlowOperationDTOs()
Returns information about long running operations.
|
boolean |
isCallTimedOut(Operation op)
Checks if this call is timed out.
|
createInvocationBuilder, createInvocationBuilder, dumpPerformanceMetrics, executeOperation, getExecutedOperationCount, getGenericOperationThreadCount, getOperationExecutorQueueSize, getPartitionOperationThreadCount, getPriorityOperationExecutorQueueSize, getRemoteOperationsCount, getResponseQueueSize, getRunningOperationsCount, invokeOnAllPartitions, invokeOnPartition, invokeOnPartitions, invokeOnTarget, isAllowedToRunOnCallingThread, runOperationOnCallingThread, send, send
handle
boolean isCallTimedOut(Operation op)
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 executeList<SlowOperationDTO> getSlowOperationDTOs()
SlowOperationDTO
instances.<V> void asyncInvokeOnPartition(String serviceName, Operation op, int partitionId, ExecutionCallback<V> callback)
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.