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.
void	executeOnPartitions(PartitionTaskFactory taskFactory, BitSet partitions) Executes for each of the partitions, a task created by the taskFactory.
InboundResponseHandler	getBackupHandler()
long	getExecutedOperationCount() Returns the number of executed operations.
int	getGenericThreadCount() Returns the number of generic threads.
InboundResponseHandlerSupplier	getInboundResponseHandlerSupplier()
com.hazelcast.spi.impl.operationservice.impl.Invocation.Context	getInvocationContext()
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 operations on each partition.
<T> ICompletableFuture<Map<Integer,T>>	invokeOnAllPartitionsAsync(String serviceName, OperationFactory operationFactory) Invokes a set of operations on selected set of all partitions in an async way.
<E> InternalCompletableFuture<E>	invokeOnPartition(Operation op) Executes an operation on a partition.
<E> InternalCompletableFuture<E>	invokeOnPartition(String serviceName, Operation op, int partitionId)
<T> Map<Integer,T>	invokeOnPartitions(String serviceName, OperationFactory operationFactory, Collection<Integer> partitions) Invokes a set of operations on selected set of partitions.
Map<Integer,Object>	invokeOnPartitions(String serviceName, OperationFactory operationFactory, int[] partitions) Invokes a set of operations on selected set of partitions.
<T> ICompletableFuture<Map<Integer,T>>	invokeOnPartitionsAsync(String serviceName, OperationFactory operationFactory, Collection<Integer> partitions) Invokes a set of operations on selected set of partitions in an async way.
<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) Should be called when the asynchronous operation has completed.
void	onEndpointLeft(Address endpoint) Cleans up heartbeats and fails invocations for the given endpoint.
void	onMemberLeft(MemberImpl member)
void	onStartAsyncOperation(Operation op) Should be called when an asynchronous operations not running on a operation thread is running.
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()

getInboundResponseHandlerSupplier

public InboundResponseHandlerSupplier getInboundResponseHandlerSupplier()

getInvocationMonitor

public 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()

getBackupHandler

public InboundResponseHandler getBackupHandler()

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

executeOnPartitions

public void executeOnPartitions(PartitionTaskFactory taskFactory,
                                BitSet partitions)

Description copied from interface: InternalOperationService

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

Specified by:

executeOnPartitions in interface InternalOperationService

Parameters:

taskFactory - the PartitionTaskFactory used to create operations.

partitions - the partitions to execute an operation on.

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)

Description copied from interface: InternalOperationService

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

Specified by:

onStartAsyncOperation in interface InternalOperationService

onCompletionAsyncOperation

public void onCompletionAsyncOperation(Operation op)

Description copied from interface: InternalOperationService

Should be called when the asynchronous operation has completed.

Specified by:

onCompletionAsyncOperation in interface InternalOperationService

See Also:

InternalOperationService.onStartAsyncOperation(Operation)

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 operations on each partition.

This method blocks until the operations complete.

If the operations have sync backups, this method will not wait for their completion. Instead, it will return once the operations are completed on primary replicas of the given partitions.

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 a key and the outcome of the operation as a value.

Throws:

Exception

invokeOnAllPartitionsAsync

public <T> ICompletableFuture<Map<Integer,T>> invokeOnAllPartitionsAsync(String serviceName,
                                                                         OperationFactory operationFactory)

Description copied from interface: OperationService

Invokes a set of operations on selected set of all partitions in an async way.

If the operations have sync backups, the returned ICompletableFuture does not wait for their completion. Instead, the ICompletableFuture is completed once the operations are completed on primary replicas of the given partitions.

Specified by:

invokeOnAllPartitionsAsync in interface OperationService

Type Parameters:

T - type of result of operations returned by operationFactory

Parameters:

serviceName - the name of the service

operationFactory - the factory responsible for creating operations

Returns:

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

invokeOnPartitions

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

Description copied from interface: OperationService

Invokes a set of operations on selected set of partitions.

This method blocks until all operations complete.

If the operations have sync backups, this method will not wait for their completion. Instead, it will return once the operations are completed on primary replicas of the given partitions.

Specified by:

invokeOnPartitions in interface OperationService

Type Parameters:

T - type of result of operations returned by operationFactory

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 a key and the outcome of the operation as a value.

Throws:

Exception - if there was an exception while waiting for the results of the partition invocations

invokeOnPartitionsAsync

public <T> ICompletableFuture<Map<Integer,T>> invokeOnPartitionsAsync(String serviceName,
                                                                      OperationFactory operationFactory,
                                                                      Collection<Integer> partitions)

Description copied from interface: OperationService

Invokes a set of operations on selected set of partitions in an async way.

If the operations have sync backups, the returned ICompletableFuture does not wait for their completion. Instead, the ICompletableFuture is completed once the operations are completed on primary replicas of the given partitions.

Specified by:

invokeOnPartitionsAsync in interface OperationService

Type Parameters:

T - type of result of operations returned by operationFactory

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 future returning a Map with partitionId as a key and the outcome of the operation as a value.

invokeOnPartitions

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

Description copied from interface: OperationService

Invokes a set of operations on selected set of partitions.

This method blocks until all operations complete.

If the operations have sync backups, this method will not wait for their completion. Instead, it will return once the operations are completed on primary replicas of the given partitions.

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 a key and the outcome of the operation as a 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)

onEndpointLeft

public void onEndpointLeft(Address endpoint)

Description copied from interface: InternalOperationService

Cleans up heartbeats and fails invocations for the given endpoint.

Specified by:

onEndpointLeft in interface InternalOperationService

Parameters:

endpoint - the endpoint that has left

reset

public void reset()

provideMetrics

public void provideMetrics(MetricsRegistry registry)

Specified by:

provideMetrics in interface MetricsProvider

start

public void start()

getInvocationContext

public com.hazelcast.spi.impl.operationservice.impl.Invocation.Context getInvocationContext()

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()