com.hazelcast.spi.impl

Interface InternalOperationService

All Superinterfaces:

OperationService

public interface InternalOperationService
extends OperationService

This is the interface that needs to be implemented by actual InternalOperationService. Currently there is a single InternalOperationService: BasicOperationService, 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
void	execute(Runnable task, int partitionId) Executes a Runnable on a thread that is responsible for a given partition.
void	executeOperation(Packet packet) Executes an operation.
boolean	isCallTimedOut(Operation op)
void	notifyBackupCall(long callId)
void	onMemberLeft(MemberImpl member)
void	reset() Resets internal state of InternalOperationService.
void	shutdown() Shuts down this InternalOperationService.

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

Method Detail

onMemberLeft

void onMemberLeft(MemberImpl member)

isCallTimedOut

boolean isCallTimedOut(Operation op)

notifyBackupCall

void notifyBackupCall(long callId)

execute

void execute(Runnable task,
           int partitionId)

Executes a Runnable on a thread that is responsible for a given partition. This method is typically used by the ClientEngine when it has received a Packet containing a request that needs to be processed. The advantage of this method is that the request can immediately be handed over to a thread that can take care of it; either execute it directly or send it to the remote machine.

Parameters:

task - the task to execute

partitionId - the partition id. A partition of smaller than 0, means that the task is going to be executed in the generic operation-threads and not on a partition specific operation-thread.

executeOperation

void executeOperation(Packet packet)

Executes an operation. This method is typically called by the IO system when an operation-packet is received.

Parameters:

packet - the packet containing the serialized operation.

reset

void reset()

Resets internal state of InternalOperationService. Notifies registered invocations with an error message.

shutdown

void shutdown()

Shuts down this InternalOperationService.