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	apllied(OTransactionIdPromise promise)
void	cancel(OTransactionIdPromise promise, OOperationContext ctx)
void	cancelPromise(OTransactionIdPromise promise)
void	confirm(OTransactionIdPromise promise, OOperationContext ctx)
void	failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODatabasesTopology	getDatabaseTopology()
Set<ONodeId>	getNetworkMembers()
ONodeStateNetwork	getNetworkState()
ONodeId	getNodeId()
OCoordinatedDistributedOps	getOps()
OStatsManager	getStats()
ODiscoverAction	initFromStore()
Optional<OAcceptResult>	propose(ODistributedMessage message, OOperationContext ctx)
Optional<ODistributedMessage>	receiveFailure(OTransactionIdPromise promise)
OConfirmResult	receiveSuccess(OTransactionIdPromise promise)
List<ODistributedMessage>	recover(List<OTransactionId> ids)
void	recover(List<OConfirmedRetryOp> ops, OrientDBDistributed context)
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)

propose

public Optional<OAcceptResult> propose(ODistributedMessage message,
 OOperationContext ctx)

confirm

public void confirm(OTransactionIdPromise promise,
 OOperationContext ctx)

cancel

public void cancel(OTransactionIdPromise promise,
 OOperationContext ctx)

receiveFailure

public Optional<ODistributedMessage> receiveFailure(OTransactionIdPromise promise)

receiveSuccess

public OConfirmResult receiveSuccess(OTransactionIdPromise promise)

apllied

public void apllied(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()

getStats

public OStatsManager getStats()

cancelPromise

public void cancelPromise(OTransactionIdPromise promise)

recover

public void recover(List<OConfirmedRetryOp> ops,
 OrientDBDistributed context)