Package 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	Description
ONewDistributedTxContextImpl(ODistributedDatabaseImpl shared, ODistributedRequestId reqId, OTransactionInternal tx, OTransactionIdPromise id)

Method Summary

Modifier and Type	Method	Description
OTransactionId	acquireIndexKeyPromise(Object key, int version, boolean force)
OTransactionId	acquirePromise(ORID rid, int version, boolean force)
void	begin(ODatabaseDocumentInternal database, boolean local)
Set<ORecordId>	cancel(ODistributedServerManager current, ODatabaseDocumentInternal database)
void	clearUndo()
void	commit(ODatabaseDocumentInternal database)
void	destroy()
OTransactionIdPromise	getPromise()
Set<OTxPromise<Object>>	getPromisedKeys()
Set<OTxPromise<ORID>>	getPromisedRids()
ODistributedRequestId	getReqId()
long	getStartedOn()
TxContextStatus	getStatus()
OTransactionInternal	getTransaction()
OTransactionId	getTransactionId()
void	releasePromises()
Set<ORecordId>	rollback(ODatabaseDocumentInternal database)
void	setStatus(TxContextStatus status)

Methods inherited from class java.lang.Object

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

Constructor Details

ONewDistributedTxContextImpl

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

Method Details

acquireIndexKeyPromise

public OTransactionId acquireIndexKeyPromise(Object key,
 int version,
 boolean force)

Specified by:

acquireIndexKeyPromise in interface ODistributedTxContext

acquirePromise

public OTransactionId acquirePromise(ORID rid,
 int version,
 boolean force)

Specified by:

acquirePromise 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

releasePromises

public void releasePromises()

Specified by:

releasePromises 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

getStatus

public TxContextStatus getStatus()

setStatus

public void setStatus(TxContextStatus status)

getPromisedRids

public Set<OTxPromise<ORID>> getPromisedRids()

getPromisedKeys

public Set<OTxPromise<Object>> getPromisedKeys()

getTransactionId

public OTransactionId getTransactionId()

Specified by:

getTransactionId in interface ODistributedTxContext

getPromise

public OTransactionIdPromise getPromise()