Package com.orientechnologies.orient.distributed.context

Class ODatabaseTopologyState

java.lang.Object

com.orientechnologies.orient.distributed.context.ODatabaseTopologyState

public class ODatabaseTopologyState
extends Object

Constructor Summary

Constructors

Constructor	Description
ODatabaseTopologyState(ODatabaseId db, String name, Set<ONodeId> partecipants, int quorum, ODatabaseStateChangeListener stateListener)
ODatabaseTopologyState(ODatabaseStateNetwork state, ODatabaseStateChangeListener stateListener)

Method Summary

Modifier and Type	Method	Description
boolean	acceptSync(ONodeId sender, ONodeId receiver, OSyncId syncId)
void	cancelSetState(ONodeId nodeId, long version)
Optional<OSyncState>	canSync(ONodeId sender, ONodeId receiver, OSyncId syncId, boolean canSync, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
void	defineNode(ONodeId node, ONodeRole role, ODatabaseState state, long version)
void	executeOnOneOnline()
void	executeOnOneOnline(OStateAction execute)
ODatabaseId	getId()
String	getName()
ODatabaseStateNetwork	getNetworkState()
Set<ONodeId>	getOnlineNodes()
ONodeRole	getRole(ONodeId nodeId)
ODatabaseState	getState(ONodeId nodeId)
long	getVersion()
boolean	isMain(ONodeId nodeId)
Optional<OSyncInfo>	newSync()
Optional<OAcceptResult>	promiseState(ODatabaseState state, ONodeId nodeId, long version)
void	receiveState(ODatabaseStateNetwork state)
void	setState(ONodeId node, ODatabaseState state, long version)
OSyncState	startSend(ONodeId from, ONodeId to, OSyncId syncId, OSyncMode mode, Optional<OTransactionSequenceStatus> sequenceStatus)
boolean	waitOnlineOne()
boolean	waitOnlineQuorum(Optional<Long> timeout)

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<ONodeId> partecipants,
 int quorum,
 ODatabaseStateChangeListener stateListener)

ODatabaseTopologyState

public ODatabaseTopologyState(ODatabaseStateNetwork state,
 ODatabaseStateChangeListener stateListener)

Method Details

defineNode

public void defineNode(ONodeId node,
 ONodeRole role,
 ODatabaseState state,
 long version)

setState

public void setState(ONodeId node,
 ODatabaseState state,
 long version)

getId

public ODatabaseId getId()

getName

public String getName()

promiseState

public Optional<OAcceptResult> promiseState(ODatabaseState state,
 ONodeId nodeId,
 long version)

getVersion

public long getVersion()

getState

public ODatabaseState getState(ONodeId nodeId)

cancelSetState

public void cancelSetState(ONodeId nodeId,
 long version)

executeOnOneOnline

public void executeOnOneOnline()
                        throws InterruptedException

Throws:

InterruptedException

waitOnlineQuorum

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

Throws:

InterruptedException

waitOnlineOne

public boolean waitOnlineOne()

executeOnOneOnline

public void executeOnOneOnline(OStateAction execute)

getOnlineNodes

public Set<ONodeId> getOnlineNodes()

newSync

public Optional<OSyncInfo> 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

public boolean acceptSync(ONodeId sender,
 ONodeId receiver,
 OSyncId syncId)

isMain

public boolean isMain(ONodeId nodeId)

getNetworkState

public ODatabaseStateNetwork getNetworkState()

receiveState

public void receiveState(ODatabaseStateNetwork state)

getRole

public ONodeRole getRole(ONodeId nodeId)