Package com.orientechnologies.orient.distributed.context

Class ODatabasesTopologyState

java.lang.Object

com.orientechnologies.orient.distributed.context.ODatabasesTopologyState

All Implemented Interfaces:

ODatabasesTopology

public class ODatabasesTopologyState
extends Object
implements ODatabasesTopology

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	addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, long version)
void	cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes)
void	cancelPomise(OTransactionIdPromise promise, ODatabaseId db, String name)
void	cancelSetState(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	completeSync(OSyncId syncId)
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()
long	getDatabaseVersion(ODatabaseId dbId)
List<ODatabaseStateNetwork>	getNetworkState()
Set<ONodeId>	getOnlineNodes(ODatabaseId dbId)
ONodeRole	getRole(ODatabaseId dbId, ONodeId nodeId)
ODatabaseState	getState(ODatabaseId dbId, ONodeId nodeID)
ODatabasesTopologyStore	getStore()
OSyncState	getSyncState(OSyncId syncId)
boolean	isMain(ODatabaseId dbId, ONodeId nodeId)
boolean	isOnline(ODatabaseId dbId, ONodeId nodeID)
Set<ODatabaseId>	listDatabaseIds()
void	load(ODatabasesTopologyStore store)
void	mergeNetworkState(List<ODatabaseStateNetwork> network)
Optional<OSyncInfo>	newSync(ODatabaseId dbId)
void	receiverNetworkState(List<ODatabaseStateNetwork> network)
void	setState(ODatabaseId db, ONodeId node, ODatabaseState state, long version)
boolean	shouldSink(ODatabaseId dbId, ONodeId nodeID)
OSyncState	startSend(ONodeId to, ONodeId from, ODatabaseId dbId, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
Optional<OAcceptResult>	validateAddMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, long version)
Optional<OAcceptResult>	validateDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<ONodeId> partecipants, int minimumQuorum)
Optional<OAcceptResult>	validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, long version)
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

validateDeclare

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

validateSetState

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

getDatabaseVersion

public long getDatabaseVersion(ODatabaseId dbId)

Specified by:

getDatabaseVersion in interface ODatabasesTopology

cancelSetState

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

Specified by:

getOnlineNodes in interface ODatabasesTopology

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)

Specified by:

getDatabaseName in interface ODatabasesTopology

acceptSync

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

getDatabaseId

public Optional<ODatabaseId> getDatabaseId(String databaseName)

Specified by:

getDatabaseId in interface ODatabasesTopology

isMain

public boolean isMain(ODatabaseId dbId,
 ONodeId nodeId)

Specified by:

isMain in interface ODatabasesTopology

receiverNetworkState

public void receiverNetworkState(List<ODatabaseStateNetwork> network)

getNetworkState

public List<ODatabaseStateNetwork> getNetworkState()

getDatabases

public Collection<ODatabaseId> getDatabases()

Specified by:

getDatabases in interface ODatabasesTopology

getState

public ODatabaseState getState(ODatabaseId dbId,
 ONodeId nodeID)

Specified by:

getState in interface ODatabasesTopology

isOnline

public boolean isOnline(ODatabaseId dbId,
 ONodeId nodeID)

Specified by:

isOnline in interface ODatabasesTopology

shouldSink

public boolean shouldSink(ODatabaseId dbId,
 ONodeId nodeID)

Specified by:

shouldSink in interface ODatabasesTopology

getRole

public ONodeRole getRole(ODatabaseId dbId,
 ONodeId nodeId)

Specified by:

getRole in interface ODatabasesTopology

mergeNetworkState

public void mergeNetworkState(List<ODatabaseStateNetwork> network)

validateAddMember

public Optional<OAcceptResult> validateAddMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 long version)

addDatabaseMember

public void addDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 long version)

cancelAddDatabaseMember

public void cancelAddDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes)

completeSync

public void completeSync(OSyncId syncId)

getStore

public ODatabasesTopologyStore getStore()

load

public void load(ODatabasesTopologyStore store)