public class OAtomicOperationsManager extends Object
Constructor and Description |
---|
OAtomicOperationsManager(OAbstractPaginatedStorage storage,
boolean trackPageOperations,
int operationsCacheLimit,
AtomicOperationsTable atomicOperationsTable) |
public OAtomicOperationsManager(OAbstractPaginatedStorage storage, boolean trackPageOperations, int operationsCacheLimit, AtomicOperationsTable atomicOperationsTable)
public OAtomicOperation startAtomicOperation(byte[] metadata) throws IOException
IOException
public <T> T calculateInsideAtomicOperation(byte[] metadata, TxFunction<T> function) throws IOException
IOException
public void executeInsideAtomicOperation(byte[] metadata, TxConsumer consumer) throws IOException
IOException
public void executeInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxConsumer consumer)
public void executeInsideComponentOperation(OAtomicOperation atomicOperation, String lockName, TxConsumer consumer)
public boolean tryExecuteInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxConsumer consumer)
public <T> T calculateInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxFunction<T> function)
public <T> T calculateInsideComponentOperation(OAtomicOperation atomicOperation, String lockName, TxFunction<T> function)
public long freezeComponentOperations()
public void releaseComponentOperations(long freezeId)
public static void alarmClearOfAtomicOperation()
public long freezeAtomicOperations(Class<? extends OException> exceptionClass, String message)
public void releaseAtomicOperations(long id)
public static OAtomicOperation getCurrentOperation()
public void endAtomicOperation(boolean rollback) throws IOException
rollback
- true
to indicate a rollback, false
for successful commit.IOException
public void ensureThatComponentsUnlocked()
public void acquireExclusiveLockTillOperationComplete(OAtomicOperation operation, String lockName)
operation
- the atomic operation to acquire the lock in.lockName
- the lock name to acquire.public void acquireExclusiveLockTillOperationComplete(ODurableComponent durableComponent)
durableComponent
.public void acquireReadLock(ODurableComponent durableComponent)
public void releaseReadLock(ODurableComponent durableComponent)
Copyright © 2009–2020 OrientDB. All rights reserved.