Package com.orientechnologies.orient.distributed.context.coordination

Class OResponseCollectorImpl

java.lang.Object

com.orientechnologies.orient.distributed.context.coordination.OResponseCollectorImpl

All Implemented Interfaces:

OResponseCollector

public class OResponseCollectorImpl
extends Object
implements OResponseCollector

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.distributed.context.coordination.OResponseCollector

OResponseCollector.CompleteInfo

Constructor Summary

Constructors

Constructor	Description
OResponseCollectorImpl(OCompleteAction action, OTransactionIdPromise promise, int quorum, Set<ONodeId> activeNodes)

Method Summary

Modifier and Type	Method	Description
Optional<OResponseCollector.CompleteInfo>	applied()
Optional<OResponseCollector.CompleteInfo>	disconnected(ONodeId node)
Optional<OResponseCollector.CompleteInfo>	fail(ONodeId node, OAcceptResult acceptResult)
Set<ONodeId>	getExpected()
boolean	hasFailureQuorum()
boolean	hasSuccessQuorum()
boolean	isFinished()
boolean	isFinishedNotQuorum()
boolean	isTotallyFinished()
Optional<OResponseCollector.CompleteInfo>	receive(ONodeId node)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

OResponseCollectorImpl

public OResponseCollectorImpl(OCompleteAction action,
 OTransactionIdPromise promise,
 int quorum,
 Set<ONodeId> activeNodes)

Method Details

receive

public Optional<OResponseCollector.CompleteInfo> receive(ONodeId node)

Specified by:

receive in interface OResponseCollector

hasSuccessQuorum

public boolean hasSuccessQuorum()

hasFailureQuorum

public boolean hasFailureQuorum()

isFinished

public boolean isFinished()

isTotallyFinished

public boolean isTotallyFinished()

Specified by:

isTotallyFinished in interface OResponseCollector

isFinishedNotQuorum

public boolean isFinishedNotQuorum()

getExpected

public Set<ONodeId> getExpected()

disconnected

public Optional<OResponseCollector.CompleteInfo> disconnected(ONodeId node)

Specified by:

disconnected in interface OResponseCollector

fail

public Optional<OResponseCollector.CompleteInfo> fail(ONodeId node,
 OAcceptResult acceptResult)

Specified by:

fail in interface OResponseCollector

applied

public Optional<OResponseCollector.CompleteInfo> applied()

Specified by:

applied in interface OResponseCollector

toString

public String toString()

Overrides:

toString in class Object