com.orientechnologies.orient.server.distributed.impl

Class ODistributedTxContextImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ODistributedTxContextImpl

All Implemented Interfaces:

ODistributedTxContext

public class ODistributedTxContextImpl
extends Object
implements ODistributedTxContext

Stores a transaction request that is waiting for the "completed" message (2-phase) by the leader node. Objects of this class are immutable.

Author:

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

Constructor Summary

Constructors

Constructor and Description
ODistributedTxContextImpl(ODistributedDatabase iDatabase, ODistributedRequestId iRequestId)

Method Summary

Modifier and Type	Method and Description
void	addUndoTask(ORemoteTask undoTask)
void	begin(ODatabaseDocumentInternal distributed, boolean local)
Set<ORecordId>	cancel(ODistributedServerManager dManager, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit(ODatabaseDocumentInternal database)
void	destroy()
static void	executeFix(Object me, ODistributedTxContext context, ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks, ODistributedRequestId requestId, ODistributedDatabase ddb)
void	fix(ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks)
ODistributedRequestId	getReqId()
long	getStartedOn()
OTransactionOptimistic	getTransaction()
boolean	isCanceled()
void	lock(ORID rid)
void	lock(ORID rid, long timeout)
void	lockIndexKey(Object rid)
Set<ORecordId>	rollback(ODatabaseDocumentInternal database)
String	toString()
void	unlock()

Methods inherited from class java.lang.Object

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

Constructor Detail

ODistributedTxContextImpl

public ODistributedTxContextImpl(ODistributedDatabase iDatabase,
                                 ODistributedRequestId iRequestId)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

cancel

public Set<ORecordId> cancel(ODistributedServerManager dManager,
                             ODatabaseDocumentInternal database)

Specified by:

cancel in interface ODistributedTxContext

lock

public void lock(ORID rid)

Specified by:

lock in interface ODistributedTxContext

lock

public void lock(ORID rid,
                 long timeout)

Specified by:

lock in interface ODistributedTxContext

lockIndexKey

public void lockIndexKey(Object rid)

Specified by:

lockIndexKey in interface ODistributedTxContext

getReqId

public ODistributedRequestId getReqId()

Specified by:

getReqId in interface ODistributedTxContext

addUndoTask

public void addUndoTask(ORemoteTask undoTask)

Specified by:

addUndoTask in interface ODistributedTxContext

commit

public void commit(ODatabaseDocumentInternal database)

Specified by:

commit in interface ODistributedTxContext

fix

public void fix(ODatabaseDocumentInternal database,
                List<ORemoteTask> fixTasks)

Specified by:

fix in interface ODistributedTxContext

rollback

public Set<ORecordId> rollback(ODatabaseDocumentInternal database)

Specified by:

rollback in interface ODistributedTxContext

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface ODistributedTxContext

destroy

public void destroy()

Specified by:

destroy in interface ODistributedTxContext

clearUndo

public void clearUndo()

Specified by:

clearUndo in interface ODistributedTxContext

unlock

public void unlock()

Specified by:

unlock in interface ODistributedTxContext

getStartedOn

public long getStartedOn()

Specified by:

getStartedOn in interface ODistributedTxContext

executeFix

public static void executeFix(Object me,
                              ODistributedTxContext context,
                              ODatabaseDocumentInternal database,
                              List<ORemoteTask> fixTasks,
                              ODistributedRequestId requestId,
                              ODistributedDatabase ddb)

getTransaction

public OTransactionOptimistic getTransaction()

Specified by:

getTransaction in interface ODistributedTxContext

begin

public void begin(ODatabaseDocumentInternal distributed,
                  boolean local)

Specified by:

begin in interface ODistributedTxContext