Package com.orientechnologies.orient.core.storage.impl.local.paginated.atomicoperations

Class OAtomicOperationsManager

java.lang.Object

com.orientechnologies.orient.core.storage.impl.local.paginated.atomicoperations.OAtomicOperationsManager

public class OAtomicOperationsManager
extends Object

Since:

12/3/13

Author:

Andrey Lomakin (a.lomakin-at-orientdb.com)

Constructor Summary

Constructors

Constructor	Description
OAtomicOperationsManager(OAbstractPaginatedStorage storage, int operationsCacheLimit, AtomicOperationsTable atomicOperationsTable)

Method Summary

Modifier and Type	Method	Description
void	acquireExclusiveLockTillOperationComplete(OAtomicOperation operation, String lockName)	Acquires exclusive lock with the given lock name in the given atomic operation.
void	acquireExclusiveLockTillOperationComplete(ODurableComponent durableComponent)	Acquires exclusive lock in the active atomic operation running on the current thread for the durableComponent.
void	acquireReadLock(ODurableComponent durableComponent)
void	alarmClearOfAtomicOperation()
<T> T	calculateInsideAtomicOperation(byte[] metadata, TxFunction<T> function)
<T> T	calculateInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxFunction<T> function)
<T> T	calculateInsideComponentOperation(OAtomicOperation atomicOperation, String lockName, TxFunction<T> function)
void	endAtomicOperation(Throwable error)	Ends the current atomic operation on this manager.
void	ensureThatComponentsUnlocked()
void	executeInsideAtomicOperation(byte[] metadata, TxConsumer consumer)
void	executeInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxConsumer consumer)
void	executeInsideComponentOperation(OAtomicOperation atomicOperation, String lockName, TxConsumer consumer)
long	freezeAtomicOperations(Class<? extends OException> exceptionClass, String message)
long	freezeComponentOperations()
final OAtomicOperation	getCurrentOperation()
void	releaseAtomicOperations(long id)
void	releaseComponentOperations(long freezeId)
void	releaseReadLock(ODurableComponent durableComponent)
OAtomicOperation	startAtomicOperation(byte[] metadata)
boolean	tryExecuteInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxConsumer consumer)

Methods inherited from class java.lang.Object

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

Constructor Details

OAtomicOperationsManager

public OAtomicOperationsManager(OAbstractPaginatedStorage storage,
 int operationsCacheLimit,
 AtomicOperationsTable atomicOperationsTable)

Method Details

startAtomicOperation

public OAtomicOperation startAtomicOperation(byte[] metadata)
                                      throws IOException

Throws:

IOException

calculateInsideAtomicOperation

public <T> T calculateInsideAtomicOperation(byte[] metadata,
 TxFunction<T> function)
                                     throws IOException

Throws:

IOException

executeInsideAtomicOperation

public void executeInsideAtomicOperation(byte[] metadata,
 TxConsumer consumer)
                                  throws IOException

Throws:

IOException

executeInsideComponentOperation

public void executeInsideComponentOperation(OAtomicOperation atomicOperation,
 ODurableComponent component,
 TxConsumer consumer)

executeInsideComponentOperation

public void executeInsideComponentOperation(OAtomicOperation atomicOperation,
 String lockName,
 TxConsumer consumer)

tryExecuteInsideComponentOperation

public boolean tryExecuteInsideComponentOperation(OAtomicOperation atomicOperation,
 ODurableComponent component,
 TxConsumer consumer)

calculateInsideComponentOperation

public <T> T calculateInsideComponentOperation(OAtomicOperation atomicOperation,
 ODurableComponent component,
 TxFunction<T> function)

calculateInsideComponentOperation

public <T> T calculateInsideComponentOperation(OAtomicOperation atomicOperation,
 String lockName,
 TxFunction<T> function)

freezeComponentOperations

public long freezeComponentOperations()

releaseComponentOperations

public void releaseComponentOperations(long freezeId)

alarmClearOfAtomicOperation

public void alarmClearOfAtomicOperation()

freezeAtomicOperations

public long freezeAtomicOperations(Class<? extends OException> exceptionClass,
 String message)

releaseAtomicOperations

public void releaseAtomicOperations(long id)

getCurrentOperation

public final OAtomicOperation getCurrentOperation()

endAtomicOperation

public void endAtomicOperation(Throwable error)
                        throws IOException

Ends the current atomic operation on this manager.

Throws:

IOException

ensureThatComponentsUnlocked

public void ensureThatComponentsUnlocked()

acquireExclusiveLockTillOperationComplete

public void acquireExclusiveLockTillOperationComplete(OAtomicOperation operation,
 String lockName)

Acquires exclusive lock with the given lock name in the given atomic operation.

Parameters:

operation - the atomic operation to acquire the lock in.

lockName - the lock name to acquire.

acquireExclusiveLockTillOperationComplete

public void acquireExclusiveLockTillOperationComplete(ODurableComponent durableComponent)

Acquires exclusive lock in the active atomic operation running on the current thread for the durableComponent.

acquireReadLock

public void acquireReadLock(ODurableComponent durableComponent)

releaseReadLock

public void releaseReadLock(ODurableComponent durableComponent)