Package com.orientechnologies.orient.distributed.context.coordination.dbs

Class ODatabasesTopologyState

java.lang.Object

com.orientechnologies.orient.distributed.context.coordination.dbs.OWatcher

com.orientechnologies.orient.distributed.context.coordination.dbs.ODatabasesTopologyState

All Implemented Interfaces:

ODatabasesTopology

public class ODatabasesTopologyState
extends OWatcher
implements ODatabasesTopology

Nested Class Summary

Nested classes/interfaces inherited from class com.orientechnologies.orient.distributed.context.coordination.dbs.OWatcher

OWatcher.ONotificationActionData, OWatcher.WaitCond

Constructor Summary

Constructors

Constructor	Description
ODatabasesTopologyState(ODatabaseStateChangeListener listener, ONodeId current)

Method Summary

Modifier and Type	Method	Description
boolean	acceptSync(ONodeId sender, OSyncId syncId)
void	addDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
void	cancelAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OTransactionIdPromise promise)
void	cancelDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	cancelMerge(OTransactionIdPromise promise)
void	cancelPomise(OTransactionIdPromise promise, ODatabaseId db, String name)
void	cancelRemoveDatabaseMembers(ODatabaseId dbId, OTransactionIdPromise promise)
void	cancelSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	cancelSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	cancelSetState(ODatabaseId dbId, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
Optional<OCanSyncResult>	canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
void	checkTimeoutSync(long timeOutSync)
void	completeSync(OSyncId syncId, boolean success)
void	dbRemovedFromDiskWhenOffline(ODatabaseId db)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId db, String name, Set<OAddNodeInfo> partecipants, int minimumQuorum)
void	dropDatabase(OTransactionIdPromise promise, ODatabaseId dbId, OVersion version)
boolean	executeOnOneOnline(ODatabaseId dbId, ONotificationAction execute)
Set<OSyncState>	getActiveSyncs(ODatabaseId dbId)
Optional<ODatabaseId>	getDatabaseId(String databaseName)
String	getDatabaseName(ODatabaseId dbId)
Collection<ODatabaseId>	getDatabases()
OVersion	getDatabaseVersion(ODatabaseId dbId)
Set<ONodeId>	getMembers(ODatabaseId databaseId)
List<ODatabaseStateNetwork>	getNetworkState()
Set<ONodeId>	getOnlineNodes(ODatabaseId dbId)
int	getQuorum(ODatabaseId databaseId)
ONodeRole	getRole(ODatabaseId dbId, ONodeId nodeId)
ODatabaseState	getState(ODatabaseId dbId, ONodeId nodeID)
ODatabasesTopologyStore	getStore()
Optional<OSyncState>	getSyncState(OSyncId syncId)
boolean	isAllOnline(ODatabaseId dbId)
boolean	isMain(ODatabaseId dbId, ONodeId nodeId)
boolean	isOnline(ODatabaseId dbId, ONodeId nodeID)
boolean	isQuorumOnline(ODatabaseId dbId)
boolean	isSynching(ODatabaseId dbId)
Set<ODatabaseId>	listDatabaseIds()
void	load(ODatabasesTopologyStore store)
void	mergeNetworkState(List<ODatabaseStateNetwork> network, OTransactionIdPromise promise)
Optional<OSyncInfo>	newSync(ODatabaseId dbId)
OVersion	nextDatabaseVersion(ODatabaseId id)
void	nodeDisconnected(ONodeId node)
void	receiverNetworkState(List<ODatabaseStateNetwork> network)
void	removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	requestNext(OSyncId syncId, boolean close)
void	setDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	setDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
void	setState(ODatabaseId db, ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
boolean	shouldSink(ODatabaseId dbId, ONodeId nodeID)
Optional<OSyncState>	startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
Optional<OAcceptResult>	validateAddMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateDeclare(OTransactionIdPromise promise, ODatabaseId db, String name, Set<OAddNodeInfo> partecipants, int minimumQuorum)
Optional<OAcceptResult>	validateDropDatabase(OTransactionIdPromise promise, ODatabaseId dbId, OVersion version)
Optional<OAcceptResult>	validateMergeNode(List<ODatabaseStateNetwork> databases, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateMergeToNetwork(List<ODatabaseStateNetwork> original, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateRemoveMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateSetDatabaseNodeRole(ODatabaseId db, ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateSetDatabaseQuorum(ODatabaseId db, int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateSetState(ODatabaseId dbId, ONodeId nodeId, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
boolean	waitOnlineAll(ODatabaseId dbId, Optional<Long> timeout)
boolean	waitOnlineOne(ODatabaseId dbId, Optional<Long> timeout)
boolean	waitOnlineQuorum(ODatabaseId dbId, Optional<Long> timeout)
boolean	waitSelfOnline(ODatabaseId dbId, Optional<Long> timeout)
boolean	waitSelfOnline(String dbName, Optional<Long> timeout)

Methods inherited from class com.orientechnologies.orient.distributed.context.coordination.dbs.OWatcher

executeOn, notifyChange, waitFor

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,
 ONodeId current)

Method Details

validateDeclare

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

cancelPomise

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

declareDatabase

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

setState

public void setState(ODatabaseId db,
 ONodeId node,
 ODatabaseState state,
 OVersion version,
 OTransactionIdPromise promise)

listDatabaseIds

public Set<ODatabaseId> listDatabaseIds()

validateSetState

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

getDatabaseVersion

public OVersion getDatabaseVersion(ODatabaseId dbId)

Specified by:

getDatabaseVersion in interface ODatabasesTopology

cancelSetState

public void cancelSetState(ODatabaseId dbId,
 ONodeId nodeId,
 OVersion version,
 OTransactionIdPromise promise)

isQuorumOnline

public boolean isQuorumOnline(ODatabaseId dbId)

Specified by:

isQuorumOnline in interface ODatabasesTopology

isAllOnline

public boolean isAllOnline(ODatabaseId dbId)

Specified by:

isAllOnline in interface ODatabasesTopology

waitOnlineQuorum

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

Throws:

InterruptedException

waitOnlineAll

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

Throws:

InterruptedException

waitSelfOnline

public boolean waitSelfOnline(String dbName,
 Optional<Long> timeout)
                       throws InterruptedException

Throws:

InterruptedException

waitSelfOnline

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

Throws:

InterruptedException

waitOnlineOne

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

Throws:

InterruptedException

executeOnOneOnline

public boolean executeOnOneOnline(ODatabaseId dbId,
 ONotificationAction execute)

getOnlineNodes

public Set<ONodeId> getOnlineNodes(ODatabaseId dbId)

Specified by:

getOnlineNodes in interface ODatabasesTopology

newSync

public Optional<OSyncInfo> newSync(ODatabaseId dbId)

canSync

public Optional<OCanSyncResult> canSync(ONodeId sender,
 OSyncId syncId,
 OCanSyncAccept canSync)

startSend

public Optional<OSyncState> startSend(ONodeId from,
 OSyncId syncId,
 OCanSyncAccept mode)

requestNext

public void requestNext(OSyncId syncId,
 boolean close)

getSyncState

public Optional<OSyncState> getSyncState(OSyncId syncId)

getDatabaseName

public String getDatabaseName(ODatabaseId dbId)

Specified by:

getDatabaseName in interface ODatabasesTopology

acceptSync

public boolean acceptSync(ONodeId sender,
 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

isSynching

public boolean isSynching(ODatabaseId dbId)

Specified by:

isSynching 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,
 OTransactionIdPromise promise)

validateAddMember

public Optional<OAcceptResult> validateAddMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 OVersion version,
 OTransactionIdPromise promise)

addDatabaseMember

public void addDatabaseMember(ODatabaseId dbId,
 List<OAddNodeInfo> nodes,
 OVersion version,
 OTransactionIdPromise promise)

cancelAddDatabaseMember

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

validateRemoveMembers

public Optional<OAcceptResult> validateRemoveMembers(ODatabaseId dbId,
 List<ONodeId> nodes,
 OVersion version,
 OTransactionIdPromise promise)

removeDatabaseMembers

public void removeDatabaseMembers(ODatabaseId dbId,
 List<ONodeId> nodes,
 OVersion version,
 OTransactionIdPromise promise)

cancelRemoveDatabaseMembers

public void cancelRemoveDatabaseMembers(ODatabaseId dbId,
 OTransactionIdPromise promise)

completeSync

public void completeSync(OSyncId syncId,
 boolean success)

getStore

public ODatabasesTopologyStore getStore()

load

public void load(ODatabasesTopologyStore store)

getQuorum

public int getQuorum(ODatabaseId databaseId)

Specified by:

getQuorum in interface ODatabasesTopology

getActiveSyncs

public Set<OSyncState> getActiveSyncs(ODatabaseId dbId)

Specified by:

getActiveSyncs in interface ODatabasesTopology

validateDropDatabase

public Optional<OAcceptResult> validateDropDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 OVersion version)

dropDatabase

public void dropDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 OVersion version)

cancelDropDatabase

public void cancelDropDatabase(ODatabaseId dbId,
 OVersion version,
 OTransactionIdPromise promise)

nodeDisconnected

public void nodeDisconnected(ONodeId node)

cancelMerge

public void cancelMerge(OTransactionIdPromise promise)

validateMergeToNetwork

public Optional<OAcceptResult> validateMergeToNetwork(List<ODatabaseStateNetwork> original,
 OTransactionIdPromise promise)

nextDatabaseVersion

public OVersion nextDatabaseVersion(ODatabaseId id)

validateSetDatabaseNodeRole

public Optional<OAcceptResult> validateSetDatabaseNodeRole(ODatabaseId db,
 ONodeId node,
 ONodeRole role,
 OVersion version,
 OTransactionIdPromise promise)

setDatabaseNodeRole

public void setDatabaseNodeRole(ODatabaseId db,
 ONodeId node,
 ONodeRole role,
 OVersion version,
 OTransactionIdPromise promise)

cancelSetDatabaseNodeRole

public void cancelSetDatabaseNodeRole(ODatabaseId db,
 ONodeId node,
 ONodeRole role,
 OVersion version,
 OTransactionIdPromise promise)

dbRemovedFromDiskWhenOffline

public void dbRemovedFromDiskWhenOffline(ODatabaseId db)

getMembers

public Set<ONodeId> getMembers(ODatabaseId databaseId)

Specified by:

getMembers in interface ODatabasesTopology

validateSetDatabaseQuorum

public Optional<OAcceptResult> validateSetDatabaseQuorum(ODatabaseId db,
 int quorum,
 OVersion version,
 OTransactionIdPromise promise)

setDatabaseQuorum

public void setDatabaseQuorum(ODatabaseId db,
 int quorum,
 OVersion version,
 OTransactionIdPromise promise)

cancelSetDatabaseQuorum

public void cancelSetDatabaseQuorum(ODatabaseId db,
 int quorum,
 OVersion version,
 OTransactionIdPromise promise)

validateMergeNode

public Optional<OAcceptResult> validateMergeNode(List<ODatabaseStateNetwork> databases,
 OTransactionIdPromise promise)

checkTimeoutSync

public void checkTimeoutSync(long timeOutSync)