com.hazelcast.spi.impl.operationservice

Interface InternalOperationService

All Superinterfaces:

OperationService, PacketHandler

All Known Implementing Classes:

OperationServiceImpl

public interface InternalOperationService
extends OperationService, PacketHandler

This is the interface that needs to be implemented by actual InternalOperationService. Currently there is a single InternalOperationService: 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.

Method Summary

Methods

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.

Methods inherited from interface com.hazelcast.spi.OperationService

createInvocationBuilder, createInvocationBuilder, dumpPerformanceMetrics, executeOperation, getExecutedOperationCount, getGenericOperationThreadCount, getOperationExecutorQueueSize, getPartitionOperationThreadCount, getPriorityOperationExecutorQueueSize, getRemoteOperationsCount, getResponseQueueSize, getRunningOperationsCount, invokeOnAllPartitions, invokeOnPartition, invokeOnPartitions, invokeOnTarget, isAllowedToRunOnCallingThread, runOperationOnCallingThread, send, send

Methods inherited from interface com.hazelcast.spi.impl.PacketHandler

handle

Method Detail

isCallTimedOut

boolean isCallTimedOut(Operation op)

Checks if this call is timed out. A timed out call is not going to be executed.

Parameters:

op - the operation to check.

Returns:

true if it is timed out, false otherwise.

execute

void execute(PartitionSpecificRunnable task)

Executes a PartitionSpecificRunnable.

This method is typically used by the ClientEngine when it has received a Packet containing a request that needs to be processed.

Parameters:

task - the task to execute

getSlowOperationDTOs

List<SlowOperationDTO> getSlowOperationDTOs()

Returns information about long running operations.

Returns:

list of SlowOperationDTO instances.

asyncInvokeOnPartition

<V> void asyncInvokeOnPartition(String serviceName,
                              Operation op,
                              int partitionId,
                              ExecutionCallback<V> callback)