Package com.orientechnologies.orient.distributed.context

Class ONodeState

java.lang.Object

com.orientechnologies.orient.distributed.context.ONodeState

public class ONodeState
extends Object

Constructor Summary

Constructors

Constructor	Description
ONodeState(ONodeId current, OGroupId groupId, int minimumQuorum, OStateStore store, ODatabaseStateChangeListener listener)

Method Summary

Modifier and Type	Method	Description
void	complete(OTransactionIdPromise promise)
void	failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODatabasesTopology	getDatabaseTopology()
Set<ONodeId>	getNetworkMembers()
ONodeStateNetwork	getNetworkState()
ONodeId	getNodeId()
OCoordinatedDistributedOps	getOps()
ODiscoverAction	initFromStore()
Optional<OAcceptResult>	receive(ODistributedMessage message)
Optional<ODistributedMessage>	receiveFailure(OTransactionIdPromise promise)
Optional<ODistributedMessage>	receiveSuccess(OTransactionIdPromise promise)
List<ODistributedMessage>	recover(List<OTransactionId> ids)
Optional<OOperationStart>	start(OCompleteAction action)
void	success(ONodeId node, OTransactionIdPromise promise)
void	waitComplete(OTransactionIdPromise promise)

Methods inherited from class java.lang.Object

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

Constructor Details

ONodeState

public ONodeState(ONodeId current,
 OGroupId groupId,
 int minimumQuorum,
 OStateStore store,
 ODatabaseStateChangeListener listener)

Method Details

initFromStore

public ODiscoverAction initFromStore()

start

public Optional<OOperationStart> start(OCompleteAction action)

success

public void success(ONodeId node,
 OTransactionIdPromise promise)

failure

public void failure(ONodeId node,
 OTransactionIdPromise promise,
 OAcceptResult acceptResult)

receive

public Optional<OAcceptResult> receive(ODistributedMessage message)

receiveFailure

public Optional<ODistributedMessage> receiveFailure(OTransactionIdPromise promise)

receiveSuccess

public Optional<ODistributedMessage> receiveSuccess(OTransactionIdPromise promise)

complete

public void complete(OTransactionIdPromise promise)

recover

public List<ODistributedMessage> recover(List<OTransactionId> ids)

getNodeId

public ONodeId getNodeId()

waitComplete

public void waitComplete(OTransactionIdPromise promise)

getNetworkState

public ONodeStateNetwork getNetworkState()

getDatabaseTopology

public ODatabasesTopology getDatabaseTopology()

getNetworkMembers

public Set<ONodeId> getNetworkMembers()

getOps

public OCoordinatedDistributedOps getOps()