com.hazelcast.spi.impl.operationservice

Interface InternalOperationService

All Superinterfaces:

OperationService

All Known Implementing Classes:

OperationServiceImpl

public interface InternalOperationService
extends OperationService

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.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Method Summary

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.
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.

Methods inherited from interface com.hazelcast.spi.OperationService

createInvocationBuilder, createInvocationBuilder, execute, invokeOnAllPartitions, invokeOnPartition, invokeOnPartition, invokeOnPartitions, invokeOnPartitions, invokeOnTarget, run, send

Field Detail

SERVICE_NAME

static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

getResponseQueueSize

int getResponseQueueSize()

Returns the size of the response queue.

Returns:

the size of the response queue.

getOperationExecutorQueueSize

int getOperationExecutorQueueSize()

getPriorityOperationExecutorQueueSize

int getPriorityOperationExecutorQueueSize()

getRunningOperationsCount

int getRunningOperationsCount()

getRemoteOperationsCount

int getRemoteOperationsCount()

getExecutedOperationCount

long getExecutedOperationCount()

Returns the number of executed operations.

Returns:

the number of executed operations.

getPartitionThreadCount

int getPartitionThreadCount()

Returns the number of partition threads.

Returns:

the number of partition threads.

getGenericThreadCount

int getGenericThreadCount()

Returns the number of generic threads.

Returns:

number of generic threads.

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.

isRunAllowed

boolean isRunAllowed(Operation op)

Returns true if the given operation is allowed to run on the calling thread, false otherwise. If this method returns true, then the operation can be executed using OperationService.run(Operation) method, otherwise OperationService.execute(Operation) should be used.

Parameters:

op - the operation to check.

Returns:

true if the operation is allowed to run on the calling thread, 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)