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
void	checkNodeInConfiguration(ODistributedConfiguration cfg, String serverName)
String	dump()
boolean	forceLockRecord(com.orientechnologies.orient.core.id.ORID record, ODistributedRequestId requestId) Force the locking of a record.
com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx	getDatabaseInstance()
String	getDatabaseName()
ODistributedDatabaseRepairer	getDatabaseRepairer()
ODistributedServerManager	getManager()
long	getProcessedRequests()
long	getReceivedRequests()
com.orientechnologies.orient.core.storage.ORawBuffer	getRecordIfLocked(com.orientechnologies.orient.core.id.ORID iRecord) Returns the locked record for read-only purpose.
ODistributedSyncConfiguration	getSyncConfiguration()
void	handleUnreachableNode(String nodeName) Unlocks all the record locked by node iNodeName
boolean	lockRecord(com.orientechnologies.orient.core.id.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)
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, com.orientechnologies.common.util.OCallable<Void,ODistributedResponseManager> endCallback)
void	setLSN(String sourceNodeName, com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber taskLastLSN, boolean writeLastOperation)
void	setOnline()
void	unlockRecord(com.orientechnologies.orient.core.db.record.OIdentifiable record, ODistributedRequestId requestId) Unlocks the record previously locked through #lockRecord method.
void	unlockResourcesOfServer(com.orientechnologies.orient.core.db.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,
                                com.orientechnologies.common.util.OCallable<Void,ODistributedRequestId> iAfterSentCallback,
                                com.orientechnologies.common.util.OCallable<Void,ODistributedResponseManager> endCallback)

setOnline

void setOnline()

getRecordIfLocked

com.orientechnologies.orient.core.storage.ORawBuffer getRecordIfLocked(com.orientechnologies.orient.core.id.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.

lockRecord

boolean lockRecord(com.orientechnologies.orient.core.id.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(com.orientechnologies.orient.core.db.record.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(com.orientechnologies.orient.core.id.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(com.orientechnologies.orient.core.db.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()

processRequest

void processRequest(ODistributedRequest request,
                    boolean waitForAcceptingRequests)

registerTxContext

ODistributedTxContext registerTxContext(ODistributedRequestId reqId)

popTxContext

ODistributedTxContext popTxContext(ODistributedRequestId requestId)

getManager

ODistributedServerManager getManager()

getDatabaseInstance

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

getReceivedRequests

long getReceivedRequests()

getProcessedRequests

long getProcessedRequests()

checkNodeInConfiguration

void checkNodeInConfiguration(ODistributedConfiguration cfg,
                              String serverName)

setLSN

void setLSN(String sourceNodeName,
            com.orientechnologies.orient.core.storage.impl.local.paginated.wal.OLogSequenceNumber taskLastLSN,
            boolean writeLastOperation)
     throws IOException

Throws:

IOException

getDatabaseRepairer

ODistributedDatabaseRepairer getDatabaseRepairer()