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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	begin(ODatabaseDocumentInternal database, boolean local)
Set<ORecordId>	cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit(ODatabaseDocumentInternal database)
void	destroy()
List<ORID>	getLockedRids()
ODistributedRequestId	getReqId()
long	getStartedOn()
TxContextStatus	getStatus()
OTransactionInternal	getTransaction()
OTransactionId	getTransactionId()
void	lock(ORID rid)
void	lock(ORID rid, long timeout)
void	lockIndexKey(Object key)
Set<ORecordId>	rollback(ODatabaseDocumentInternal database)
void	setStatus(TxContextStatus 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,
                                    OTransactionId id)

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

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

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

getTransaction

public OTransactionInternal getTransaction()

Specified by:

getTransaction in interface ODistributedTxContext

setStatus

public void setStatus(TxContextStatus status)

getStatus

public TxContextStatus getStatus()

getLockedRids

public List<ORID> getLockedRids()

getTransactionId

public OTransactionId getTransactionId()

Specified by:

getTransactionId in interface ODistributedTxContext