com.orientechnologies.orient.server.distributed

Interface ODistributedDatabase

All Known Implementing Classes:

ODistributedDatabaseImpl

public interface ODistributedDatabase

Generic Distributed Database interface.

Author:

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

Method Summary

Modifier and Type	Method and Description
void	checkNodeInConfiguration(ODistributedConfiguration cfg, String serverName)
String	dump()
boolean	forceLockRecord(ORID record, ODistributedRequestId requestId) Force the locking of a record.
ODatabaseDocumentInternal	getDatabaseInstance()
String	getDatabaseName()
ODistributedDatabaseRepairer	getDatabaseRepairer()
ODistributedServerManager	getManager()
long	getProcessedRequests()
long	getReceivedRequests()
ORawBuffer	getRecordIfLocked(ORID iRecord) Returns the locked record for read-only purpose.
ODistributedSyncConfiguration	getSyncConfiguration()
ODistributedTxContext	getTxContext(ODistributedRequestId requestId)
void	handleUnreachableNode(String nodeName) Unlocks all the record locked by node iNodeName
boolean	lockRecord(ORID record, ODistributedRequestId requestId, long timeout) 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, boolean waitForAcceptingRequests)
void	reEnqueue(int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
void	replaceRecordContentIfLocked(ORID rid, byte[] bytes) Replace the record content if it is locked.
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
void	setLSN(String sourceNodeName, OLogSequenceNumber taskLastLSN, boolean writeLastOperation)
void	setOnline()
void	unlockRecord(OIdentifiable record, ODistributedRequestId requestId) Unlocks the record previously locked through #lockRecord method.
void	unlockResourcesOfServer(ODatabaseDocumentInternal database, String serverName)
void	waitForOnline()

Method Detail

getDatabaseName

String getDatabaseName()

send2Nodes

ODistributedResponse send2Nodes(ODistributedRequest iRequest,
                                Collection<String> iClusterNames,
                                Collection<String> iNodes,
                                ODistributedRequest.EXECUTION_MODE iExecutionMode,
                                Object localResult,
                                OCallable<Void,ODistributedRequestId> iAfterSentCallback,
                                OCallable<Void,ODistributedResponseManager> endCallback)

setOnline

void setOnline()

getRecordIfLocked

ORawBuffer getRecordIfLocked(ORID iRecord)

Returns the locked record for read-only purpose. This avoid to have dirty reads until the transaction is fully committed.

Parameters:

iRecord - record to load.

Returns:

The record if it is locked, otherwise null.

replaceRecordContentIfLocked

void replaceRecordContentIfLocked(ORID rid,
                                  byte[] bytes)

Replace the record content if it is locked.

Parameters:

rid - Record ID of the record to find

bytes - Content as byte[] of the record to replace

lockRecord

boolean lockRecord(ORID record,
                   ODistributedRequestId requestId,
                   long timeout)

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:

record - Record to lock

requestId - Request id

timeout - Timeout in ms to wait for the lock

Throws:

ODistributedRecordLockedException - if the record wasn't locked

See Also:

unlockRecord(OIdentifiable, ODistributedRequestId)

unlockRecord

void unlockRecord(OIdentifiable record,
                  ODistributedRequestId requestId)

Unlocks the record previously locked through #lockRecord method.

Parameters:

record - Record to unlock

requestId - Request id

See Also:

lockRecord(ORID, ODistributedRequestId, long)

forceLockRecord

boolean forceLockRecord(ORID record,
                        ODistributedRequestId requestId)

Force the locking of a record. If the record was previously locked by a transaction (context), then that transaction is canceled.

Parameters:

record - Record to lock

requestId - Request id

dump

String dump()

unlockResourcesOfServer

void unlockResourcesOfServer(ODatabaseDocumentInternal database,
                             String serverName)

handleUnreachableNode

void handleUnreachableNode(String nodeName)

Unlocks all the record locked by node iNodeName

Parameters:

nodeName - node id

getSyncConfiguration

ODistributedSyncConfiguration getSyncConfiguration()

waitForOnline

void waitForOnline()

reEnqueue

void reEnqueue(int senderNodeId,
               long msgSequence,
               String databaseName,
               ORemoteTask payload,
               int retryCount,
               int autoRetryDelay)

processRequest

void processRequest(ODistributedRequest request,
                    boolean waitForAcceptingRequests)

registerTxContext

ODistributedTxContext registerTxContext(ODistributedRequestId reqId)

registerTxContext

ODistributedTxContext registerTxContext(ODistributedRequestId reqId,
                                        ODistributedTxContext ctx)

popTxContext

ODistributedTxContext popTxContext(ODistributedRequestId requestId)

getTxContext

ODistributedTxContext getTxContext(ODistributedRequestId requestId)

getManager

ODistributedServerManager getManager()

getDatabaseInstance

ODatabaseDocumentInternal getDatabaseInstance()

getReceivedRequests

long getReceivedRequests()

getProcessedRequests

long getProcessedRequests()

checkNodeInConfiguration

void checkNodeInConfiguration(ODistributedConfiguration cfg,
                              String serverName)

setLSN

void setLSN(String sourceNodeName,
            OLogSequenceNumber taskLastLSN,
            boolean writeLastOperation)
     throws IOException

Throws:

IOException

getDatabaseRepairer

ODistributedDatabaseRepairer getDatabaseRepairer()