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, int minimumQuorum, OStateStore store)

Method Summary

Modifier and Type	Method	Description
void	cancelEnstablish()
void	cancelRegisterPromise()
void	complete(OTransactionIdPromise promise)
void	enstablish(OGroupId groupId, Set<ONodeId> candidates)
void	failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ONodeStateNetwork	getNetworkState()
ONodeId	getNodeId()
void	initFromStore()
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state)
boolean	promiseRegister(ONodeId node, long version)
boolean	receive(ODistributedMessage message)
Optional<ODistributedMessage>	receiveFailure(OTransactionIdPromise promise)
ODistributedMessage	receiveSuccess(OTransactionIdPromise promise)
List<ODistributedMessage>	recover(List<OTransactionId> ids)
void	register(ONodeId node, long version)
OOperationStart	start(OCompleteAction action)
OTransactionIdPromise	startEnstablish(Set<ONodeId> nodes, OCompleteAction action)
void	success(ONodeId node, OTransactionIdPromise promise)
void	unregister(ONodeId node, long version)
Optional<OAcceptResult>	validateEnstablish(OGroupId groupId, Set<ONodeId> candidates)
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,
 int minimumQuorum,
 OStateStore store)

Method Details

initFromStore

public void initFromStore()

start

public OOperationStart start(OCompleteAction action)

success

public void success(ONodeId node,
 OTransactionIdPromise promise)

failure

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

register

public void register(ONodeId node,
 long version)

unregister

public void unregister(ONodeId node,
 long version)

receive

public boolean receive(ODistributedMessage message)

receiveFailure

public Optional<ODistributedMessage> receiveFailure(OTransactionIdPromise promise)

receiveSuccess

public 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)

promiseRegister

public boolean promiseRegister(ONodeId node,
 long version)

enstablish

public void enstablish(OGroupId groupId,
 Set<ONodeId> candidates)

validateEnstablish

public Optional<OAcceptResult> validateEnstablish(OGroupId groupId,
 Set<ONodeId> candidates)

startEnstablish

public OTransactionIdPromise startEnstablish(Set<ONodeId> nodes,
 OCompleteAction action)

nodeJoinStart

public ODiscoverAction nodeJoinStart(ONodeId node,
 ONodeStateNetwork state)

getNetworkState

public ONodeStateNetwork getNetworkState()

cancelRegisterPromise

public void cancelRegisterPromise()

cancelEnstablish

public void cancelEnstablish()