com.orientechnologies.orient.server.distributed

Class ODistributedResponseManager

java.lang.Object

com.orientechnologies.orient.server.distributed.ODistributedResponseManager

public class ODistributedResponseManager
extends Object

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--orientechnologies.com)

Field Summary

Fields

Modifier and Type	Field and Description
static int	ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

Constructor Summary

Constructors

Constructor and Description
ODistributedResponseManager(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
boolean	addFollowupToServer(String server)
void	cancel()
protected boolean	checkNoWinnerCase(List<ODistributedResponse> bestResponsesGroup)
boolean	collectResponse(ODistributedResponse response) Not synchronized, it's called when a message arrives
boolean	executeInLock(OCallable<Boolean,ODistributedResponseManager> callback)
protected boolean	fixNodesInConflict(List<ODistributedResponse> bestResponsesGroup, int conflicts, boolean cannotFixRecordLockException)
protected int	getBestResponsesGroup() Returns the biggest response group.
protected List<ODistributedResponse>	getConflictResponses() Returns all the responses in conflict.
List<String>	getConflictServers() Returns all the servers 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.
protected int	getMissingResponses()
int	getQuorum()
ODistributedResponse	getQuorumResponse()
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.
Object	getResponseFromServer(String s)
long	getSentOn()
Set<String>	getServersWithoutFollowup()
long	getSynchTimeout()
protected long	getTotalTimeout()
boolean	isCanceled()
protected boolean	isMinimumQuorumReached(boolean reachedTimeout)
boolean	isReceivedCurrentNode()
boolean	isSynchronousWaiting()
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

Field Detail

ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

public static final int ADDITIONAL_TIMEOUT_CLUSTER_SHAPE

See Also:

Constant Field Values

Constructor Detail

ODistributedResponseManager

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

Parameters:

response - Received response to collect

Returns:

True if all the nodes responded, otherwise false

getMessageId

public ODistributedRequestId getMessageId()

getSentOn

public long getSentOn()

setLocalResult

public boolean setLocalResult(String localNodeName,
                              Object localResult)

Parameters:

localNodeName -

localResult -

Returns:

isSynchronousWaiting

public boolean isSynchronousWaiting()

removeServerBecauseUnreachable

public void removeServerBecauseUnreachable(String node)

getQuorum

public int getQuorum()

waitForSynchronousResponses

public boolean waitForSynchronousResponses()
                                    throws InterruptedException

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

Returns:

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

Throws:

InterruptedException

executeInLock

public boolean executeInLock(OCallable<Boolean,ODistributedResponseManager> callback)

isWaitForLocalNode

public boolean isWaitForLocalNode()

isReceivedCurrentNode

public boolean isReceivedCurrentNode()

getFinalResponse

public ODistributedResponse getFinalResponse()

getDatabaseName

public String getDatabaseName()

getSynchTimeout

public long getSynchTimeout()

timeout

public void timeout()

isCanceled

public boolean isCanceled()

cancel

public void cancel()

getMissingNodes

public List<String> getMissingNodes()

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

getConflictServers

public List<String> getConflictServers()

Returns all the servers in conflict.

getExpectedNodes

public Set<String> getExpectedNodes()

addFollowupToServer

public boolean addFollowupToServer(String server)

getServersWithoutFollowup

public Set<String> getServersWithoutFollowup()

getQuorumResponse

public ODistributedResponse getQuorumResponse()

getResponseFromServer

public Object getResponseFromServer(String s)

getRespondingNodes

public List<String> getRespondingNodes()

Returns the list of node names that provided a response.

getRequest

public ODistributedRequest getRequest()

getConflictResponses

protected List<ODistributedResponse> getConflictResponses()

Returns all the responses in conflict.

getExpectedResponses

protected int getExpectedResponses()

getMissingResponses

protected int getMissingResponses()

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

fixNodesInConflict

protected boolean fixNodesInConflict(List<ODistributedResponse> bestResponsesGroup,
                                     int conflicts,
                                     boolean cannotFixRecordLockException)

checkNoWinnerCase

protected boolean checkNoWinnerCase(List<ODistributedResponse> bestResponsesGroup)