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

Class ODatabaseTopologyState

java.lang.Object

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

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

public class ODatabaseTopologyState
extends OWatcher

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
ODatabaseTopologyState(ODatabaseId db, String name, Set<OAddNodeInfo> partecipants, int quorum, ODatabaseStateChangeListener stateListener, ONodeId current)
ODatabaseTopologyState(ODatabaseStateChangeListener listener, ODatabaseTopologyStore store, ONodeId current)
ODatabaseTopologyState(ODatabaseStateNetwork state, ODatabaseStateChangeListener stateListener, ONodeId current)

Method Summary

Modifier and Type	Method	Description
boolean	acceptSync(ONodeId sender, OSyncId syncId)
void	addMember(List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
void	cancelAddMemer(List<OAddNodeInfo> nodes, OTransactionIdPromise promise)
void	cancelDrop(OTransactionIdPromise promise, OVersion version)
void	cancelMerge(OTransactionIdPromise promise)
void	cancelQuorum(OVersion version, OTransactionIdPromise promise)
void	cancelRemoveMemer(OTransactionIdPromise promise)
void	cancelRole(ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	cancelSetState(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	drop(OTransactionIdPromise promise, OVersion version)
void	executeOnOneOnline(ONotificationAction execute)
ODatabaseId	getId()
Set<ONodeId>	getMembers()
String	getName()
ODatabaseStateNetwork	getNetworkState()
Set<ONodeId>	getOnlineNodes()
int	getQuorum()
ONodeRole	getRole(ONodeId nodeId)
ODatabaseState	getState(ONodeId nodeId)
ODatabaseTopologyStore	getStore()
Set<OSyncState>	getSyncs()
Optional<OSyncState>	getSyncState(OSyncId syncId)
OVersion	getVersion()
boolean	isAllOnline()
boolean	isMain(ONodeId nodeId)
boolean	isQuorumOnline()
boolean	isSynching()
void	mergeState(ODatabaseStateNetwork state, OTransactionIdPromise promise)
Optional<OSyncInfo>	newSync()
OVersion	nextVersion()
void	nodeDisconnected(ONodeId node)
void	notifyAllNodesStates()
Optional<OAcceptResult>	promiseMember(List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	promiseRemoveMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	promiseState(ODatabaseState state, ONodeId nodeId, OVersion version, OTransactionIdPromise promise)
void	receiveState(ODatabaseStateNetwork state, boolean notify)
void	removeMember(List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	requestNext(OSyncId syncId, boolean close)
void	setQuorum(int newQuorum, OVersion version, OTransactionIdPromise promise)
void	setRole(ONodeId node, ONodeRole role, OVersion version, OTransactionIdPromise promise)
void	setState(ONodeId node, ODatabaseState state, OVersion version, OTransactionIdPromise promise)
boolean	shouldSink(ONodeId nodeID)
Optional<OSyncState>	startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
Optional<OAcceptResult>	validateDrop(OTransactionIdPromise promise, OVersion version)
Optional<OAcceptResult>	validateMerge(OTransactionIdPromise promise, ODatabaseStateNetwork stateDb)
Optional<OAcceptResult>	validateMergeNode(OTransactionIdPromise promise, ODatabaseStateNetwork stateDb)
Optional<OAcceptResult>	validateRole(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateSetQurum(int newQuorum, OVersion version, OTransactionIdPromise promise)
boolean	waitOnlineAll(Optional<Long> timeout)
boolean	waitOnlineOne(Optional<Long> timeout)
boolean	waitOnlineQuorum(Optional<Long> timeout)
boolean	waitSelfOnline(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

ODatabaseTopologyState

public ODatabaseTopologyState(ODatabaseId db,
 String name,
 Set<OAddNodeInfo> partecipants,
 int quorum,
 ODatabaseStateChangeListener stateListener,
 ONodeId current)

ODatabaseTopologyState

public ODatabaseTopologyState(ODatabaseStateNetwork state,
 ODatabaseStateChangeListener stateListener,
 ONodeId current)

ODatabaseTopologyState

public ODatabaseTopologyState(ODatabaseStateChangeListener listener,
 ODatabaseTopologyStore store,
 ONodeId current)

Method Details

setState

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

getId

public ODatabaseId getId()

getName

public String getName()

promiseState

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

getVersion

public OVersion getVersion()

getState

public ODatabaseState getState(ONodeId nodeId)

cancelSetState

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

waitOnlineQuorum

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

Throws:

InterruptedException

waitOnlineAll

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

Throws:

InterruptedException

isQuorumOnline

public boolean isQuorumOnline()

isAllOnline

public boolean isAllOnline()

waitOnlineOne

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

Throws:

InterruptedException

waitSelfOnline

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

Throws:

InterruptedException

executeOnOneOnline

public void executeOnOneOnline(ONotificationAction execute)

getOnlineNodes

public Set<ONodeId> getOnlineNodes()

newSync

public Optional<OSyncInfo> newSync()

canSync

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

startSend

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

acceptSync

public boolean acceptSync(ONodeId sender,
 OSyncId syncId)

requestNext

public void requestNext(OSyncId syncId,
 boolean close)

isMain

public boolean isMain(ONodeId nodeId)

getNetworkState

public ODatabaseStateNetwork getNetworkState()

receiveState

public void receiveState(ODatabaseStateNetwork state,
 boolean notify)

mergeState

public void mergeState(ODatabaseStateNetwork state,
 OTransactionIdPromise promise)

getRole

public ONodeRole getRole(ONodeId nodeId)

promiseMember

public Optional<OAcceptResult> promiseMember(List<OAddNodeInfo> nodes,
 OVersion version,
 OTransactionIdPromise promise)

promiseRemoveMember

public Optional<OAcceptResult> promiseRemoveMember(List<ONodeId> nodes,
 OVersion version,
 OTransactionIdPromise promise)

removeMember

public void removeMember(List<ONodeId> nodes,
 OVersion version,
 OTransactionIdPromise promise)

cancelRemoveMemer

public void cancelRemoveMemer(OTransactionIdPromise promise)

addMember

public void addMember(List<OAddNodeInfo> nodes,
 OVersion version,
 OTransactionIdPromise promise)

cancelAddMemer

public void cancelAddMemer(List<OAddNodeInfo> nodes,
 OTransactionIdPromise promise)

shouldSink

public boolean shouldSink(ONodeId nodeID)

completeSync

public void completeSync(OSyncId syncId,
 boolean success)

getStore

public ODatabaseTopologyStore getStore()

getQuorum

public int getQuorum()

validateDrop

public Optional<OAcceptResult> validateDrop(OTransactionIdPromise promise,
 OVersion version)

drop

public void drop(OTransactionIdPromise promise,
 OVersion version)

cancelDrop

public void cancelDrop(OTransactionIdPromise promise,
 OVersion version)

getSyncState

public Optional<OSyncState> getSyncState(OSyncId syncId)

getSyncs

public Set<OSyncState> getSyncs()

nodeDisconnected

public void nodeDisconnected(ONodeId node)

validateMerge

public Optional<OAcceptResult> validateMerge(OTransactionIdPromise promise,
 ODatabaseStateNetwork stateDb)

validateMergeNode

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

cancelMerge

public void cancelMerge(OTransactionIdPromise promise)

nextVersion

public OVersion nextVersion()

validateRole

public Optional<OAcceptResult> validateRole(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

setRole

public void setRole(ONodeId node,
 ONodeRole role,
 OVersion version,
 OTransactionIdPromise promise)

cancelRole

public void cancelRole(ONodeId nodeId,
 OVersion version,
 OTransactionIdPromise promise)

notifyAllNodesStates

public void notifyAllNodesStates()

validateSetQurum

public Optional<OAcceptResult> validateSetQurum(int newQuorum,
 OVersion version,
 OTransactionIdPromise promise)

setQuorum

public void setQuorum(int newQuorum,
 OVersion version,
 OTransactionIdPromise promise)

cancelQuorum

public void cancelQuorum(OVersion version,
 OTransactionIdPromise promise)

getMembers

public Set<ONodeId> getMembers()

checkTimeoutSync

public void checkTimeoutSync(long timeOutSync)

isSynching

public boolean isSynching()