Method Detail

• getDatabaseName

  String getDatabaseName()

• send2Nodes

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

• setOnline

  void setOnline()

• checkQuorumBeforeReplicate

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

• lockRecord

  ODistributedRequestId lockRecord(OIdentifiable iRecord,
                                   ODistributedRequestId iRequestId)

  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:

  iRecord - Record to lock

  iRequestId - Request id

  Returns:

  true if the lock succeed, otherwise false

  See Also:

  unlockRecord(OIdentifiable, ODistributedRequestId)

• unlockRecord

  void unlockRecord(OIdentifiable iRecord,
                    ODistributedRequestId requestId)

  Unlocks the record previously locked through #lockRecord method.

  Parameters:

  iRecord -

  requestId -

  See Also:

  lockRecord(OIdentifiable, ODistributedRequestId)

• handleUnreachableNode

  void handleUnreachableNode(int iNodeId)

  Unlocks all the record locked by node iNodeName

  Parameters:

  iNodeId - node id

• getSyncConfiguration

  ODistributedSyncConfiguration getSyncConfiguration()

• processRequest

  void processRequest(ODistributedRequest request)

• registerTxContext

  ODistributedTxContext registerTxContext(ODistributedRequestId reqId)

• popTxContext

  ODistributedTxContext popTxContext(ODistributedRequestId requestId)

• getManager

  ODistributedServerManager getManager()

• getDatabaseInstance

  ODatabaseDocumentTx getDatabaseInstance()