com.hazelcast.spi.impl

Class BasicPartitionInvocation

java.lang.Object

com.hazelcast.spi.impl.BasicPartitionInvocation

All Implemented Interfaces:

ResponseHandler, Runnable

public final class BasicPartitionInvocation
extends Object

A BasicInvocation evaluates a Operation Invocation for a particular partition running on top of the BasicOperationService.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	callTimeout
protected ILogger	logger
protected NodeEngineImpl	nodeEngine
protected Operation	op
protected int	partitionId
protected long	pendingResponseReceivedMillis The time in millis when the response of the primary has been received.
protected int	replicaIndex
protected String	serviceName
protected int	tryCount
protected long	tryPauseMillis

Constructor Summary

Constructors

Constructor and Description
BasicPartitionInvocation(NodeEngineImpl nodeEngine, String serviceName, Operation op, int partitionId, int replicaIndex, int tryCount, long tryPauseMillis, long callTimeout, Callback<Object> callback, String executorName, boolean resultDeserialized)

Method Summary

Methods

Modifier and Type	Method and Description
int	getPartitionId()
int	getReplicaIndex()
String	getServiceName()
Address	getTarget()
void	handleBackupTimeout(long timeoutMillis)
void	handleOperationTimeout()
com.hazelcast.spi.impl.BasicInvocationFuture	invoke()
boolean	isCallTarget(MemberImpl leftMember)
boolean	isLocal()
void	notify(Object obj)
void	run()
void	sendResponse(Object obj)
void	signalOneBackupComplete()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

pendingResponseReceivedMillis

protected long pendingResponseReceivedMillis

The time in millis when the response of the primary has been received.

callTimeout

protected final long callTimeout

nodeEngine

protected final NodeEngineImpl nodeEngine

serviceName

protected final String serviceName

op

protected final Operation op

partitionId

protected final int partitionId

replicaIndex

protected final int replicaIndex

tryCount

protected final int tryCount

tryPauseMillis

protected final long tryPauseMillis

logger

protected final ILogger logger

Constructor Detail

BasicPartitionInvocation

public BasicPartitionInvocation(NodeEngineImpl nodeEngine,
                        String serviceName,
                        Operation op,
                        int partitionId,
                        int replicaIndex,
                        int tryCount,
                        long tryPauseMillis,
                        long callTimeout,
                        Callback<Object> callback,
                        String executorName,
                        boolean resultDeserialized)

Method Detail

getTarget

public Address getTarget()

getServiceName

public String getServiceName()

getReplicaIndex

public int getReplicaIndex()

getPartitionId

public int getPartitionId()

invoke

public final com.hazelcast.spi.impl.BasicInvocationFuture invoke()

sendResponse

public void sendResponse(Object obj)

Specified by:

sendResponse in interface ResponseHandler

isLocal

public boolean isLocal()

Specified by:

isLocal in interface ResponseHandler

isCallTarget

public boolean isCallTarget(MemberImpl leftMember)

notify

public void notify(Object obj)

signalOneBackupComplete

public void signalOneBackupComplete()

handleOperationTimeout

public void handleOperationTimeout()

handleBackupTimeout

public void handleBackupTimeout(long timeoutMillis)

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class Object