com.orientechnologies.orient.server.distributed

Interface ODistributedDatabase

public interface ODistributedDatabase

Generic Distributed Database interface.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

Method Summary

Modifier and Type	Method and Description
int	checkQuorumBeforeReplicate(com.orientechnologies.orient.core.command.OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedConfiguration cfg)
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx	getDatabaseInstance()
String	getDatabaseName()
ODistributedServerManager	getManager()
ODistributedSyncConfiguration	getSyncConfiguration()
void	handleUnreachableNode(int iNodeId) Unlocks all the record locked by node iNodeName
ODistributedRequestId	lockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord, ODistributedRequestId iRequestId) Locks the record to be sure distributed transactions never work concurrently against the same records in the meanwhile the transaction is executed and the OCompleteTxTask is not arrived.
ODistributedTxContext	popTxContext(ODistributedRequestId requestId)
void	processRequest(ODistributedRequest request)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterSentCallback)
void	setOnline()
void	unlockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord, ODistributedRequestId requestId) Unlocks the record previously locked through #lockRecord method.

Method Detail

getDatabaseName

String getDatabaseName()

send2Nodes

ODistributedResponse send2Nodes(ODistributedRequest iRequest,
                                Collection<String> iClusterNames,
                                Collection<String> iNodes,
                                ODistributedRequest.EXECUTION_MODE iExecutionMode,
                                Object localResult,
                                com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterSentCallback)

setOnline

void setOnline()

checkQuorumBeforeReplicate

int checkQuorumBeforeReplicate(com.orientechnologies.orient.core.command.OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType,
                               Collection<String> iClusterNames,
                               Collection<String> iNodes,
                               ODistributedConfiguration cfg)

lockRecord

ODistributedRequestId lockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord,
                                 ODistributedRequestId iRequestId)

Locks the record to be sure distributed transactions never work concurrently against the same records in the meanwhile the transaction is executed and the OCompleteTxTask is not arrived.

Parameters:

iRecord - Record to lock

iRequestId - Request id

Returns:

true if the lock succeed, otherwise false

See Also:

unlockRecord(OIdentifiable, ODistributedRequestId)

unlockRecord

void unlockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable iRecord,
                  ODistributedRequestId requestId)

Unlocks the record previously locked through #lockRecord method.

Parameters:

iRecord -

requestId -

See Also:

lockRecord(OIdentifiable, ODistributedRequestId)

handleUnreachableNode

void handleUnreachableNode(int iNodeId)

Unlocks all the record locked by node iNodeName

Parameters:

iNodeId - node id

getSyncConfiguration

ODistributedSyncConfiguration getSyncConfiguration()

processRequest

void processRequest(ODistributedRequest request)

registerTxContext

ODistributedTxContext registerTxContext(ODistributedRequestId reqId)

popTxContext

ODistributedTxContext popTxContext(ODistributedRequestId requestId)

getManager

ODistributedServerManager getManager()

getDatabaseInstance

com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx getDatabaseInstance()