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

Methods inherited from interface com.hazelcast.spi.OperationService

createInvocationBuilder, createInvocationBuilder, execute, invokeOnAllPartitions, invokeOnAllPartitionsAsync, invokeOnPartition, invokeOnPartition, invokeOnPartitions, invokeOnPartitions, invokeOnPartitionsAsync, 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.

onStartAsyncOperation

void onStartAsyncOperation(Operation op)

Should be called when an asynchronous operations not running on a operation thread is running. Primary purpose is to provide heartbeats

Parameters:

op -

onCompletionAsyncOperation

void onCompletionAsyncOperation(Operation op)

Should be called when the asynchronous operation has completed.

Parameters:

op -

See Also:

onStartAsyncOperation(Operation)

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

executeOnPartitions

void executeOnPartitions(PartitionTaskFactory taskFactory,
                         BitSet partitions)

Executes for each of the partitions, a task created by the taskFactory. For more info see the OperationExecutor.executeOnPartitions(PartitionTaskFactory, BitSet)

Parameters:

taskFactory - the PartitionTaskFactory used to create operations.

partitions - the partitions to execute an operation on.

Throws:

NullPointerException - if taskFactory or partitions is null.

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)

onEndpointLeft

void onEndpointLeft(Address endpoint)

Cleans up heartbeats and fails invocations for the given endpoint.

Parameters:

endpoint - the endpoint that has left