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 and Description
protected ConcurrentHashMap<ODistributedRequestId,ODistributedTxContext>	activeTxContexts
protected String	databaseName
static String	DISTRIBUTED_SYNC_JSON_FILENAME
protected ODistributedWorker	lockThread
protected ODistributedAbstractPlugin	manager
protected ODistributedMessageServiceImpl	msgService
protected ODistributedWorker	nowaitThread
protected ODistributedSyncConfiguration	syncConfiguration
protected List<ODistributedWorker>	workerThreads

Constructor Summary

Constructors

Constructor and Description
ODistributedDatabaseImpl(OHazelcastPlugin manager, ODistributedMessageServiceImpl msgService, String iDatabaseName, ODistributedConfiguration cfg, OServer server)

Method Summary

Modifier and Type	Method and Description
protected int	calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType, Collection<String> clusterNames, ODistributedConfiguration cfg, int totalServers, int totalMasterServers, int onlineMasters, boolean checkNodesAreOnline, String localNodeName)
protected void	checkForServerOnline(ODistributedRequest iRequest)
void	checkNodeInConfiguration(ODistributedConfiguration cfg, String serverName)
void	checkReverseSync(OTransactionSequenceStatus lastState)
OTxMetadataHolder	commit(OTransactionId id)
String	dump()
void	endOperation()
boolean	exists()
ConcurrentHashMap<ODistributedRequestId,ODistributedTxContext>	getActiveTxContexts()
ODatabaseDocumentInternal	getDatabaseInstance()
String	getDatabaseName()
OSimpleLockManager<Object>	getIndexKeyLockManager()
protected Set<Integer>	getInvolvedQueuesByPartitionKeys(int[] partitionKeys)
protected String	getLocalNodeName()
ODistributedServerManager	getManager()
long	getProcessedRequests()
long	getReceivedRequests()
OSimpleLockManager<ORID>	getRecordLockManager()
ODistributedSyncConfiguration	getSyncConfiguration()
ODistributedTxContext	getTxContext(ODistributedRequestId requestId)
void	handleUnreachableNode(String nodeName) Unlocks all the record locked by node iNodeName
List<OTransactionId>	missingTransactions(OTransactionSequenceStatus lastState)
ODistributedResponseManager	newResponseManager(ODistributedRequest iRequest, Collection<String> iNodes, OCallable<Void,ODistributedResponseManager> endCallback, ORemoteTask task, Set<String> nodesConcurToTheQuorum, int availableNodes, int expectedResponses, int quorum, boolean groupByResponse, boolean waitLocalNode)
Optional<OTransactionId>	nextId()
ODistributedTxContext	popTxContext(ODistributedRequestId requestId)
protected void	processRequest(int partitionKey, ODistributedRequest request)
void	processRequest(ODistributedRequest request, boolean waitForAcceptingRequests) Distributed requests against the available workers by using one queue per worker.
void	reEnqueue(int senderNodeId, long msgSequence, String databaseName, ORemoteTask payload, int retryCount, int autoRetryDelay)
ODistributedTxContext	registerTxContext(ODistributedRequestId reqId, ODistributedTxContext ctx)
void	resume()
void	rollback(OTransactionId id)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback)
ODistributedResponse	send2Nodes(ODistributedRequest iRequest, Collection<String> iClusterNames, Collection<String> iNodes, ODistributedRequest.EXECUTION_MODE iExecutionMode, Object localResult, OCallable<Void,ODistributedRequestId> iAfterSentCallback, OCallable<Void,ODistributedResponseManager> endCallback, ODistributedResponseManagerFactory responseManagerFactory)
void	setLSN(String sourceNodeName, OLogSequenceNumber taskLastLSN, boolean updateLastOperationTimestamp)
void	setOnline()
void	shutdown()
void	startOperation()
Optional<OTransactionSequenceStatus>	status()
void	suspend()
void	unlockResourcesOfServer(ODatabaseDocumentInternal database, String serverName)
Optional<OTransactionId>	validate(OTransactionId id)
void	validateStatus(OTransactionSequenceStatus status)
void	waitDistributedIsReady()
protected boolean	waitForLocalNode(ODistributedConfiguration cfg, Collection<String> iClusterNames, Collection<String> iNodes)
void	waitForOnline()
protected ODistributedResponse	waitForResponse(ODistributedRequest iRequest, ODistributedResponseManager currentResponseMgr)
void	waitIsReady(ORemoteTask task)

Methods inherited from class java.lang.Object

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

Field Detail

DISTRIBUTED_SYNC_JSON_FILENAME

public static final String DISTRIBUTED_SYNC_JSON_FILENAME

See Also:

Constant Field Values

manager

protected final ODistributedAbstractPlugin manager

msgService

protected final ODistributedMessageServiceImpl msgService

databaseName

protected final String databaseName

syncConfiguration

protected ODistributedSyncConfiguration syncConfiguration

activeTxContexts

protected ConcurrentHashMap<ODistributedRequestId,ODistributedTxContext> activeTxContexts

workerThreads

protected final List<ODistributedWorker> workerThreads

lockThread

protected ODistributedWorker lockThread

nowaitThread

protected ODistributedWorker nowaitThread

Constructor Detail

ODistributedDatabaseImpl

public ODistributedDatabaseImpl(OHazelcastPlugin manager,
                                ODistributedMessageServiceImpl msgService,
                                String iDatabaseName,
                                ODistributedConfiguration cfg,
                                OServer server)

Method Detail

getRecordLockManager

public OSimpleLockManager<ORID> getRecordLockManager()

getIndexKeyLockManager

public OSimpleLockManager<Object> getIndexKeyLockManager()

startOperation

public void startOperation()

endOperation

public void endOperation()

waitForOnline

public void waitForOnline()

Specified by:

waitForOnline in interface ODistributedDatabase

reEnqueue

public void reEnqueue(int senderNodeId,
                      long msgSequence,
                      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

waitIsReady

public void waitIsReady(ORemoteTask task)

waitDistributedIsReady

public void waitDistributedIsReady()

getInvolvedQueuesByPartitionKeys

protected Set<Integer> getInvolvedQueuesByPartitionKeys(int[] partitionKeys)

processRequest

protected void processRequest(int partitionKey,
                              ODistributedRequest request)

send2Nodes

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

Specified by:

send2Nodes in interface ODistributedDatabase

send2Nodes

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

newResponseManager

public ODistributedResponseManager newResponseManager(ODistributedRequest iRequest,
                                                      Collection<String> iNodes,
                                                      OCallable<Void,ODistributedResponseManager> endCallback,
                                                      ORemoteTask task,
                                                      Set<String> nodesConcurToTheQuorum,
                                                      int availableNodes,
                                                      int expectedResponses,
                                                      int quorum,
                                                      boolean groupByResponse,
                                                      boolean waitLocalNode)

setOnline

public void setOnline()

Specified by:

setOnline in interface ODistributedDatabase

unlockResourcesOfServer

public void unlockResourcesOfServer(ODatabaseDocumentInternal database,
                                    String serverName)

Specified by:

unlockResourcesOfServer in interface ODistributedDatabase

validate

public Optional<OTransactionId> validate(OTransactionId id)

Specified by:

validate in interface ODistributedDatabase

commit

public OTxMetadataHolder commit(OTransactionId id)

Specified by:

commit in interface ODistributedDatabase

rollback

public void rollback(OTransactionId id)

Specified by:

rollback in interface ODistributedDatabase

registerTxContext

public ODistributedTxContext registerTxContext(ODistributedRequestId reqId,
                                               ODistributedTxContext ctx)

Specified by:

registerTxContext in interface ODistributedDatabase

nextId

public Optional<OTransactionId> nextId()

Specified by:

nextId 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()

getSyncConfiguration

public ODistributedSyncConfiguration getSyncConfiguration()

Specified by:

getSyncConfiguration in interface ODistributedDatabase

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

shutdown

public void shutdown()

checkForServerOnline

protected void checkForServerOnline(ODistributedRequest iRequest)
                             throws ODistributedException

Throws:

ODistributedException

waitForLocalNode

protected boolean waitForLocalNode(ODistributedConfiguration cfg,
                                   Collection<String> iClusterNames,
                                   Collection<String> iNodes)

calculateQuorum

protected int calculateQuorum(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType,
                              Collection<String> clusterNames,
                              ODistributedConfiguration cfg,
                              int totalServers,
                              int totalMasterServers,
                              int onlineMasters,
                              boolean checkNodesAreOnline,
                              String localNodeName)

waitForResponse

protected ODistributedResponse waitForResponse(ODistributedRequest iRequest,
                                               ODistributedResponseManager currentResponseMgr)
                                        throws InterruptedException

Throws:

InterruptedException

checkNodeInConfiguration

public void checkNodeInConfiguration(ODistributedConfiguration cfg,
                                     String serverName)

Specified by:

checkNodeInConfiguration in interface ODistributedDatabase

getLocalNodeName

protected String getLocalNodeName()

setLSN

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

Specified by:

setLSN in interface ODistributedDatabase

Throws:

IOException

suspend

public void suspend()

resume

public void resume()

dump

public String dump()

Specified by:

dump in interface ODistributedDatabase

getActiveTxContexts

public ConcurrentHashMap<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