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

Interface OCoordinatedDistributedOps

All Known Implementing Classes:

OCoordinatedDistributedOpsImpl

public interface OCoordinatedDistributedOps

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	cancelDeclareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database)
void	cancelDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
void	cancelEstablish(OTransactionIdPromise promise)
void	cancelMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	cancelMergeToNetwork(OTransactionIdPromise promise)
void	cancelPromise(OTransactionIdPromise promise)
void	cancelRegisterNode(OTransactionIdPromise promise)
void	cancelRemoveDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, 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)
void	cancelSetTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
void	cancelUnregisterNode(OTransactionIdPromise promise)
Optional<OCanSyncResult>	canSync(ONodeId sender, OSyncId syncId, OCanSyncAccept canSync)
Set<ONodeId>	checkOffline(long time)
void	checkTimeoutSync(long timeOutSync)
void	completeExecution(OTransactionIdPromise promise)
void	completeSync(OSyncId syncId, boolean success)
Optional<ODistributedMessage>	consensusFailure(OTransactionIdPromise promise)
OConfirmResult	consensusSuccess(OTransactionIdPromise promise)
Optional<ONodeStateNetwork>	createMergedState(ONodeStateNetwork state)
void	dbRemovedFromDiskWhenOffline(ODatabaseId db)
void	declareDatabase(OTransactionIdPromise promise, ODatabaseId dbId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
ODiscoverAction	discoverNode(ONodeId node)
void	dropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
Set<ONodeId>	establish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	executeOnEnstablish(ONotificationAction action)
boolean	executeOnOneOnline(ODatabaseId dbId, ONotificationAction execute)
ONodeId	getCurrent()
int	getDatabaseQuorum(ODatabaseId databaseId)
ODatabasesTopology	getDatabaseTopology()
OGroupId	getGroupId()
ONodeStateNetwork	getNetworkState()
ONetworkTopology	getNetworkTopology()
Optional<OSyncState>	getSyncState(OSyncId syncId)
OTransactionSequenceStatus	getTransactionSequenceState()
boolean	isApplied(OTransactionId txId)
void	load(ONodeStateStore storeState)
void	mergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
void	mergeToNetwork(OTransactionIdPromise promise)
Optional<OSyncInfo>	newSync(ODatabaseId dbId)
OVersion	nextDatabaseVersion(ODatabaseId Id)
OVersion	nextTopologyVersion()
ODisconnectAction	nodeDisconnected(ONodeId node)
void	nodeFailure(ONodeId node, OTransactionIdPromise promise, OAcceptResult acceptResult)
ODiscoverAction	nodeJoinStart(ONodeId node, ONodeStateNetwork state, boolean merge)
void	nodeMergeResult(ONodeId node, OTransactionIdPromise promise, Optional<OAcceptResult> accepted)
void	nodeSuccess(ONodeId node, OTransactionIdPromise promise)
Optional<OAcceptResult>	receive(ODistributedMessage message)
boolean	receivePing(ONodeId nodeId, OTransactionSequenceStatus status)
boolean	receiveRecover(OTransactionIdPromise promise)
Optional<OAcceptResult>	receiveRetry(OTransactionIdPromise promise)
void	registerNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
void	removeDatabaseMembers(ODatabaseId dbId, List<ONodeId> nodes, OVersion version, OTransactionIdPromise promise)
void	requestNext(OSyncId syncId, boolean close)
Optional<OOperationStart>	restart(OTransactionIdPromise current, OCompleteAction action)
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)
void	setTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OOperationStart>	start(OCompleteAction action)
Optional<OTransactionIdPromise>	startEstablish(Set<ONodeId> nodes, OCompleteAction action)
Optional<OSyncState>	startSend(ONodeId from, OSyncId syncId, OCanSyncAccept mode)
boolean	successRecover(OTransactionIdPromise promise)
List<OTransactionId>	transactionsToSend(OTransactionSequenceStatus otherStatus)
ODisconnectAction	unregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateAddDatabaseMember(ODatabaseId dbId, List<OAddNodeInfo> nodes, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateDeclareDatabase(OTransactionIdPromise promise, ODatabaseId databaseId, String database, Set<OAddNodeInfo> partecipants, int minimumQuorum)
Optional<OAcceptResult>	validateDropDatabase(ODatabaseId dbId, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateEstablish(OGroupId networkId, Set<ONodeId> candidates, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateMergeNode(ONodeId node, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateMergeToNetwork(OGroupId group, ONodeStateNetwork state, ONodeStateNetwork original, OTransactionIdPromise coordinator)
Optional<OAcceptResult>	validateRegisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateRemoveDatabaseMembers(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)
Optional<OAcceptResult>	validateSetTopologyQuorum(int quorum, OVersion version, OTransactionIdPromise promise)
Optional<OAcceptResult>	validateUnregisterNode(ONodeId node, OVersion version, OTransactionIdPromise promise)
boolean	waitForEnstablish(Optional<Long> timeout)
boolean	waitNodeJoined(ONodeId dbId, Optional<Long> timeout)
boolean	waitOnlineAll(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)

Method Details

start

Optional<OOperationStart> start(OCompleteAction action)

restart

Optional<OOperationStart> restart(OTransactionIdPromise current,
 OCompleteAction action)

receive

Optional<OAcceptResult> receive(ODistributedMessage message)

successRecover

boolean successRecover(OTransactionIdPromise promise)

receiveRecover

boolean receiveRecover(OTransactionIdPromise promise)

nodeSuccess

void nodeSuccess(ONodeId node,
 OTransactionIdPromise promise)

nodeFailure

void nodeFailure(ONodeId node,
 OTransactionIdPromise promise,
 OAcceptResult acceptResult)

consensusFailure

Optional<ODistributedMessage> consensusFailure(OTransactionIdPromise promise)

consensusSuccess

OConfirmResult consensusSuccess(OTransactionIdPromise promise)

completeExecution

void completeExecution(OTransactionIdPromise promise)

nextTopologyVersion

OVersion nextTopologyVersion()

nextDatabaseVersion

OVersion nextDatabaseVersion(ODatabaseId Id)

discoverNode

ODiscoverAction discoverNode(ONodeId node)

nodeJoinStart

ODiscoverAction nodeJoinStart(ONodeId node,
 ONodeStateNetwork state,
 boolean merge)

validateRegisterNode

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

registerNode

void registerNode(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

validateUnregisterNode

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

unregisterNode

ODisconnectAction unregisterNode(ONodeId node,
 OVersion version,
 OTransactionIdPromise promise)

cancelUnregisterNode

void cancelUnregisterNode(OTransactionIdPromise promise)

cancelRegisterNode

void cancelRegisterNode(OTransactionIdPromise promise)

validateMergeToNetwork

Optional<OAcceptResult> validateMergeToNetwork(OGroupId group,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise coordinator)

mergeToNetwork

void mergeToNetwork(OTransactionIdPromise promise)

nodeMergeResult

void nodeMergeResult(ONodeId node,
 OTransactionIdPromise promise,
 Optional<OAcceptResult> accepted)

cancelMergeToNetwork

void cancelMergeToNetwork(OTransactionIdPromise promise)

startEstablish

Optional<OTransactionIdPromise> startEstablish(Set<ONodeId> nodes,
 OCompleteAction action)

validateEstablish

Optional<OAcceptResult> validateEstablish(OGroupId networkId,
 Set<ONodeId> candidates,
 OTransactionIdPromise promise)

establish

Set<ONodeId> establish(OGroupId networkId,
 Set<ONodeId> candidates,
 OTransactionIdPromise promise)

cancelEstablish

void cancelEstablish(OTransactionIdPromise promise)

validateDeclareDatabase

Optional<OAcceptResult> validateDeclareDatabase(OTransactionIdPromise promise,
 ODatabaseId databaseId,
 String database,
 Set<OAddNodeInfo> partecipants,
 int minimumQuorum)

declareDatabase

void declareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database,
 Set<OAddNodeInfo> partecipants,
 int minimumQuorum)

cancelDeclareDatabase

void cancelDeclareDatabase(OTransactionIdPromise promise,
 ODatabaseId dbId,
 String database)

validateAddDatabaseMember

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

addDatabaseMember

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

cancelAddDatabaseMember

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

validateRemoveDatabaseMembers

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

removeDatabaseMembers

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

cancelRemoveDatabaseMembers

void cancelRemoveDatabaseMembers(ODatabaseId dbId,
 List<ONodeId> nodes,
 OTransactionIdPromise promise)

validateSetState

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

setState

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

cancelSetState

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

newSync

Optional<OSyncInfo> newSync(ODatabaseId dbId)

acceptSync

boolean acceptSync(ONodeId sender,
 OSyncId syncId)

canSync

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

startSend

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

getSyncState

Optional<OSyncState> getSyncState(OSyncId syncId)

requestNext

void requestNext(OSyncId syncId,
 boolean close)

completeSync

void completeSync(OSyncId syncId,
 boolean success)

getDatabaseTopology

ODatabasesTopology getDatabaseTopology()

getNetworkTopology

ONetworkTopology getNetworkTopology()

getNetworkState

ONodeStateNetwork getNetworkState()

getCurrent

ONodeId getCurrent()

getGroupId

OGroupId getGroupId()

isApplied

boolean isApplied(OTransactionId txId)

load

void load(ONodeStateStore storeState)

executeOnOneOnline

boolean executeOnOneOnline(ODatabaseId dbId,
 ONotificationAction execute)

waitOnlineQuorum

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

Throws:

InterruptedException

waitOnlineAll

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

Throws:

InterruptedException

waitSelfOnline

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

Throws:

InterruptedException

waitSelfOnline

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

Throws:

InterruptedException

waitNodeJoined

boolean waitNodeJoined(ONodeId dbId,
 Optional<Long> timeout)
                throws InterruptedException

Throws:

InterruptedException

nodeDisconnected

ODisconnectAction nodeDisconnected(ONodeId node)

cancelPromise

void cancelPromise(OTransactionIdPromise promise)

receiveRetry

Optional<OAcceptResult> receiveRetry(OTransactionIdPromise promise)

getTransactionSequenceState

OTransactionSequenceStatus getTransactionSequenceState()

receivePing

boolean receivePing(ONodeId nodeId,
 OTransactionSequenceStatus status)

transactionsToSend

List<OTransactionId> transactionsToSend(OTransactionSequenceStatus otherStatus)

checkOffline

Set<ONodeId> checkOffline(long time)

getDatabaseQuorum

int getDatabaseQuorum(ODatabaseId databaseId)

validateDropDatabase

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

dropDatabase

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

cancelDropDatabase

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

validateMergeNode

Optional<OAcceptResult> validateMergeNode(ONodeId node,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

mergeNode

void mergeNode(ONodeId node,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

cancelMergeNode

void cancelMergeNode(ONodeId node,
 ONodeStateNetwork state,
 ONodeStateNetwork original,
 OTransactionIdPromise promise)

createMergedState

Optional<ONodeStateNetwork> createMergedState(ONodeStateNetwork state)

validateSetDatabaseNodeRole

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

setDatabaseNodeRole

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

cancelSetDatabaseNodeRole

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

dbRemovedFromDiskWhenOffline

void dbRemovedFromDiskWhenOffline(ODatabaseId db)

waitForEnstablish

boolean waitForEnstablish(Optional<Long> timeout)
                   throws InterruptedException

Throws:

InterruptedException

executeOnEnstablish

void executeOnEnstablish(ONotificationAction action)

validateSetDatabaseQuorum

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

setDatabaseQuorum

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

cancelSetDatabaseQuorum

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

checkTimeoutSync

void checkTimeoutSync(long timeOutSync)

validateSetTopologyQuorum

Optional<OAcceptResult> validateSetTopologyQuorum(int quorum,
 OVersion version,
 OTransactionIdPromise promise)

setTopologyQuorum

void setTopologyQuorum(int quorum,
 OVersion version,
 OTransactionIdPromise promise)

cancelSetTopologyQuorum

void cancelSetTopologyQuorum(int quorum,
 OVersion version,
 OTransactionIdPromise promise)