com.hazelcast.spi.impl.operationservice.impl

Class IsStillRunningService

java.lang.Object

com.hazelcast.spi.impl.operationservice.impl.IsStillRunningService

public class IsStillRunningService
extends Object

Checks if an Operation is still running. This is useful when an operation isn't executed (e.g. got lost due to an OOME on the remote side) and no response is ever send. The behavior needs to be cleaned up. Currently we only detect if an operation is actually running, not if it is in a queue somewhere. So it can mean that you assume an operation isn't running, even though it is queued. Another issue is that the actual IsStillRunningOperation isn't executed quick enough and then the system still decides that the operation isn't running. Instead of letting every invocation ask the remote system if an operation is still running, let the remote system send a batch of all the call-id's for a particular member of the operations that are running.

Constructor Summary

Constructors

Constructor and Description
IsStillRunningService(OperationExecutor operationExecutor, NodeEngineImpl nodeEngine, ILogger logger)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isOperationExecuting(Address callerAddress, int partitionId, long operationCallId) Checks if an operation is still running.
boolean	isOperationExecuting(Address callerAddress, String callerUuid, String serviceName, Object identifier) Checks if an operation is still running.
boolean	isOperationExecuting(Invocation invocation) Checks if an operation is still running.
void	timeoutInvocationIfNotExecuting(Invocation invocation) Sets operation timeout to invocation result if the operation is not running.

Methods inherited from class java.lang.Object

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

Constructor Detail

IsStillRunningService

public IsStillRunningService(OperationExecutor operationExecutor,
                     NodeEngineImpl nodeEngine,
                     ILogger logger)

Method Detail

isOperationExecuting

public boolean isOperationExecuting(Invocation invocation)

Checks if an operation is still running.

Parameters:

invocation - The invocation for this operation.

Returns:

true if the operation is running, false otherwise.

timeoutInvocationIfNotExecuting

public void timeoutInvocationIfNotExecuting(Invocation invocation)

Sets operation timeout to invocation result if the operation is not running.

Parameters:

invocation - The invocation to check

isOperationExecuting

public boolean isOperationExecuting(Address callerAddress,
                           String callerUuid,
                           String serviceName,
                           Object identifier)

Checks if an operation is still running.

Parameters:

callerAddress - The caller address for this operation.

callerUuid - The caller Uuid for this operation.

serviceName - The service name for this operation.

identifier - The object identifier for this operation.

Returns:

true if the operation is running, false otherwise.

isOperationExecuting

public boolean isOperationExecuting(Address callerAddress,
                           int partitionId,
                           long operationCallId)

Checks if an operation is still running.

If the partition id is set, then it is super cheap: it just involves some volatile reads since the right worker thread can be found and in the worker-thread the current operation is stored in a volatile field.

If the partition id isn't set, then we iterate over all generic-operationthread and check if one of them is running the given operation. So this is more expensive, but in most cases this should not be an issue since most of the data is hot in cache.

Parameters:

callerAddress - The caller address for this operation.

partitionId - The id of the partition where this operation resides.

operationCallId - The call id for this operation.

Returns:

true if the operation is running, false otherwise.