Class ODistributedTxCoordinator
java.lang.Object
com.orientechnologies.orient.server.distributed.impl.ODistributedTxCoordinator
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionODistributedTxCoordinator(OStorage storage, ODistributedServerManager manager, ODistributedDatabase iDDatabase, ODistributedMessageService messageService, int nodeId, String nodeName, int maxRetries, int retryDelay) -
Method Summary
Modifier and TypeMethodDescriptionvoidcommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, Set<String> clusters) protected OTransactionPhase1TaskcreateTxPhase1Task(OTransactionIdPromise id, OTransactionInternal transaction) voidsetResponseManager(ODistributedTxResponseManager responseManager) This is to be used only for testing!voidtryCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionIdPromise txId, ODistributedRequestId requestId)
-
Field Details
-
LOCAL_RESULT_SUCCESS
- See Also:
-
-
Constructor Details
-
ODistributedTxCoordinator
public ODistributedTxCoordinator(OStorage storage, ODistributedServerManager manager, ODistributedDatabase iDDatabase, ODistributedMessageService messageService, int nodeId, String nodeName, int maxRetries, int retryDelay)
-
-
Method Details
-
commit
public void commit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, Set<String> clusters) -
tryCommit
public void tryCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionIdPromise txId, ODistributedRequestId requestId) -
createTxPhase1Task
protected OTransactionPhase1Task createTxPhase1Task(OTransactionIdPromise id, OTransactionInternal transaction) -
setResponseManager
This is to be used only for testing!
-