Class OTransactionPhase1Task
java.lang.Object
com.orientechnologies.orient.server.distributed.task.OAbstractRemoteTask
com.orientechnologies.orient.server.distributed.impl.task.OTransactionPhase1Task
- 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
ConstructorsConstructorDescriptionOTransactionPhase1Task(List<ORecordOperation> ops, OTransactionIdPromise promise, SortedSet<OTransactionUniqueKey> uniqueIndexKeys) -
Method Summary
Modifier and TypeMethodDescriptionexecute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) static OTransactionResultPayloadexecuteTransaction(ODistributedRequestId requestId, OTransactionIdPromise id, ODatabaseDocumentDistributed database, OTransactionInternal tx, boolean isCoordinator, int retryCount) voidfinished(ODistributedDatabase distributedDatabase) voidfromStream(DataInput in, ORemoteTaskFactory factory) voidgenOps(List<ORecordOperation> ops) longintgetName()getOps()intgetRids()booleanvoidinit(OTransactionIdPromise transactionId, OTransactionInternal tx) booleanstatic Objectstatic voidmapRid(Set<ORID> set, ORecordOperation operation) static voidreadTxUniqueIndexKeys(SortedSet<OTransactionUniqueKey> uniqueIndexKeys, ORecordSerializerNetworkV37 serializer, DataInput in) voidreceived(ODistributedRequest request, ODistributedDatabase distributedDatabase) 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
getNodeSource, getResultStrategy, getSynchronousTimeout, getTotalTimeout, isNodeOnlineRequired, isUsingDatabase, setNodeSource, toString
-
Field Details
-
FACTORYID
public static final int FACTORYID- See Also:
-
-
Constructor Details
-
OTransactionPhase1Task
public OTransactionPhase1Task() -
OTransactionPhase1Task
public OTransactionPhase1Task(List<ORecordOperation> ops, OTransactionIdPromise promise, SortedSet<OTransactionUniqueKey> uniqueIndexKeys)
-
-
Method Details
-
genOps
-
getName
- Specified by:
getNamein interfaceORemoteTask
-
getQuorumType
- Specified by:
getQuorumTypein interfaceORemoteTask
-
execute
public Object execute(ODistributedRequestId requestId, OServer iServer, ODistributedServerManager iManager, ODatabaseDocumentInternal database) throws Exception - Specified by:
executein interfaceORemoteTask- Throws:
Exception
-
hasResponse
public boolean hasResponse()- Specified by:
hasResponsein interfaceORemoteTask- Overrides:
hasResponsein classOAbstractRemoteTask
-
executeTransaction
public static OTransactionResultPayload executeTransaction(ODistributedRequestId requestId, OTransactionIdPromise id, ODatabaseDocumentDistributed database, OTransactionInternal tx, boolean isCoordinator, int retryCount) -
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
-
getFactoryId
public int getFactoryId()- Specified by:
getFactoryIdin interfaceORemoteTask
-
init
-
isIdempotent
public boolean isIdempotent()- Specified by:
isIdempotentin interfaceORemoteTask- Overrides:
isIdempotentin classOAbstractRemoteTask
-
getDistributedTimeout
public long getDistributedTimeout()- Specified by:
getDistributedTimeoutin interfaceORemoteTask- Overrides:
getDistributedTimeoutin classOAbstractRemoteTask
-
getRetryCount
public int getRetryCount() -
getOperations
-
getOps
-
received
- Specified by:
receivedin interfaceORemoteTask
-
finished
- Specified by:
finishedin interfaceORemoteTask
-
getTransactionId
- Specified by:
getTransactionIdin interfaceOLockKeySource
-
getRids
- Specified by:
getRidsin interfaceOLockKeySource
-
getUniqueKeys
- Specified by:
getUniqueKeysin interfaceOLockKeySource
-
mapRid
-
mapKey
-
getPromise
-