Package com.orientechnologies.orient.server.distributed.impl

Class ODistributedTxResponseManagerImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedTxResponseManagerImpl

All Implemented Interfaces:

ODistributedTxResponseManager, ODistributedResponseManager

public class ODistributedTxResponseManagerImpl
extends Object
implements ODistributedTxResponseManager

Constructor Summary

Constructors

Constructor	Description
ODistributedTxResponseManagerImpl(ORemoteTask iRequest, Collection<String> iNodes, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum)

Method Summary

Modifier and Type	Method	Description
void	cancel()
boolean	collectResponse(OTransactionPhase1TaskResult response, String senderNodeName)
boolean	collectResponse(ODistributedResponse response)
List<OTransactionResultPayload>	getAllResponses()
String	getDatabaseName()
Optional<OTransactionResultPayload>	getDistributedTxFinalResponse()
Set<String>	getExpectedNodes()
ODistributedResponse	getFinalResponse()
ODistributedRequestId	getMessageId()
List<String>	getMissingNodes()
String	getNodeNameFromPayload(OTransactionResultPayload payload)
int	getQuorum()
List<String>	getRespondingNodes()
long	getSentOn()
long	getSynchTimeout()
boolean	isFinished()
boolean	isQuorumReached()
void	removeServerBecauseUnreachable(String node)
boolean	setLocalResult(String localNodeName, Object localResult)
void	timeout()
boolean	waitForSynchronousResponses()

Methods inherited from class java.lang.Object

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

Constructor Details

ODistributedTxResponseManagerImpl

public ODistributedTxResponseManagerImpl(ORemoteTask iRequest,
 Collection<String> iNodes,
 Set<String> nodesConcurToTheQuorum,
 int availableNodes,
 int expectedResponses,
 int quorum)

Method Details

setLocalResult

public boolean setLocalResult(String localNodeName,
 Object localResult)

Specified by:

setLocalResult in interface ODistributedResponseManager

getFinalResponse

public ODistributedResponse getFinalResponse()

Specified by:

getFinalResponse in interface ODistributedResponseManager

getDistributedTxFinalResponse

public Optional<OTransactionResultPayload> getDistributedTxFinalResponse()

Specified by:

getDistributedTxFinalResponse in interface ODistributedTxResponseManager

removeServerBecauseUnreachable

public void removeServerBecauseUnreachable(String node)

Specified by:

removeServerBecauseUnreachable in interface ODistributedResponseManager

waitForSynchronousResponses

public boolean waitForSynchronousResponses()

Specified by:

waitForSynchronousResponses in interface ODistributedResponseManager

getSynchTimeout

public long getSynchTimeout()

Specified by:

getSynchTimeout in interface ODistributedResponseManager

cancel

public void cancel()

Specified by:

cancel in interface ODistributedResponseManager

getExpectedNodes

public Set<String> getExpectedNodes()

Specified by:

getExpectedNodes in interface ODistributedResponseManager

getRespondingNodes

public List<String> getRespondingNodes()

Specified by:

getRespondingNodes in interface ODistributedResponseManager

getMessageId

public ODistributedRequestId getMessageId()

Specified by:

getMessageId in interface ODistributedResponseManager

getNodeNameFromPayload

public String getNodeNameFromPayload(OTransactionResultPayload payload)

Specified by:

getNodeNameFromPayload in interface ODistributedTxResponseManager

getQuorum

public int getQuorum()

Specified by:

getQuorum in interface ODistributedResponseManager

collectResponse

public boolean collectResponse(OTransactionPhase1TaskResult response,
 String senderNodeName)

Specified by:

collectResponse in interface ODistributedTxResponseManager

getAllResponses

public List<OTransactionResultPayload> getAllResponses()

Specified by:

getAllResponses in interface ODistributedTxResponseManager

collectResponse

public boolean collectResponse(ODistributedResponse response)

Specified by:

collectResponse in interface ODistributedResponseManager

isQuorumReached

public boolean isQuorumReached()

Specified by:

isQuorumReached in interface ODistributedTxResponseManager

isFinished

public boolean isFinished()

Specified by:

isFinished in interface ODistributedResponseManager

timeout

public void timeout()

Specified by:

timeout in interface ODistributedResponseManager

getSentOn

public long getSentOn()

Specified by:

getSentOn in interface ODistributedResponseManager

getMissingNodes

public List<String> getMissingNodes()

Specified by:

getMissingNodes in interface ODistributedResponseManager

getDatabaseName

public String getDatabaseName()

Specified by:

getDatabaseName in interface ODistributedResponseManager