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



Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.