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

• requestLock

  protected final Lock requestLock

• syncConfiguration

  protected ODistributedSyncConfiguration syncConfiguration

• lockManager

  protected ConcurrentHashMap<ORID,ODistributedRequestId> lockManager

• activeTxContexts

  protected ConcurrentHashMap<ODistributedRequestId,ODistributedTxContextImpl> activeTxContexts

• workerThreads

  protected final List<ODistributedWorker> workerThreads

• processLock

  protected volatile ReadWriteLock processLock

• status

  protected AtomicBoolean status

Constructor Detail

• ODistributedDatabaseImpl

  public ODistributedDatabaseImpl(OHazelcastPlugin manager,
                                  ODistributedMessageServiceImpl msgService,
                                  String iDatabaseName)

Method Detail

• processRequest

  public void processRequest(ODistributedRequest request)

  Distributed requests against the available workers. This guarantee the sequence of the operations against the same record cluster.

  Specified by:

  processRequest in interface ODistributedDatabase

• checkQuorumBeforeReplicate

  public int checkQuorumBeforeReplicate(OCommandDistributedReplicateRequest.QUORUM_TYPE quorumType,
                                        Collection<String> iClusterNames,
                                        Collection<String> iNodes,
                                        ODistributedConfiguration cfg)

  Specified by:

  checkQuorumBeforeReplicate 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)

  Specified by:

  send2Nodes in interface ODistributedDatabase

• setOnline

  public void setOnline()

  Specified by:

  setOnline in interface ODistributedDatabase

• lockRecord

  public ODistributedRequestId lockRecord(OIdentifiable iRecord,
                                          ODistributedRequestId iRequestId)

  Description copied from interface: ODistributedDatabase
  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.

  Specified by:

  lockRecord in interface ODistributedDatabase

  Parameters:

  iRecord - Record to lock

  iRequestId - Request id

  Returns:

  true if the lock succeed, otherwise false

  See Also:

  ODistributedDatabase.unlockRecord(OIdentifiable, ODistributedRequestId)

• unlockRecord

  public void unlockRecord(OIdentifiable iRecord,
                           ODistributedRequestId requestId)

  Description copied from interface: ODistributedDatabase
  Unlocks the record previously locked through #lockRecord method.

  Specified by:

  unlockRecord in interface ODistributedDatabase

  See Also:

  ODistributedDatabase.lockRecord(OIdentifiable, ODistributedRequestId)

• registerTxContext

  public ODistributedTxContext registerTxContext(ODistributedRequestId reqId)

  Specified by:

  registerTxContext in interface ODistributedDatabase

• popTxContext

  public ODistributedTxContext popTxContext(ODistributedRequestId requestId)

  Specified by:

  popTxContext 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(int iNodeId)

  Description copied from interface: ODistributedDatabase
  Unlocks all the record locked by node iNodeName

  Specified by:

  handleUnreachableNode in interface ODistributedDatabase

  Parameters:

  iNodeId - node id

• getDatabaseName

  public String getDatabaseName()

  Specified by:

  getDatabaseName in interface ODistributedDatabase

• getDatabaseInstance

  public ODatabaseDocumentTx getDatabaseInstance()

  Specified by:

  getDatabaseInstance 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 allAvailableNodes,
                                int masterAvailableNodes,
                                boolean checkNodesAreOnline)

• waitForResponse

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

  Throws:

  InterruptedException

• checkLocalNodeInConfiguration

  protected void checkLocalNodeInConfiguration()

• getLocalNodeName

  protected String getLocalNodeName()