Package com.orientechnologies.orient.server.distributed.impl

Class ODistributedTxCoordinator

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedTxCoordinator

public class ODistributedTxCoordinator
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LOCAL_RESULT_SUCCESS

Constructor Summary

Constructors

Constructor	Description
ODistributedTxCoordinator(OStorage storage, ODistributedServerManager manager, ODistributedDatabase iDDatabase, ODistributedMessageService messageService, int nodeId, String nodeName, int maxRetries, int retryDelay)

Method Summary

Modifier and Type	Method	Description
void	commit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, Set<String> clusters)
protected OTransactionPhase1Task	createTxPhase1Task(OTransactionIdPromise id, OTransactionInternal transaction)
void	setResponseManager(ODistributedTxResponseManager responseManager)	This is to be used only for testing!
void	tryCommit(ODatabaseDocumentDistributed database, OTransactionInternal iTx, OTransactionIdPromise txId, ODistributedRequestId requestId)

Methods inherited from class java.lang.Object

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

Field Details

LOCAL_RESULT_SUCCESS

public static final String LOCAL_RESULT_SUCCESS

See Also:

• Constant Field Values

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

public void setResponseManager(ODistributedTxResponseManager responseManager)

This is to be used only for testing!