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--orientechnologies.com)

Constructor Summary

Constructors

Constructor and Description
ODistributedTxContextImpl(ODistributedDatabase iDatabase, ODistributedRequestId iRequestId)

Method Summary

Modifier and Type	Method and Description
void	addUndoTask(ORemoteTask undoTask)
Set<ORecordId>	cancel(ODistributedServerManager dManager, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit()
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()
boolean	isCanceled()
void	lock(ORID rid)
void	lock(ORID rid, long timeout)
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

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()

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)