Package com.orientechnologies.orient.distributed.context

Class OResponseCollector

java.lang.Object

com.orientechnologies.orient.distributed.context.OResponseCollector

public class OResponseCollector
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	OResponseCollector.CompleteInfo

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
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()
Optional<OResponseCollector.CompleteInfo>	receive(ONodeId node)

Methods inherited from class java.lang.Object

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

Constructor Details

OResponseCollector

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

Method Details

receive

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

hasSuccessQuorum

public boolean hasSuccessQuorum()

hasFailureQuorum

public boolean hasFailureQuorum()

isFinished

public boolean isFinished()

isFinishedNotQuorum

public boolean isFinishedNotQuorum()

getExpected

public Set<ONodeId> getExpected()

disconnected

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

fail

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