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

Class OTransactionPhase2Task

java.lang.Object

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

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

All Implemented Interfaces:

OLockKeySource, ORemoteTask

public class OTransactionPhase2Task
extends OAbstractRemoteTask
implements OLockKeySource

Author:

Luigi Dell'Aquila (l.dellaquila - at - orientdb.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	Description
static final int	FACTORYID

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

nodeSource

Constructor Summary

Constructors

Constructor	Description
OTransactionPhase2Task()
OTransactionPhase2Task(ODistributedRequestId firstPhaseId, boolean success, SortedSet<ORID> rids, SortedSet<OTransactionUniqueKey> uniqueIndexKeys, OTransactionIdPromise transactionId)

Method Summary

Modifier and Type	Method	Description
Object	execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database)
void	fromStream(DataInput in, ORemoteTaskFactory factory)
int	getFactoryId()
ODistributedRequestId	getFirstPhaseId()
String	getName()
OCommandDistributedReplicateRequest.QUORUM_TYPE	getQuorumType()
int	getRetryCount()
SortedSet<ORID>	getRids()
OTransactionId	getTransactionId()
SortedSet<OTransactionUniqueKey>	getUniqueKeys()
boolean	hasResponse()
boolean	isIdempotent()
static void	readTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys, ORecordSerializerNetworkV37 serializer, DataInput in)
void	toStream(DataOutput out)
static void	writeTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys, ORecordSerializerNetworkV37 serializer, DataOutput out, OSerializationContext ctx)

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

getDistributedTimeout, getNodeSource, getResultStrategy, getSynchronousTimeout, getTotalTimeout, isNodeOnlineRequired, isUsingDatabase, setNodeSource, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask

finished, received

Field Details

FACTORYID

public static final int FACTORYID

See Also:

• Constant Field Values

Constructor Details

OTransactionPhase2Task

public OTransactionPhase2Task(ODistributedRequestId firstPhaseId,
 boolean success,
 SortedSet<ORID> rids,
 SortedSet<OTransactionUniqueKey> uniqueIndexKeys,
 OTransactionIdPromise transactionId)

OTransactionPhase2Task

public OTransactionPhase2Task()

Method Details

getName

public String getName()

Specified by:

getName in interface ORemoteTask

getQuorumType

public OCommandDistributedReplicateRequest.QUORUM_TYPE getQuorumType()

Specified by:

getQuorumType in interface ORemoteTask

fromStream

public void fromStream(DataInput in,
 ORemoteTaskFactory factory)
                throws IOException

Specified by:

fromStream in interface ORemoteTask

Overrides:

fromStream in class OAbstractRemoteTask

Throws:

IOException

readTxUniqueIndexKeys

public static void readTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys,
 ORecordSerializerNetworkV37 serializer,
 DataInput in)
                                  throws IOException

Throws:

IOException

toStream

public void toStream(DataOutput out)
              throws IOException

Specified by:

toStream in interface ORemoteTask

Overrides:

toStream in class OAbstractRemoteTask

Throws:

IOException

writeTxUniqueIndexKeys

public static void writeTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys,
 ORecordSerializerNetworkV37 serializer,
 DataOutput out,
 OSerializationContext ctx)
                                   throws IOException

Throws:

IOException

execute

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

Specified by:

execute in interface ORemoteTask

Throws:

Exception

getRetryCount

public int getRetryCount()

getFirstPhaseId

public ODistributedRequestId getFirstPhaseId()

isIdempotent

public boolean isIdempotent()

Specified by:

isIdempotent in interface ORemoteTask

Overrides:

isIdempotent in class OAbstractRemoteTask

hasResponse

public boolean hasResponse()

Specified by:

hasResponse in interface ORemoteTask

Overrides:

hasResponse in class OAbstractRemoteTask

getFactoryId

public int getFactoryId()

Specified by:

getFactoryId in interface ORemoteTask

getRids

public SortedSet<ORID> getRids()

Specified by:

getRids in interface OLockKeySource

getUniqueKeys

public SortedSet<OTransactionUniqueKey> getUniqueKeys()

Specified by:

getUniqueKeys in interface OLockKeySource

getTransactionId

public OTransactionId getTransactionId()

Specified by:

getTransactionId in interface OLockKeySource