com.orientechnologies.orient.server.distributed.impl

Class ONewDistributedResponseManager

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ONewDistributedResponseManager

All Implemented Interfaces:

ODistributedResponseManager

public class ONewDistributedResponseManager
extends Object
implements ODistributedResponseManager

Constructor Summary

Constructors

Constructor and Description
ONewDistributedResponseManager(OTransactionPhase1Task iRequest, Collection<String> iNodes, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum)

Method Summary

Modifier and Type	Method and Description
boolean	addFollowupToServer(String node)
void	cancel()
boolean	collectResponse(ODistributedResponse response)
boolean	collectResponse(OTransactionPhase1TaskResult response, String senderNodeName)
boolean	executeInLock(OCallable<Boolean,ODistributedResponseManager> oCallable)
List<OTransactionResultPayload>	getAllResponses()
Collection<String>	getConflictServers()
String	getDatabaseName()
Set<String>	getExpectedNodes()
ODistributedResponse	getFinalResponse()
Object	getGenericFinalResponse()
ODistributedRequestId	getMessageId()
List<String>	getMissingNodes()
String	getNodeNameFromPayload(OTransactionResultPayload payload)
int	getQuorum()
ODistributedResponse	getQuorumResponse()
ODistributedRequest	getRequest()
List<String>	getRespondingNodes()
Object	getResponseFromServer(String server)
long	getSentOn()
Set<String>	getServersWithoutFollowup()
long	getSynchTimeout()
boolean	isFinished()
boolean	isQuorumReached()
boolean	isSynchronousWaiting()
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 Detail

ONewDistributedResponseManager

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

Method Detail

setLocalResult

public boolean setLocalResult(String localNodeName,
                              Object localResult)

Specified by:

setLocalResult in interface ODistributedResponseManager

getFinalResponse

public ODistributedResponse getFinalResponse()

Specified by:

getFinalResponse in interface ODistributedResponseManager

getGenericFinalResponse

public Object getGenericFinalResponse()

Specified by:

getGenericFinalResponse in interface ODistributedResponseManager

removeServerBecauseUnreachable

public void removeServerBecauseUnreachable(String node)

Specified by:

removeServerBecauseUnreachable in interface ODistributedResponseManager

waitForSynchronousResponses

public boolean waitForSynchronousResponses()
                                    throws InterruptedException

Specified by:

waitForSynchronousResponses in interface ODistributedResponseManager

Throws:

InterruptedException

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

getConflictServers

public Collection<String> getConflictServers()

Specified by:

getConflictServers in interface ODistributedResponseManager

getServersWithoutFollowup

public Set<String> getServersWithoutFollowup()

Specified by:

getServersWithoutFollowup in interface ODistributedResponseManager

addFollowupToServer

public boolean addFollowupToServer(String node)

Specified by:

addFollowupToServer in interface ODistributedResponseManager

isSynchronousWaiting

public boolean isSynchronousWaiting()

Specified by:

isSynchronousWaiting in interface ODistributedResponseManager

getQuorumResponse

public ODistributedResponse getQuorumResponse()

Specified by:

getQuorumResponse in interface ODistributedResponseManager

getMessageId

public ODistributedRequestId getMessageId()

Specified by:

getMessageId in interface ODistributedResponseManager

getRequest

public ODistributedRequest getRequest()

Specified by:

getRequest in interface ODistributedResponseManager

getResponseFromServer

public Object getResponseFromServer(String server)

Specified by:

getResponseFromServer in interface ODistributedResponseManager

getNodeNameFromPayload

public String getNodeNameFromPayload(OTransactionResultPayload payload)

getQuorum

public int getQuorum()

Specified by:

getQuorum in interface ODistributedResponseManager

executeInLock

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

Specified by:

executeInLock in interface ODistributedResponseManager

collectResponse

public boolean collectResponse(OTransactionPhase1TaskResult response,
                               String senderNodeName)

getAllResponses

public List<OTransactionResultPayload> getAllResponses()

collectResponse

public boolean collectResponse(ODistributedResponse response)

Specified by:

collectResponse in interface ODistributedResponseManager

isQuorumReached

public boolean isQuorumReached()

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