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	cancelDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	cancelEnstablish()
void	cancelRegisterPromise()
void	complete(OTransactionIdPromise promise)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<ONodeId> partecipants, int minimumQuorum)
Set<ONodeId>	enstablish(OGroupId groupId, Set<ONodeId> candidates)
void	failure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODatabasesTopologyState	getDatabaseTopology()
Set<ONodeId>	getNetworkMemebers()
ONodeStateNetwork	getNetworkState()
ONodeId	getNodeId()
ODiscoverAction	initFromStore()
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state)
Optional<OAcceptResult>	promiseDeclare(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	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)
Optional<OOperationStart>	start(OCompleteAction action)
Optional<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,
 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)

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 Optional<OAcceptResult> promiseRegister(ONodeId node,
 long version)

enstablish

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

validateEnstablish

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

startEnstablish

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

promiseDeclare

public Optional<OAcceptResult> promiseDeclare(OTransactionIdPromise promise,
 ODatabaseId databaseId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

declareDatabase

public void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database,
 Set<ONodeId> partecipants,
 int minimumQuorum)

cancelDatabase

public void cancelDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database)

getDatabaseTopology

public ODatabasesTopologyState getDatabaseTopology()

getNetworkMemebers

public Set<ONodeId> getNetworkMemebers()