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
static final String	DISTRIBUTED_SYNC_JSON_FILENAME
protected final ODistributedPlugin	manager

Constructor Summary

Constructors

Constructor	Description
ODistributedDatabaseImpl(OrientDBDistributed context, ODistributedPlugin manager, String iDatabaseName)

Method Summary

Modifier and Type	Method	Description
void	checkReverseSync(OTransactionSequenceStatus lastState)
void	checkTxTimeout()
void	clearLastValidBackup()
OTxMetadataHolder	commit(OTransactionIdPromise id)
String	dump()
void	endOperation()
boolean	exists()
void	fillStatus()
void	freezeStatus()
Map<ODistributedRequestId,ODistributedTxContext>	getActiveTxContexts()
Set<String>	getAvailableNodesButLocal(ODatabaseSession database)
ODatabaseDocumentInternal	getDatabaseInstance()
String	getDatabaseName()
OTxPromiseManager<Object>	getIndexKeyPromiseManager()
OSyncSource	getLastValidBackup()
protected String	getLocalNodeName()
ODistributedServerManager	getManager()
int	getPoolSize(ExecutorService service)
long	getProcessedRequests()
long	getReceivedRequests()
OTxPromiseManager<ORID>	getRecordPromiseManager()
ODistributedTxContext	getTxContext(ODistributedRequestId requestId)
void	handleUnreachableNode(String nodeName)	Unlocks all the record locked by node iNodeName
void	incSentRequest()
void	initFirstOpen(ODatabaseDocumentInternal session)
void	initProfilerHooks()
List<OLockGuard>	localLock(OLockKeySource keySource)
void	localUnlock(List<OLockGuard> guards)
List<OTransactionId>	missingTransactions(OTransactionSequenceStatus lastState)
Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>>	nextDDLId()
Optional<OTransactionIdPromise>	nextId()
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	resetLastValidBackup()
void	resume()
void	rollback(OTransactionIdPromise id)
static boolean	sendResponseBack(Object current, ODistributedServerManager manager, ODistributedRequestId iRequestId, Object responsePayload)
void	setLastValidBackup(OSyncSource lastValidBackup)
void	setOnline()
void	shutdown()
void	shutdown(boolean wait)
void	startOperation()
Optional<OTransactionSequenceStatus>	status()
void	suspend()
void	trackTransactions(OTransactionId id)
void	unlockResourcesOfServer(ODatabaseDocumentInternal database, String serverName)
void	untrackTransactions(OTransactionId id)
ValidationResult	validate(OTransactionIdPromise id)
void	validateStatus(OTransactionSequenceStatus status)
void	waitDistributedIsReady()
void	waitForOnline()
void	waitIsReady(ORemoteTask task)

Methods inherited from class java.lang.Object

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

Field Details

DISTRIBUTED_SYNC_JSON_FILENAME

public static final String DISTRIBUTED_SYNC_JSON_FILENAME

See Also:

• Constant Field Values

manager

protected final ODistributedPlugin manager

databaseName

protected final String databaseName

activeTxContexts

protected Map<ODistributedRequestId,ODistributedTxContext> activeTxContexts

Constructor Details

ODistributedDatabaseImpl

public ODistributedDatabaseImpl(OrientDBDistributed context,
 ODistributedPlugin manager,
 String iDatabaseName)

Method Details

initProfilerHooks

public void initProfilerHooks()

sendResponseBack

public static boolean sendResponseBack(Object current,
 ODistributedServerManager manager,
 ODistributedRequestId iRequestId,
 Object responsePayload)

getPoolSize

public int getPoolSize(ExecutorService service)

getRecordPromiseManager

public OTxPromiseManager<ORID> getRecordPromiseManager()

getIndexKeyPromiseManager

public OTxPromiseManager<Object> getIndexKeyPromiseManager()

startOperation

public void startOperation()

endOperation

public void endOperation()

waitForOnline

public void waitForOnline()

Specified by:

waitForOnline 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

fillStatus

public void fillStatus()

Specified by:

fillStatus in interface ODistributedDatabase

unlockResourcesOfServer

public void unlockResourcesOfServer(ODatabaseDocumentInternal database,
 String serverName)

Specified by:

unlockResourcesOfServer in interface ODistributedDatabase

validate

public ValidationResult validate(OTransactionIdPromise id)

Specified by:

validate in interface ODistributedDatabase

commit

public OTxMetadataHolder commit(OTransactionIdPromise id)

Specified by:

commit in interface ODistributedDatabase

rollback

public void rollback(OTransactionIdPromise id)

Specified by:

rollback in interface ODistributedDatabase

registerTxContext

public ODistributedTxContext registerTxContext(ODistributedRequestId reqId,
 ODistributedTxContext ctx)

Specified by:

registerTxContext in interface ODistributedDatabase

nextId

public Optional<OTransactionIdPromise> nextId()

Specified by:

nextId in interface ODistributedDatabase

nextDDLId

public Optional<ORawPair<OTransactionIdPromise,OTransactionIdPromise>> nextDDLId()

Specified by:

nextDDLId in interface ODistributedDatabase

missingTransactions

public List<OTransactionId> missingTransactions(OTransactionSequenceStatus lastState)

Specified by:

missingTransactions 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

getManager

public ODistributedServerManager getManager()

Specified by:

getManager in interface ODistributedDatabase

exists

public boolean exists()

handleUnreachableNode

public void handleUnreachableNode(String nodeName)

Description copied from interface: ODistributedDatabase

Unlocks all the record locked by node iNodeName

Specified by:

handleUnreachableNode in interface ODistributedDatabase

Parameters:

nodeName - node id

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 void suspend()

resume

public void resume()

dump

public String dump()

Specified by:

dump in interface ODistributedDatabase

getActiveTxContexts

public Map<ODistributedRequestId,ODistributedTxContext> getActiveTxContexts()

validateStatus

public void validateStatus(OTransactionSequenceStatus status)

Specified by:

validateStatus in interface ODistributedDatabase

status

public Optional<OTransactionSequenceStatus> status()

Specified by:

status in interface ODistributedDatabase

checkReverseSync

public void checkReverseSync(OTransactionSequenceStatus lastState)

Specified by:

checkReverseSync in interface ODistributedDatabase

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)