com.hazelcast.spi.impl.operationservice.impl

Class OperationServiceImpl

java.lang.Object

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

All Implemented Interfaces:

InternalOperationService, PacketHandler, OperationService

public final class OperationServiceImpl
extends Object
implements InternalOperationService, PacketHandler

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

Constructor Summary

Constructors

Constructor and Description
OperationServiceImpl(NodeEngineImpl nodeEngine)

Method Summary

Methods

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	dumpPerformanceMetrics(StringBuffer sb) Dumps all kinds of metrics: for example, performance.
void	execute(PartitionSpecificRunnable task) Executes a PartitionSpecificRunnable.
void	executeOperation(Operation op) Executes an operation in the operation executor pool.
long	getExecutedOperationCount() This methods is deprecated since 3.5.
int	getGenericOperationThreadCount() This methods is deprecated since 3.5.
InvocationRegistry	getInvocationsRegistry()
IsStillRunningService	getIsStillRunningService()
OperationExecutor	getOperationExecutor()
int	getOperationExecutorQueueSize() This methods is deprecated since 3.5.
int	getPartitionOperationThreadCount() This methods is deprecated since 3.5.
int	getPriorityOperationExecutorQueueSize() This methods is deprecated since 3.5.
int	getRemoteOperationsCount() This methods is deprecated since 3.5.
int	getResponseQueueSize() This methods is deprecated since 3.5.
int	getRunningOperationsCount() This methods is deprecated since 3.5.
List<SlowOperationDTO>	getSlowOperationDTOs() Returns information about long running operations.
void	handle(Packet packet) Signals the PacketHandler that there is a packet to be handled.
Map<Integer,Object>	invokeOnAllPartitions(String serviceName, OperationFactory operationFactory) Invokes a set of operation on each 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.
<E> InternalCompletableFuture<E>	invokeOnTarget(String serviceName, Operation op, Address target)
boolean	isAllowedToRunOnCallingThread(Operation op) Returns true if the given operation is allowed to run on the calling thread, false otherwise.
boolean	isCallTimedOut(Operation op) Checks if this call is timed out.
void	onMemberLeft(MemberImpl member)
void	reset()
void	runOperationOnCallingThread(Operation op) Runs an operation in the calling thread.
boolean	send(Operation op, Address target) Executes an operation remotely.
boolean	send(Response response, Address target) Sends a response to a remote machine.
void	shutdown()
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

start

public void start()

getIsStillRunningService

public IsStillRunningService getIsStillRunningService()

dumpPerformanceMetrics

public void dumpPerformanceMetrics(StringBuffer sb)

Description copied from interface: OperationService

Dumps all kinds of metrics: for example, performance. This can be used for performance analysis. In the future we'll have a more formal (such as map with key/value pairs) information.

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

dumpPerformanceMetrics in interface OperationService

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.

getInvocationsRegistry

public InvocationRegistry getInvocationsRegistry()

getPartitionOperationThreadCount

public int getPartitionOperationThreadCount()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getPartitionOperationThreadCount in interface OperationService

getGenericOperationThreadCount

public int getGenericOperationThreadCount()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getGenericOperationThreadCount in interface OperationService

getRunningOperationsCount

public int getRunningOperationsCount()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getRunningOperationsCount in interface OperationService

getExecutedOperationCount

public long getExecutedOperationCount()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getExecutedOperationCount in interface OperationService

getRemoteOperationsCount

public int getRemoteOperationsCount()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getRemoteOperationsCount in interface OperationService

getOperationExecutorQueueSize

public int getOperationExecutorQueueSize()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getOperationExecutorQueueSize in interface OperationService

getPriorityOperationExecutorQueueSize

public int getPriorityOperationExecutorQueueSize()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getPriorityOperationExecutorQueueSize in interface OperationService

getOperationExecutor

public OperationExecutor getOperationExecutor()

getResponseQueueSize

public int getResponseQueueSize()

Description copied from interface: OperationService

This methods is deprecated since 3.5. This feature will be dropped since it is an internal implementation detail and should not directly be exposed the the SPI user.

Specified by:

getResponseQueueSize in interface OperationService

handle

public void handle(Packet packet)
            throws Exception

Description copied from interface: PacketHandler

Signals the PacketHandler that there is a packet to be handled.

Specified by:

handle in interface PacketHandler

Parameters:

packet - the response packet to handle

Throws:

Exception

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

runOperationOnCallingThread

public void runOperationOnCallingThread(Operation op)

Description copied from interface: OperationService

Runs an operation in the calling thread.

Specified by:

runOperationOnCallingThread in interface OperationService

Parameters:

op - the operation to execute in the calling thread

executeOperation

public void executeOperation(Operation op)

Description copied from interface: OperationService

Executes an operation in the operation executor pool.

Specified by:

executeOperation in interface OperationService

Parameters:

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

isAllowedToRunOnCallingThread

public boolean isAllowedToRunOnCallingThread(Operation op)

Description copied from interface: OperationService

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.runOperationOnCallingThread(Operation) method, otherwise OperationService.executeOperation(Operation) should be used.

Specified by:

isAllowedToRunOnCallingThread in interface OperationService

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

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

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

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.

send

public boolean send(Response response,
           Address target)

Description copied from interface: OperationService

Sends a response to a remote machine.

This methods is deprecated since 3.5. It is an implementation detail, so it is moved to the InternalOperationService.

Specified by:

send in interface OperationService

Parameters:

response - the response to send.

target - the address of the target machine

Returns:

true if send is successful, false otherwise.

onMemberLeft

public void onMemberLeft(MemberImpl member)

reset

public void reset()

shutdown

public void shutdown()