com.hazelcast.spi.impl.operationservice.impl

Class OperationServiceImpl

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.OperationServiceImpl

All Implemented Interfaces:

MetricsProvider, InternalOperationService, LiveOperationsTracker, OperationService

public final class OperationServiceImpl
extends Object
implements InternalOperationService, MetricsProvider, LiveOperationsTracker

This is the implementation of the InternalOperationService.

System Operation

When a UrgentSystemOperation is invoked on this OperationService, it will be executed with a high urgency by making use of a urgent queue. So when the system is under load, and the operation queues are filled, then system operations are executed before normal operation. The advantage is that when a system is under pressure, it still is able to do things like recognizing new members in the cluster and moving partitions around.

When a UrgentSystemOperation is send to a remote machine, it is wrapped in a Packet and the packet is marked as a urgent packet. When this packet is received on the remove OperationService, the urgent flag is checked and if needed, the operation is set on the urgent queue. So local and remote execution of System operations will obey the urgency.

See Also:

Invocation, InvocationBuilderImpl, PartitionInvocation, TargetInvocation

Field Summary

Fields inherited from interface com.hazelcast.spi.impl.operationservice.InternalOperationService

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
OperationServiceImpl(NodeEngineImpl nodeEngine)

Method Summary

Modifier and Type	Method and Description
<V> void	asyncInvokeOnPartition(String serviceName, Operation op, int partitionId, ExecutionCallback<V> callback)
InvocationBuilder	createInvocationBuilder(String serviceName, Operation op, Address target)
InvocationBuilder	createInvocationBuilder(String serviceName, Operation op, int partitionId)
void	execute(Operation op) Executes an operation in the operation executor pool.
void	execute(PartitionSpecificRunnable task) Executes a PartitionSpecificRunnable.
PacketHandler	getAsyncInboundResponseHandler()
long	getExecutedOperationCount() Returns the number of executed operations.
int	getGenericThreadCount() Returns the number of generic threads.
InboundResponseHandler	getInboundResponseHandler()
com.hazelcast.spi.impl.operationservice.impl.InvocationMonitor	getInvocationMonitor()
InvocationRegistry	getInvocationRegistry()
OperationExecutor	getOperationExecutor()
int	getOperationExecutorQueueSize()
OutboundResponseHandler	getOutboundResponseHandler()
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.
Map<Integer,Object>	invokeOnAllPartitions(String serviceName, OperationFactory operationFactory) Invokes a set of operation on each partition.
<E> InternalCompletableFuture<E>	invokeOnPartition(Operation op) Executes an operation on a partition.
<E> InternalCompletableFuture<E>	invokeOnPartition(String serviceName, Operation op, int partitionId)
Map<Integer,Object>	invokeOnPartitions(String serviceName, OperationFactory operationFactory, Collection<Integer> partitions) Invokes an set of operation on selected set of partitions * This method blocks until all operations complete.
Map<Integer,Object>	invokeOnPartitions(String serviceName, OperationFactory operationFactory, int[] partitions) Invokes an set of operation on selected set of partitions * This method blocks until all operations complete.
<E> InternalCompletableFuture<E>	invokeOnTarget(String serviceName, Operation op, Address target)
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)
void	onMemberLeft(MemberImpl member)
void	onStartAsyncOperation(Operation op)
void	populate(LiveOperations liveOperations) Populate the LiveOperations
void	provideMetrics(MetricsRegistry registry)
void	reset()
void	run(Operation op) Runs an operation in the calling thread.
boolean	send(Operation op, Address target) Executes an operation remotely.
void	shutdownInvocations() Shuts down invocation infrastructure.
void	shutdownOperationExecutor()
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperationServiceImpl

public OperationServiceImpl(NodeEngineImpl nodeEngine)

Method Detail

getOutboundResponseHandler

public OutboundResponseHandler getOutboundResponseHandler()

getAsyncInboundResponseHandler

public PacketHandler getAsyncInboundResponseHandler()

getInvocationMonitor

public com.hazelcast.spi.impl.operationservice.impl.InvocationMonitor getInvocationMonitor()

getSlowOperationDTOs

public List<SlowOperationDTO> getSlowOperationDTOs()

Description copied from interface: InternalOperationService

Returns information about long running operations.

Specified by:

getSlowOperationDTOs in interface InternalOperationService

Returns:

list of SlowOperationDTO instances.

getInvocationRegistry

public InvocationRegistry getInvocationRegistry()

getInboundResponseHandler

public InboundResponseHandler getInboundResponseHandler()

getPartitionThreadCount

public int getPartitionThreadCount()

Description copied from interface: InternalOperationService

Returns the number of partition threads.

Specified by:

getPartitionThreadCount in interface InternalOperationService

Returns:

the number of partition threads.

getGenericThreadCount

public int getGenericThreadCount()

Description copied from interface: InternalOperationService

Returns the number of generic threads.

Specified by:

getGenericThreadCount in interface InternalOperationService

Returns:

number of generic threads.

getRunningOperationsCount

public int getRunningOperationsCount()

Specified by:

getRunningOperationsCount in interface InternalOperationService

getExecutedOperationCount

public long getExecutedOperationCount()

Description copied from interface: InternalOperationService

Returns the number of executed operations.

Specified by:

getExecutedOperationCount in interface InternalOperationService

Returns:

the number of executed operations.

getRemoteOperationsCount

public int getRemoteOperationsCount()

Specified by:

getRemoteOperationsCount in interface InternalOperationService

getOperationExecutorQueueSize

public int getOperationExecutorQueueSize()

Specified by:

getOperationExecutorQueueSize in interface InternalOperationService

getPriorityOperationExecutorQueueSize

public int getPriorityOperationExecutorQueueSize()

Specified by:

getPriorityOperationExecutorQueueSize in interface InternalOperationService

getOperationExecutor

public OperationExecutor getOperationExecutor()

getResponseQueueSize

public int getResponseQueueSize()

Description copied from interface: InternalOperationService

Returns the size of the response queue.

Specified by:

getResponseQueueSize in interface InternalOperationService

Returns:

the size of the response queue.

populate

public void populate(LiveOperations liveOperations)

Description copied from interface: LiveOperationsTracker

Populate the LiveOperations

Specified by:

populate in interface LiveOperationsTracker

Parameters:

liveOperations - the LiveOperations to populate.

execute

public void execute(PartitionSpecificRunnable task)

Description copied from interface: InternalOperationService

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.

Specified by:

execute in interface InternalOperationService

Parameters:

task - the task to execute

createInvocationBuilder

public InvocationBuilder createInvocationBuilder(String serviceName,
                                                 Operation op,
                                                 int partitionId)

Specified by:

createInvocationBuilder in interface OperationService

createInvocationBuilder

public InvocationBuilder createInvocationBuilder(String serviceName,
                                                 Operation op,
                                                 Address target)

Specified by:

createInvocationBuilder in interface OperationService

run

public void run(Operation op)

Description copied from interface: OperationService

Runs an operation in the calling thread.

Specified by:

run in interface OperationService

Parameters:

op - the operation to execute in the calling thread

execute

public void execute(Operation op)

Description copied from interface: OperationService

Executes an operation in the operation executor pool.

Specified by:

execute in interface OperationService

Parameters:

op - the operation to execute in the operation executor pool.

isRunAllowed

public boolean isRunAllowed(Operation op)

Description copied from interface: InternalOperationService

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.

Specified by:

isRunAllowed in interface InternalOperationService

Parameters:

op - the operation to check.

Returns:

true if the operation is allowed to run on the calling thread, false otherwise.

invokeOnPartition

public <E> InternalCompletableFuture<E> invokeOnPartition(String serviceName,
                                                          Operation op,
                                                          int partitionId)

Specified by:

invokeOnPartition in interface OperationService

invokeOnPartition

public <E> InternalCompletableFuture<E> invokeOnPartition(Operation op)

Description copied from interface: OperationService

Executes an operation on a partition.

Specified by:

invokeOnPartition in interface OperationService

Type Parameters:

E - the return type of the operation response

Parameters:

op - the operation

Returns:

the future.

invokeOnTarget

public <E> InternalCompletableFuture<E> invokeOnTarget(String serviceName,
                                                       Operation op,
                                                       Address target)

Specified by:

invokeOnTarget in interface OperationService

asyncInvokeOnPartition

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

Specified by:

asyncInvokeOnPartition in interface InternalOperationService

onStartAsyncOperation

public void onStartAsyncOperation(Operation op)

onCompletionAsyncOperation

public void onCompletionAsyncOperation(Operation op)

isCallTimedOut

public boolean isCallTimedOut(Operation op)

Description copied from interface: InternalOperationService

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

Specified by:

isCallTimedOut in interface InternalOperationService

Parameters:

op - the operation to check.

Returns:

true if it is timed out, false otherwise.

invokeOnAllPartitions

public Map<Integer,Object> invokeOnAllPartitions(String serviceName,
                                                 OperationFactory operationFactory)
                                          throws Exception

Description copied from interface: OperationService

Invokes a set of operation on each partition.

This method blocks until the operation completes.

Specified by:

invokeOnAllPartitions in interface OperationService

Parameters:

serviceName - the name of the service.

operationFactory - the factory responsible for creating operations

Returns:

a Map with partitionId as key and the outcome of the operation as value.

Throws:

Exception

invokeOnPartitions

public Map<Integer,Object> invokeOnPartitions(String serviceName,
                                              OperationFactory operationFactory,
                                              Collection<Integer> partitions)
                                       throws Exception

Description copied from interface: OperationService

Invokes an set of operation on selected set of partitions *

This method blocks until all operations complete.

Specified by:

invokeOnPartitions in interface OperationService

Parameters:

serviceName - the name of the service

operationFactory - the factory responsible for creating operations

partitions - the partitions the operation should be executed on.

Returns:

a Map with partitionId as key and the outcome of the operation as value.

Throws:

Exception

invokeOnPartitions

public Map<Integer,Object> invokeOnPartitions(String serviceName,
                                              OperationFactory operationFactory,
                                              int[] partitions)
                                       throws Exception

Description copied from interface: OperationService

Invokes an set of operation on selected set of partitions *

This method blocks until all operations complete.

Specified by:

invokeOnPartitions in interface OperationService

Parameters:

serviceName - the name of the service

operationFactory - the factory responsible for creating operations

partitions - the partitions the operation should be executed on.

Returns:

a Map with partitionId as key and the outcome of the operation as value.

Throws:

Exception

send

public boolean send(Operation op,
                    Address target)

Description copied from interface: OperationService

Executes an operation remotely.

It isn't allowed

Specified by:

send in interface OperationService

Parameters:

op - the operation to send and execute.

target - the address of that target member.

Returns:

true if send is successful, false otherwise.

onMemberLeft

public void onMemberLeft(MemberImpl member)

reset

public void reset()

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

start

public void start()

shutdownInvocations

public void shutdownInvocations()

Shuts down invocation infrastructure. New invocation requests will be rejected after shutdown and all pending invocations will be notified with a failure response.

shutdownOperationExecutor

public void shutdownOperationExecutor()