com.orientechnologies.orient.server.distributed.impl.task

Class OTxTask

java.lang.Object

com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

com.orientechnologies.orient.server.distributed.impl.task.OAbstract2pcTask

com.orientechnologies.orient.server.distributed.impl.task.OTxTask

All Implemented Interfaces:

ORemoteTask

Direct Known Subclasses:

ORepairClusterTask, ORepairRecordsTask

public class OTxTask
extends OAbstract2pcTask

Distributed transaction task.

Author:

Luca Garulli (l.garulli--at--orientechnologies.com)

Nested Class Summary

Nested classes/interfaces inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask

ORemoteTask.RESULT_STRATEGY

Field Summary

Fields

Modifier and Type	Field and Description
static int	FACTORYID

Fields inherited from class com.orientechnologies.orient.server.distributed.impl.task.OAbstract2pcTask

localUndoTasks, NON_LOCAL_CLUSTER, result, serialVersionUID, tasks

Fields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

lastLSN

Fields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

ALL, ANY, FAST_NOLOCK, LOCK, nodeSource

Constructor Summary

Constructors

Constructor and Description
OTxTask()

Method Summary

Modifier and Type	Method and Description
Object	execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
int	getFactoryId()
List<ORecordId>	getInvolvedRecords()
String	getName()
protected long	getRecordLock()

Methods inherited from class com.orientechnologies.orient.server.distributed.impl.task.OAbstract2pcTask

add, fromStream, getDistributedTimeout, getFixTask, getPartitionKey, getQuorumType, getTasks, getUndoTask, isIdempotent, setLastLSN, setLocalUndoTasks, setNodeSource, toStream, toString

Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractReplicatedTask

getLastLSN

Methods inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask

checkIsValid, getNodeSource, getResultStrategy, getSynchronousTimeout, getTotalTimeout, hasResponse, isNodeOnlineRequired, isUsingDatabase

Methods inherited from class java.lang.Object

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

Field Detail

FACTORYID

public static final int FACTORYID

See Also:

Constant Field Values

Constructor Detail

OTxTask

public OTxTask()

Method Detail

execute

public Object execute(ODistributedRequestId requestId,
                      OServer iServer,
                      ODistributedServerManager iManager,
                      ODatabaseDocumentInternal database)
               throws Exception

Specified by:

execute in interface ORemoteTask

Specified by:

execute in class OAbstractRemoteTask

Throws:

Exception

getRecordLock

protected long getRecordLock()

getName

public String getName()

Specified by:

getName in interface ORemoteTask

Specified by:

getName in class OAbstractRemoteTask

getFactoryId

public int getFactoryId()

getInvolvedRecords

public List<ORecordId> getInvolvedRecords()