Package com.orientechnologies.orient.server.distributed.impl

Class ODistributedDatabaseImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedDatabaseImpl

All Implemented Interfaces:

ODistributedDatabase

public class ODistributedDatabaseImpl
extends Object
implements ODistributedDatabase

Distributed database implementation. There is one instance per database. Each node creates own instance to talk with each others.

Author:

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

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<ODistributedRequestId,ODistributedTxContext>	activeTxContexts
protected final String	databaseName

Constructor Summary

Constructors

Constructor	Description
ODistributedDatabaseImpl(OrientDBDistributed context, OStorage storage)

Method Summary

Modifier and Type	Method	Description
void	checkTxTimeout()
void	clearLastValidBackup()
String	dump()
void	endOperation()
static void	executeNoDb(ODistributedRequest request, OrientDBDistributed ctx)
boolean	exists()
void	freezeStatus()
Map<ODistributedRequestId,ODistributedTxContext>	getActiveTxContexts()
Set<String>	getAvailableNodesButLocal(ODatabaseSession database)
OrientDBDistributed	getContext()
ODatabaseDocumentInternal	getDatabaseInstance()
String	getDatabaseName()
OTxPromiseManager<Object>	getIndexKeyPromiseManager()
OSyncSource	getLastValidBackup()
protected String	getLocalNodeName()
int	getPoolSize(ExecutorService service)
long	getProcessedRequests()
long	getReceivedRequests()
OTxPromiseManager<ORID>	getRecordPromiseManager()
ODistributedTxContext	getTxContext(ODistributedRequestId requestId)
void	incSentRequest()
void	initFirstOpen(ODatabaseDocumentInternal session)
void	initProfilerHooks()
List<OLockGuard>	localLock(OLockKeySource keySource)
void	localUnlock(List<OLockGuard> guards)
void	onDropShutdown()
ODistributedTxContext	popTxContext(ODistributedRequestId requestId)
void	processRequest(ODistributedRequest request, boolean waitForAcceptingRequests)	Distributed requests against the available workers by using one queue per worker.
void	reEnqueue(ODistributedRequestId requestId, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
void	releaseStatus()
void	removeProfilerHook()
void	removeRunning(List<OTransactionId> res)
void	resetLastValidBackup()
void	resume()
static boolean	sendResponseBack(ODistributedRequestId iRequestId, Object responsePayload, OrientDBDistributed ctx)
void	setLastValidBackup(OSyncSource lastValidBackup)
void	setOnline()
void	shutdown()
void	shutdown(boolean wait)
void	startOperation()
Future<Void>	suspend()
void	trackTransactions(OTransactionId id)
void	untrackTransactions(OTransactionId id)
void	waitDistributedIsReady()
void	waitIsReady(ORemoteTask task)

Methods inherited from class java.lang.Object

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

Field Details

databaseName

protected final String databaseName

activeTxContexts

protected Map<ODistributedRequestId,ODistributedTxContext> activeTxContexts

Constructor Details

ODistributedDatabaseImpl

public ODistributedDatabaseImpl(OrientDBDistributed context,
 OStorage storage)

Method Details

initProfilerHooks

public void initProfilerHooks()

executeNoDb

public static void executeNoDb(ODistributedRequest request,
 OrientDBDistributed ctx)

sendResponseBack

public static boolean sendResponseBack(ODistributedRequestId iRequestId,
 Object responsePayload,
 OrientDBDistributed ctx)

getPoolSize

public int getPoolSize(ExecutorService service)

getRecordPromiseManager

public OTxPromiseManager<ORID> getRecordPromiseManager()

getIndexKeyPromiseManager

public OTxPromiseManager<Object> getIndexKeyPromiseManager()

startOperation

public void startOperation()

Specified by:

startOperation in interface ODistributedDatabase

endOperation

public void endOperation()

Specified by:

endOperation in interface ODistributedDatabase

reEnqueue

public void reEnqueue(ODistributedRequestId requestId,
 String databaseName,
 ORemoteTask payload,
 int retryCount,
 int autoRetryDelay)

Specified by:

reEnqueue in interface ODistributedDatabase

processRequest

public void processRequest(ODistributedRequest request,
 boolean waitForAcceptingRequests)

Distributed requests against the available workers by using one queue per worker. This guarantee the sequence of the operations against the same record cluster.

Specified by:

processRequest in interface ODistributedDatabase

trackTransactions

public void trackTransactions(OTransactionId id)

untrackTransactions

public void untrackTransactions(OTransactionId id)

waitIsReady

public void waitIsReady(ORemoteTask task)

waitDistributedIsReady

public void waitDistributedIsReady()

setOnline

public void setOnline()

Specified by:

setOnline in interface ODistributedDatabase

registerTxContext

public ODistributedTxContext registerTxContext(ODistributedRequestId reqId,
 ODistributedTxContext ctx)

Specified by:

registerTxContext in interface ODistributedDatabase

popTxContext

public ODistributedTxContext popTxContext(ODistributedRequestId requestId)

Specified by:

popTxContext in interface ODistributedDatabase

getTxContext

public ODistributedTxContext getTxContext(ODistributedRequestId requestId)

Specified by:

getTxContext in interface ODistributedDatabase

exists

public boolean exists()

getDatabaseName

public String getDatabaseName()

Specified by:

getDatabaseName in interface ODistributedDatabase

getDatabaseInstance

public ODatabaseDocumentInternal getDatabaseInstance()

Specified by:

getDatabaseInstance in interface ODistributedDatabase

getReceivedRequests

public long getReceivedRequests()

Specified by:

getReceivedRequests in interface ODistributedDatabase

getProcessedRequests

public long getProcessedRequests()

Specified by:

getProcessedRequests in interface ODistributedDatabase

onDropShutdown

public void onDropShutdown()

shutdown

public void shutdown()

shutdown

public void shutdown(boolean wait)

removeProfilerHook

public void removeProfilerHook()

initFirstOpen

public void initFirstOpen(ODatabaseDocumentInternal session)

getLocalNodeName

protected String getLocalNodeName()

checkTxTimeout

public void checkTxTimeout()

suspend

public Future<Void> suspend()

resume

public void resume()

dump

public String dump()

Specified by:

dump in interface ODistributedDatabase

getActiveTxContexts

public Map<ODistributedRequestId,ODistributedTxContext> getActiveTxContexts()

localLock

public List<OLockGuard> localLock(OLockKeySource keySource)

localUnlock

public void localUnlock(List<OLockGuard> guards)

getLastValidBackup

public OSyncSource getLastValidBackup()

setLastValidBackup

public void setLastValidBackup(OSyncSource lastValidBackup)

resetLastValidBackup

public void resetLastValidBackup()

clearLastValidBackup

public void clearLastValidBackup()

freezeStatus

public void freezeStatus()

releaseStatus

public void releaseStatus()

incSentRequest

public void incSentRequest()

getAvailableNodesButLocal

public Set<String> getAvailableNodesButLocal(ODatabaseSession database)

getContext

public OrientDBDistributed getContext()

Specified by:

getContext in interface ODistributedDatabase

removeRunning

public void removeRunning(List<OTransactionId> res)