Class ODatabaseTopologyState
java.lang.Object
com.orientechnologies.orient.distributed.context.ODatabaseTopologyState
-
Constructor Summary
ConstructorsConstructorDescriptionODatabaseTopologyState(ODatabaseId db, String name, Set<ONodeId> partecipants, int quorum, ODatabaseStateChangeListener stateListener) ODatabaseTopologyState(ODatabaseStateNetwork state, ODatabaseStateChangeListener stateListener) -
Method Summary
Modifier and TypeMethodDescriptionbooleanacceptSync(ONodeId sender, ONodeId receiver, OSyncId syncId) voidcancelSetState(ONodeId nodeId, long version) canSync(ONodeId sender, ONodeId receiver, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) voiddefineNode(ONodeId node, ONodeRole role, ODatabaseState state, long version) voidvoidexecuteOnOneOnline(OStateAction execute) getId()getName()longbooleannewSync()promiseState(ODatabaseState state, ONodeId nodeId, long version) voidvoidsetState(ONodeId node, ODatabaseState state, long version) startSend(ONodeId from, ONodeId to, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) booleanbooleanwaitOnlineQuorum(Optional<Long> timeout)
-
Constructor Details
-
ODatabaseTopologyState
public ODatabaseTopologyState(ODatabaseId db, String name, Set<ONodeId> partecipants, int quorum, ODatabaseStateChangeListener stateListener) -
ODatabaseTopologyState
public ODatabaseTopologyState(ODatabaseStateNetwork state, ODatabaseStateChangeListener stateListener)
-
-
Method Details
-
defineNode
-
setState
-
getId
-
getName
-
promiseState
-
getVersion
public long getVersion() -
getState
-
cancelSetState
-
executeOnOneOnline
- Throws:
InterruptedException
-
waitOnlineQuorum
- Throws:
InterruptedException
-
waitOnlineOne
public boolean waitOnlineOne() -
executeOnOneOnline
-
getOnlineNodes
-
newSync
-
canSync
public Optional<OSyncState> canSync(ONodeId sender, ONodeId receiver, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) -
startSend
public OSyncState startSend(ONodeId from, ONodeId to, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus) -
acceptSync
-
isMain
-
getNetworkState
-
receiveState
-
getRole
-