Package com.orientechnologies.agent.operation

Class OperationResponseManager

java.lang.Object

com.orientechnologies.agent.operation.OperationResponseManager

All Implemented Interfaces:

ODistributedResponseManager

public class OperationResponseManager
extends Object
implements ODistributedResponseManager

Constructor Summary

Constructors

Constructor	Description
OperationResponseManager(Set<String> servers)

Method Summary

Modifier and Type	Method	Description
void	cancel()
boolean	collectResponse(ODistributedResponse response)
String	getDatabaseName()
Set<String>	getExpectedNodes()
ODistributedResponse	getFinalResponse()
ODistributedRequestId	getMessageId()
List<String>	getMissingNodes()
int	getQuorum()
List<String>	getRespondingNodes()
List<OperationResponseFromNode>	getResponses()
long	getSentOn()
long	getSynchTimeout()
boolean	isFinished()
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

OperationResponseManager

public OperationResponseManager(Set<String> servers)

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

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

getMessageId

public ODistributedRequestId getMessageId()

Specified by:

getMessageId in interface ODistributedResponseManager

getQuorum

public int getQuorum()

Specified by:

getQuorum in interface ODistributedResponseManager

collectResponse

public boolean collectResponse(ODistributedResponse response)

Specified by:

collectResponse 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

getResponses

public List<OperationResponseFromNode> getResponses()

isFinished

public boolean isFinished()

Specified by:

isFinished in interface ODistributedResponseManager