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
- 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
FieldsFields inherited from class com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
nodeSource -
Constructor Summary
ConstructorsConstructorDescriptionOTransactionPhase2Task(ODistributedRequestId firstPhaseId, boolean success, SortedSet<ORID> rids, SortedSet<OTransactionUniqueKey> uniqueIndexKeys, OTransactionIdPromise transactionId) -
Method Summary
Modifier and TypeMethodDescriptionexecute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) voidfromStream(DataInput in, ORemoteTaskFactory factory) intgetName()intgetRids()booleanbooleanstatic voidreadTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys, ORecordSerializerNetworkV37 serializer, DataInput in) voidtoStream(DataOutput out) static voidwriteTxUniqueIndexKeys(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, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.orientechnologies.orient.server.distributed.task.ORemoteTask
finished, received
-
Field Details
-
FACTORYID
public static final int FACTORYID- See Also:
-
-
Constructor Details
-
OTransactionPhase2Task
public OTransactionPhase2Task(ODistributedRequestId firstPhaseId, boolean success, SortedSet<ORID> rids, SortedSet<OTransactionUniqueKey> uniqueIndexKeys, OTransactionIdPromise transactionId) -
OTransactionPhase2Task
public OTransactionPhase2Task()
-
-
Method Details
-
getName
- Specified by:
getNamein interfaceORemoteTask
-
getQuorumType
- Specified by:
getQuorumTypein interfaceORemoteTask
-
fromStream
- Specified by:
fromStreamin interfaceORemoteTask- Overrides:
fromStreamin classOAbstractRemoteTask- Throws:
IOException
-
readTxUniqueIndexKeys
public static void readTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys, ORecordSerializerNetworkV37 serializer, DataInput in) throws IOException - Throws:
IOException
-
toStream
- Specified by:
toStreamin interfaceORemoteTask- Overrides:
toStreamin classOAbstractRemoteTask- 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:
executein interfaceORemoteTask- Throws:
Exception
-
getRetryCount
public int getRetryCount() -
getFirstPhaseId
-
isIdempotent
public boolean isIdempotent()- Specified by:
isIdempotentin interfaceORemoteTask- Overrides:
isIdempotentin classOAbstractRemoteTask
-
hasResponse
public boolean hasResponse()- Specified by:
hasResponsein interfaceORemoteTask- Overrides:
hasResponsein classOAbstractRemoteTask
-
getFactoryId
public int getFactoryId()- Specified by:
getFactoryIdin interfaceORemoteTask
-
getRids
- Specified by:
getRidsin interfaceOLockKeySource
-
getUniqueKeys
- Specified by:
getUniqueKeysin interfaceOLockKeySource
-
getTransactionId
- Specified by:
getTransactionIdin interfaceOLockKeySource
-