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

Class OCoordinatedDistributedOpsImpl

java.lang.Object

com.orientechnologies.orient.distributed.context.coordination.OCoordinatedDistributedOpsImpl

All Implemented Interfaces:

OCoordinatedDistributedOps

public class OCoordinatedDistributedOpsImpl
extends Object
implements OCoordinatedDistributedOps

Constructor Summary

Constructors

Constructor	Description
OCoordinatedDistributedOpsImpl(ONodeId current, OGroupId groupId, int minimumQuorum, ODatabaseStateChangeListener listener, ONodeStateUpdated updateLister)

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 groupId, Set<ONodeId> candidates, OTransactionIdPromise promise)
void	executeOnEnstablish(ONotificationAction action)
boolean	executeOnOneOnline(ODatabaseId dbId, ONotificationAction execute)
ONodeId	getCurrent()
int	getDatabaseQuorum(ODatabaseId databaseId)
ODatabasesTopologyState	getDatabaseTopology()
OGroupId	getGroupId()
ONodeStateNetwork	getNetworkState()
ONetworkTopology	getNetworkTopology()
OTransactionSequenceManager	getSequenceManager()
ONodeStateStore	getStore()
Optional<OSyncState>	getSyncState(OSyncId syncId)
OTransactionSequenceStatus	getTransactionSequenceState()
boolean	isApplied(OTransactionId txId)
void	load(ONodeStateStore state)
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)
void	notifyUpdate()
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 status)
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 groupId, 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 promise)
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OCoordinatedDistributedOpsImpl

public OCoordinatedDistributedOpsImpl(ONodeId current,
 OGroupId groupId,
 int minimumQuorum,
 ODatabaseStateChangeListener listener,
 ONodeStateUpdated updateLister)

Method Details

discoverNode

public ODiscoverAction discoverNode(ONodeId node)

Specified by:

discoverNode in interface OCoordinatedDistributedOps

registerNode

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

Specified by:

registerNode in interface OCoordinatedDistributedOps

validateUnregisterNode

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

Specified by:

validateUnregisterNode in interface OCoordinatedDistributedOps

unregisterNode

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

Specified by:

unregisterNode in interface OCoordinatedDistributedOps

cancelUnregisterNode

public void cancelUnregisterNode(OTransactionIdPromise promise)

Specified by:

cancelUnregisterNode in interface OCoordinatedDistributedOps

start

public Optional<OOperationStart> start(OCompleteAction action)

Specified by:

start in interface OCoordinatedDistributedOps

restart

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

Specified by:

restart in interface OCoordinatedDistributedOps

receiveRetry

public Optional<OAcceptResult> receiveRetry(OTransactionIdPromise promise)

Specified by:

receiveRetry in interface OCoordinatedDistributedOps

receive

public Optional<OAcceptResult> receive(ODistributedMessage message)

Specified by:

receive in interface OCoordinatedDistributedOps

successRecover

public boolean successRecover(OTransactionIdPromise promise)

Specified by:

successRecover in interface OCoordinatedDistributedOps

receiveRecover

public boolean receiveRecover(OTransactionIdPromise promise)

Specified by:

receiveRecover in interface OCoordinatedDistributedOps

cancelPromise

public void cancelPromise(OTransactionIdPromise promise)

Specified by:

cancelPromise in interface OCoordinatedDistributedOps

consensusFailure

public Optional<ODistributedMessage> consensusFailure(OTransactionIdPromise promise)

Specified by:

consensusFailure in interface OCoordinatedDistributedOps

consensusSuccess

public OConfirmResult consensusSuccess(OTransactionIdPromise promise)

Specified by:

consensusSuccess in interface OCoordinatedDistributedOps

nodeSuccess

public void nodeSuccess(ONodeId node,
 OTransactionIdPromise promise)

Specified by:

nodeSuccess in interface OCoordinatedDistributedOps

nodeFailure

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

Specified by:

nodeFailure in interface OCoordinatedDistributedOps

completeExecution

public void completeExecution(OTransactionIdPromise promise)

Specified by:

completeExecution in interface OCoordinatedDistributedOps

validateRegisterNode

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

Specified by:

validateRegisterNode in interface OCoordinatedDistributedOps

establish

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

Specified by:

establish in interface OCoordinatedDistributedOps

validateEstablish

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

Specified by:

validateEstablish in interface OCoordinatedDistributedOps

startEstablish

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

Specified by:

startEstablish in interface OCoordinatedDistributedOps

nodeJoinStart

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

Specified by:

nodeJoinStart in interface OCoordinatedDistributedOps

getNetworkState

public ONodeStateNetwork getNetworkState()

Specified by:

getNetworkState in interface OCoordinatedDistributedOps

load

public void load(ONodeStateStore state)

Specified by:

load in interface OCoordinatedDistributedOps

cancelRegisterNode

public void cancelRegisterNode(OTransactionIdPromise promise)

Specified by:

cancelRegisterNode in interface OCoordinatedDistributedOps

cancelEstablish

public void cancelEstablish(OTransactionIdPromise promise)

Specified by:

cancelEstablish in interface OCoordinatedDistributedOps

validateDeclareDatabase

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

Specified by:

validateDeclareDatabase in interface OCoordinatedDistributedOps

declareDatabase

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

Specified by:

declareDatabase in interface OCoordinatedDistributedOps

cancelDeclareDatabase

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

Specified by:

cancelDeclareDatabase in interface OCoordinatedDistributedOps

nextTopologyVersion

public OVersion nextTopologyVersion()

Specified by:

nextTopologyVersion in interface OCoordinatedDistributedOps

nextDatabaseVersion

public OVersion nextDatabaseVersion(ODatabaseId Id)

Specified by:

nextDatabaseVersion in interface OCoordinatedDistributedOps

getDatabaseTopology

public ODatabasesTopologyState getDatabaseTopology()

Specified by:

getDatabaseTopology in interface OCoordinatedDistributedOps

getNetworkTopology

public ONetworkTopology getNetworkTopology()

Specified by:

getNetworkTopology in interface OCoordinatedDistributedOps

validateAddDatabaseMember

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

Specified by:

validateAddDatabaseMember in interface OCoordinatedDistributedOps

addDatabaseMember

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

Specified by:

addDatabaseMember in interface OCoordinatedDistributedOps

cancelAddDatabaseMember

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

Specified by:

cancelAddDatabaseMember in interface OCoordinatedDistributedOps

validateRemoveDatabaseMembers

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

Specified by:

validateRemoveDatabaseMembers in interface OCoordinatedDistributedOps

removeDatabaseMembers

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

Specified by:

removeDatabaseMembers in interface OCoordinatedDistributedOps

cancelRemoveDatabaseMembers

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

Specified by:

cancelRemoveDatabaseMembers in interface OCoordinatedDistributedOps

validateSetTopologyQuorum

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

Specified by:

validateSetTopologyQuorum in interface OCoordinatedDistributedOps

setTopologyQuorum

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

Specified by:

setTopologyQuorum in interface OCoordinatedDistributedOps

cancelSetTopologyQuorum

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

Specified by:

cancelSetTopologyQuorum in interface OCoordinatedDistributedOps

validateSetState

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

Specified by:

validateSetState in interface OCoordinatedDistributedOps

setState

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

Specified by:

setState in interface OCoordinatedDistributedOps

cancelSetState

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

Specified by:

cancelSetState in interface OCoordinatedDistributedOps

newSync

public Optional<OSyncInfo> newSync(ODatabaseId dbId)

Specified by:

newSync in interface OCoordinatedDistributedOps

acceptSync

public boolean acceptSync(ONodeId sender,
 OSyncId syncId)

Specified by:

acceptSync in interface OCoordinatedDistributedOps

canSync

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

Specified by:

canSync in interface OCoordinatedDistributedOps

startSend

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

Specified by:

startSend in interface OCoordinatedDistributedOps

requestNext

public void requestNext(OSyncId syncId,
 boolean close)

Specified by:

requestNext in interface OCoordinatedDistributedOps

getSyncState

public Optional<OSyncState> getSyncState(OSyncId syncId)

Specified by:

getSyncState in interface OCoordinatedDistributedOps

executeOnOneOnline

public boolean executeOnOneOnline(ODatabaseId dbId,
 ONotificationAction execute)

Specified by:

executeOnOneOnline in interface OCoordinatedDistributedOps

waitOnlineQuorum

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

Specified by:

waitOnlineQuorum in interface OCoordinatedDistributedOps

Throws:

InterruptedException

waitOnlineAll

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

Specified by:

waitOnlineAll in interface OCoordinatedDistributedOps

Throws:

InterruptedException

waitSelfOnline

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

Specified by:

waitSelfOnline in interface OCoordinatedDistributedOps

Throws:

InterruptedException

waitSelfOnline

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

Specified by:

waitSelfOnline in interface OCoordinatedDistributedOps

Throws:

InterruptedException

isApplied

public boolean isApplied(OTransactionId txId)

Specified by:

isApplied in interface OCoordinatedDistributedOps

completeSync

public void completeSync(OSyncId syncId,
 boolean success)

Specified by:

completeSync in interface OCoordinatedDistributedOps

getStore

public ONodeStateStore getStore()

notifyUpdate

public void notifyUpdate()

getSequenceManager

public OTransactionSequenceManager getSequenceManager()

validateMergeToNetwork

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

Specified by:

validateMergeToNetwork in interface OCoordinatedDistributedOps

cancelMergeToNetwork

public void cancelMergeToNetwork(OTransactionIdPromise promise)

Specified by:

cancelMergeToNetwork in interface OCoordinatedDistributedOps

mergeToNetwork

public void mergeToNetwork(OTransactionIdPromise promise)

Specified by:

mergeToNetwork in interface OCoordinatedDistributedOps

nodeMergeResult

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

Specified by:

nodeMergeResult in interface OCoordinatedDistributedOps

getGroupId

public OGroupId getGroupId()

Specified by:

getGroupId in interface OCoordinatedDistributedOps

nodeDisconnected

public ODisconnectAction nodeDisconnected(ONodeId node)

Specified by:

nodeDisconnected in interface OCoordinatedDistributedOps

getTransactionSequenceState

public OTransactionSequenceStatus getTransactionSequenceState()

Specified by:

getTransactionSequenceState in interface OCoordinatedDistributedOps

receivePing

public boolean receivePing(ONodeId nodeId,
 OTransactionSequenceStatus status)

Specified by:

receivePing in interface OCoordinatedDistributedOps

transactionsToSend

public List<OTransactionId> transactionsToSend(OTransactionSequenceStatus status)

Specified by:

transactionsToSend in interface OCoordinatedDistributedOps

checkOffline

public Set<ONodeId> checkOffline(long time)

Specified by:

checkOffline in interface OCoordinatedDistributedOps

getCurrent

public ONodeId getCurrent()

Specified by:

getCurrent in interface OCoordinatedDistributedOps

getDatabaseQuorum

public int getDatabaseQuorum(ODatabaseId databaseId)

Specified by:

getDatabaseQuorum in interface OCoordinatedDistributedOps

validateDropDatabase

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

Specified by:

validateDropDatabase in interface OCoordinatedDistributedOps

dropDatabase

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

Specified by:

dropDatabase in interface OCoordinatedDistributedOps

cancelDropDatabase

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

Specified by:

cancelDropDatabase in interface OCoordinatedDistributedOps

validateMergeNode

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

Specified by:

validateMergeNode in interface OCoordinatedDistributedOps

mergeNode

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

Specified by:

mergeNode in interface OCoordinatedDistributedOps

cancelMergeNode

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

Specified by:

cancelMergeNode in interface OCoordinatedDistributedOps

createMergedState

public Optional<ONodeStateNetwork> createMergedState(ONodeStateNetwork state)

Specified by:

createMergedState in interface OCoordinatedDistributedOps

validateSetDatabaseNodeRole

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

Specified by:

validateSetDatabaseNodeRole in interface OCoordinatedDistributedOps

setDatabaseNodeRole

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

Specified by:

setDatabaseNodeRole in interface OCoordinatedDistributedOps

cancelSetDatabaseNodeRole

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

Specified by:

cancelSetDatabaseNodeRole in interface OCoordinatedDistributedOps

dbRemovedFromDiskWhenOffline

public void dbRemovedFromDiskWhenOffline(ODatabaseId db)

Specified by:

dbRemovedFromDiskWhenOffline in interface OCoordinatedDistributedOps

waitForEnstablish

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

Specified by:

waitForEnstablish in interface OCoordinatedDistributedOps

Throws:

InterruptedException

executeOnEnstablish

public void executeOnEnstablish(ONotificationAction action)

Specified by:

executeOnEnstablish in interface OCoordinatedDistributedOps

validateSetDatabaseQuorum

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

Specified by:

validateSetDatabaseQuorum in interface OCoordinatedDistributedOps

setDatabaseQuorum

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

Specified by:

setDatabaseQuorum in interface OCoordinatedDistributedOps

cancelSetDatabaseQuorum

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

Specified by:

cancelSetDatabaseQuorum in interface OCoordinatedDistributedOps

checkTimeoutSync

public void checkTimeoutSync(long timeOutSync)

Specified by:

checkTimeoutSync in interface OCoordinatedDistributedOps

waitNodeJoined

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

Specified by:

waitNodeJoined in interface OCoordinatedDistributedOps

Throws:

InterruptedException