Class OperationResponseManager
java.lang.Object
com.orientechnologies.agent.operation.OperationResponseManager
- All Implemented Interfaces:
ODistributedResponseManager
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcancel()booleancollectResponse(ODistributedResponse response) intlonglongbooleanvoidbooleansetLocalResult(String localNodeName, Object localResult) voidtimeout()boolean
-
Constructor Details
-
OperationResponseManager
-
-
Method Details
-
setLocalResult
- Specified by:
setLocalResultin interfaceODistributedResponseManager
-
getFinalResponse
- Specified by:
getFinalResponsein interfaceODistributedResponseManager
-
removeServerBecauseUnreachable
- Specified by:
removeServerBecauseUnreachablein interfaceODistributedResponseManager
-
waitForSynchronousResponses
- Specified by:
waitForSynchronousResponsesin interfaceODistributedResponseManager- Throws:
InterruptedException
-
getSynchTimeout
public long getSynchTimeout()- Specified by:
getSynchTimeoutin interfaceODistributedResponseManager
-
cancel
public void cancel()- Specified by:
cancelin interfaceODistributedResponseManager
-
getExpectedNodes
- Specified by:
getExpectedNodesin interfaceODistributedResponseManager
-
getRespondingNodes
- Specified by:
getRespondingNodesin interfaceODistributedResponseManager
-
getMessageId
- Specified by:
getMessageIdin interfaceODistributedResponseManager
-
getQuorum
public int getQuorum()- Specified by:
getQuorumin interfaceODistributedResponseManager
-
collectResponse
- Specified by:
collectResponsein interfaceODistributedResponseManager
-
timeout
public void timeout()- Specified by:
timeoutin interfaceODistributedResponseManager
-
getSentOn
public long getSentOn()- Specified by:
getSentOnin interfaceODistributedResponseManager
-
getMissingNodes
- Specified by:
getMissingNodesin interfaceODistributedResponseManager
-
getDatabaseName
- Specified by:
getDatabaseNamein interfaceODistributedResponseManager
-
getResponses
-
isFinished
public boolean isFinished()- Specified by:
isFinishedin interfaceODistributedResponseManager
-