com.orientechnologies.orient.server.distributed.impl

Class ONewDistributedTxContextImpl

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.ONewDistributedTxContextImpl

All Implemented Interfaces:

ODistributedTxContext

public class ONewDistributedTxContextImpl
extends Object
implements ODistributedTxContext

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ONewDistributedTxContextImpl.Status

Constructor Summary

Constructors

Constructor and Description
ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared, ODistributedRequestId reqId, OTransactionInternal tx)

Method Summary

Modifier and Type	Method and Description
void	addUndoTask(ORemoteTask undoTask)
void	begin(ODatabaseDocumentInternal database, boolean local)
Set<ORecordId>	cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit(ODatabaseDocumentInternal database)
void	destroy()
void	fix(ODatabaseDocumentInternal database, List<ORemoteTask> fixTasks)
List<Object>	getLockedKeys()
List<ORID>	getLockedRids()
ODistributedRequestId	getReqId()
long	getStartedOn()
ONewDistributedTxContextImpl.Status	getStatus()
OTransactionInternal	getTransaction()
boolean	isCanceled()
void	lock(ORID rid)
void	lock(ORID rid, long timeout)
void	lockIndexKey(Object key)
Set<ORecordId>	rollback(ODatabaseDocumentInternal database)
void	setStatus(ONewDistributedTxContextImpl.Status status)
void	unlock()

Methods inherited from class java.lang.Object

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

Constructor Detail

ONewDistributedTxContextImpl

public ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared,
                                    ODistributedRequestId reqId,
                                    OTransactionInternal tx)

Method Detail

lockIndexKey

public void lockIndexKey(Object key)

Specified by:

lockIndexKey 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

addUndoTask

public void addUndoTask(ORemoteTask undoTask)

Specified by:

addUndoTask in interface ODistributedTxContext

getReqId

public ODistributedRequestId getReqId()

Specified by:

getReqId in interface ODistributedTxContext

begin

public void begin(ODatabaseDocumentInternal database,
                  boolean local)

Specified by:

begin 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

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

cancel

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

Specified by:

cancel in interface ODistributedTxContext

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface ODistributedTxContext

getTransaction

public OTransactionInternal getTransaction()

Specified by:

getTransaction in interface ODistributedTxContext

setStatus

public void setStatus(ONewDistributedTxContextImpl.Status status)

getStatus

public ONewDistributedTxContextImpl.Status getStatus()

getLockedRids

public List<ORID> getLockedRids()

getLockedKeys

public List<Object> getLockedKeys()