Package com.orientechnologies.orient.distributed.context

Class ODatabasesTopologyState

java.lang.Object

com.orientechnologies.orient.distributed.context.ODatabasesTopologyState

public class ODatabasesTopologyState
extends Object

Constructor Summary

Constructors

Constructor	Description
ODatabasesTopologyState(ODatabaseStateChangeListener listener)

Method Summary

Modifier and Type	Method	Description
boolean	acceptSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId)
void	cancelPomise(OTransactionIdPromise promise, ODatabaseId db, String name)
void	cancelPomiseSetState(ODatabaseId dbId, ONodeId nodeId, long version)
Optional<OSyncState>	canSync(ONodeId sender, ONodeId receiver, ODatabaseId dbId, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum)
void	declareNode(ODatabaseId db, String name, ONodeId node, ONodeRole role, ODatabaseState state)
boolean	executeOnOneOnline(ODatabaseId dbId, OStateAction execute)
Optional<ODatabaseId>	getDatabaseId(String databaseName)
String	getDatabaseName(ODatabaseId dbId)
Collection<ODatabaseId>	getDatabases()
ODatabaseState	getDatabaseStatus(ONodeId nodeID, ODatabaseId dbId)
long	getDatabaseVersion(ODatabaseId dbId)
List<ODatabaseStateNetwork>	getNetworkState()
ONodeRole	getNodeRole(ONodeId nodeId, ODatabaseId dbId)
ODatabaseState	getNodeState(ODatabaseId dbId, ONodeId nodeId)
Set<ONodeId>	getOnlineNodes(ODatabaseId dbId)
OSyncState	getSyncState(OSyncId syncId)
boolean	isMain(ODatabaseId dbId, ONodeId nodeId)
Set<ODatabaseId>	listDatabaseIds()
Optional<OSyncInfo>	newSync(ODatabaseId dbId)
Optional<OAcceptResult>	promiseDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	promiseState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version)
void	receiverNetworkState(List<ODatabaseStateNetwork> network)
void	setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version)
OSyncState	startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
boolean	waitOnline(ODatabaseId dbId, ONodeId nodeId)
boolean	waitOnlineOne(ODatabaseId dbId)
boolean	waitOnlineQuorum(ODatabaseId dbId, Optional<Long> timeout)

Methods inherited from class java.lang.Object

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

Constructor Details

ODatabasesTopologyState

public ODatabasesTopologyState(ODatabaseStateChangeListener listener)

Method Details

promiseDeclare

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

cancelPomise

public void cancelPomise(OTransactionIdPromise promise,
 ODatabaseId db,
 String name)

declareDatabase

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

declareNode

public void declareNode(ODatabaseId db,
 String name,
 ONodeId node,
 ONodeRole role,
 ODatabaseState state)

setState

public void setState(ODatabaseId db,
 ONodeId node,
 ODatabaseState state,
 long version)

listDatabaseIds

public Set<ODatabaseId> listDatabaseIds()

promiseState

public Optional<OAcceptResult> promiseState(ODatabaseId dbId,
 ONodeId nodeId,
 ODatabaseState state,
 long version)

getDatabaseVersion

public long getDatabaseVersion(ODatabaseId dbId)

getNodeState

public ODatabaseState getNodeState(ODatabaseId dbId,
 ONodeId nodeId)

cancelPomiseSetState

public void cancelPomiseSetState(ODatabaseId dbId,
 ONodeId nodeId,
 long version)

waitOnline

public boolean waitOnline(ODatabaseId dbId,
 ONodeId nodeId)

waitOnlineQuorum

public boolean waitOnlineQuorum(ODatabaseId dbId,
 Optional<Long> timeout)
                         throws InterruptedException

Throws:

InterruptedException

waitOnlineOne

public boolean waitOnlineOne(ODatabaseId dbId)

executeOnOneOnline

public boolean executeOnOneOnline(ODatabaseId dbId,
 OStateAction execute)

getOnlineNodes

public Set<ONodeId> getOnlineNodes(ODatabaseId dbId)

newSync

public Optional<OSyncInfo> newSync(ODatabaseId dbId)

canSync

public Optional<OSyncState> canSync(ONodeId sender,
 ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId,
 boolean canSync,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

startSend

public OSyncState startSend(ONodeId to,
 ONodeId from,
 ODatabaseId dbId,
 OSyncId syncId,
 OSyncMode mode,
 Optional<OTransactionSequenceStatus> sequenceStatus)

getSyncState

public OSyncState getSyncState(OSyncId syncId)

getDatabaseName

public String getDatabaseName(ODatabaseId dbId)

acceptSync

public boolean acceptSync(ONodeId sender,
 ONodeId receiver,
 ODatabaseId dbId,
 OSyncId syncId)

getDatabaseId

public Optional<ODatabaseId> getDatabaseId(String databaseName)

isMain

public boolean isMain(ODatabaseId dbId,
 ONodeId nodeId)

receiverNetworkState

public void receiverNetworkState(List<ODatabaseStateNetwork> network)

getNetworkState

public List<ODatabaseStateNetwork> getNetworkState()

getDatabases

public Collection<ODatabaseId> getDatabases()

getDatabaseStatus

public ODatabaseState getDatabaseStatus(ONodeId nodeID,
 ODatabaseId dbId)

getNodeRole

public ONodeRole getNodeRole(ONodeId nodeId,
 ODatabaseId dbId)