com.orientechnologies.orient.server.distributed

Class ODistributedResponseManagerImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.ODistributedResponseManagerImpl

All Implemented Interfaces:

ODistributedResponseManager

public class ODistributedResponseManagerImpl
extends Object
implements ODistributedResponseManager

Asynchronous response manager. All the public methods have to pay attention on synchronizing access by using synchronousResponsesLock lock.

TODO: - set flags during collecting of response for fast computation on checking for the status

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Field Summary

Fields

Modifier and Type	Field and Description
static int	ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

Constructor Summary

Constructors

Constructor and Description
ODistributedResponseManagerImpl(ODistributedServerManager iManager, ODistributedRequest iRequest, Collection<String> expectedResponses, Set<String> iNodesConcurInQuorum, int iTotalExpectedResponses, int iQuorum, boolean iWaitForLocalNode, long iSynchTimeout, long iTotalTimeout, boolean iGroupResponsesByResult, OCallable<Void,ODistributedResponseManager> endCallback)

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected boolean	checkNoWinnerCase(List<ODistributedResponse> bestResponsesGroup)
boolean	collectResponse(ODistributedResponse response) Not synchronized, it's called when a message arrives
protected int	getBestResponsesGroup() Returns the biggest response group.
protected List<ODistributedResponse>	getConflictResponses() Returns all the responses in conflict.
String	getDatabaseName()
Set<String>	getExpectedNodes()
protected int	getExpectedResponses()
ODistributedResponse	getFinalResponse()
ODistributedRequestId	getMessageId()
List<String>	getMissingNodes() Returns the list of node names that didn't provide a response.
int	getQuorum()
protected List<ODistributedResponse>	getReceivedResponses() Returns the received response objects.
protected int	getReceivedResponsesCount()
ODistributedRequest	getRequest()
List<String>	getRespondingNodes() Returns the list of node names that provided a response.
long	getSentOn()
Set<String>	getServersWithoutFollowup()
long	getSynchTimeout()
protected long	getTotalTimeout()
boolean	isCanceled()
boolean	isFinished()
protected boolean	isMinimumQuorumReached(boolean reachedTimeout)
boolean	isReceivedCurrentNode()
boolean	isWaitForLocalNode()
protected RuntimeException	manageConflicts()
void	removeServerBecauseUnreachable(String node)
boolean	setLocalResult(String localNodeName, Object localResult)
void	timeout()
protected boolean	undoRequest()
boolean	waitForSynchronousResponses() Waits until the minimum responses are collected or timeout occurs.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.server.distributed.ODistributedResponseManager

getGenericFinalResponse

Field Detail

ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

public static final int ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

See Also:

Constant Field Values

Constructor Detail

ODistributedResponseManagerImpl

public ODistributedResponseManagerImpl(ODistributedServerManager iManager,
                                       ODistributedRequest iRequest,
                                       Collection<String> expectedResponses,
                                       Set<String> iNodesConcurInQuorum,
                                       int iTotalExpectedResponses,
                                       int iQuorum,
                                       boolean iWaitForLocalNode,
                                       long iSynchTimeout,
                                       long iTotalTimeout,
                                       boolean iGroupResponsesByResult,
                                       OCallable<Void,ODistributedResponseManager> endCallback)

Method Detail

collectResponse

public boolean collectResponse(ODistributedResponse response)

Not synchronized, it's called when a message arrives

Specified by:

collectResponse in interface ODistributedResponseManager

Parameters:

response - Received response to collect

Returns:

True if all the nodes responded, otherwise false

getMessageId

public ODistributedRequestId getMessageId()

Specified by:

getMessageId in interface ODistributedResponseManager

getSentOn

public long getSentOn()

Specified by:

getSentOn in interface ODistributedResponseManager

setLocalResult

public boolean setLocalResult(String localNodeName,
                              Object localResult)

Specified by:

setLocalResult in interface ODistributedResponseManager

Parameters:

localNodeName -

localResult -

Returns:

removeServerBecauseUnreachable

public void removeServerBecauseUnreachable(String node)

Specified by:

removeServerBecauseUnreachable in interface ODistributedResponseManager

getQuorum

public int getQuorum()

Specified by:

getQuorum in interface ODistributedResponseManager

waitForSynchronousResponses

public boolean waitForSynchronousResponses()
                                    throws InterruptedException

Waits until the minimum responses are collected or timeout occurs. If "waitForLocalNode" wait also for local node.

Specified by:

waitForSynchronousResponses in interface ODistributedResponseManager

Returns:

True if the received responses are major or equals then the expected synchronous responses, otherwise false

Throws:

InterruptedException

isWaitForLocalNode

public boolean isWaitForLocalNode()

isReceivedCurrentNode

public boolean isReceivedCurrentNode()

getFinalResponse

public ODistributedResponse getFinalResponse()

Specified by:

getFinalResponse in interface ODistributedResponseManager

getDatabaseName

public String getDatabaseName()

Specified by:

getDatabaseName in interface ODistributedResponseManager

getSynchTimeout

public long getSynchTimeout()

Specified by:

getSynchTimeout in interface ODistributedResponseManager

timeout

public void timeout()

Specified by:

timeout in interface ODistributedResponseManager

isCanceled

public boolean isCanceled()

cancel

public void cancel()

Specified by:

cancel in interface ODistributedResponseManager

getMissingNodes

public List<String> getMissingNodes()

Returns the list of node names that didn't provide a response.

Specified by:

getMissingNodes in interface ODistributedResponseManager

getExpectedNodes

public Set<String> getExpectedNodes()

Specified by:

getExpectedNodes in interface ODistributedResponseManager

getServersWithoutFollowup

public Set<String> getServersWithoutFollowup()

Specified by:

getServersWithoutFollowup in interface ODistributedResponseManager

getRespondingNodes

public List<String> getRespondingNodes()

Returns the list of node names that provided a response.

Specified by:

getRespondingNodes in interface ODistributedResponseManager

getRequest

public ODistributedRequest getRequest()

Specified by:

getRequest in interface ODistributedResponseManager

getConflictResponses

protected List<ODistributedResponse> getConflictResponses()

Returns all the responses in conflict.

getExpectedResponses

protected int getExpectedResponses()

isFinished

public boolean isFinished()

Specified by:

isFinished in interface ODistributedResponseManager

getReceivedResponsesCount

protected int getReceivedResponsesCount()

getTotalTimeout

protected long getTotalTimeout()

getBestResponsesGroup

protected int getBestResponsesGroup()

Returns the biggest response group.

Returns:

isMinimumQuorumReached

protected boolean isMinimumQuorumReached(boolean reachedTimeout)

getReceivedResponses

protected List<ODistributedResponse> getReceivedResponses()

Returns the received response objects.

manageConflicts

protected RuntimeException manageConflicts()

undoRequest

protected boolean undoRequest()

checkNoWinnerCase

protected boolean checkNoWinnerCase(List<ODistributedResponse> bestResponsesGroup)