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

Class OAtomicOperationsManager

java.lang.Object

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

All Implemented Interfaces:

OAtomicOperationsMangerMXBean

public class OAtomicOperationsManager
extends Object
implements OAtomicOperationsMangerMXBean

Since:

12/3/13

Author:

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

Constructor Summary

Constructors

Constructor and Description
OAtomicOperationsManager(OAbstractPaginatedStorage storage, AtomicOperationsTable atomicOperationsTable)

Method Summary

Modifier and Type	Method and 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)
static void	alarmClearOfAtomicOperation()
<T> T	calculateInsideAtomicOperation(TxFunction<T> function)
<T> T	calculateInsideComponentOperation(OAtomicOperation atomicOperation, ODurableComponent component, TxFunction<T> function)
<T> T	calculateInsideComponentOperation(OAtomicOperation atomicOperation, String lockName, TxFunction<T> function)
void	doNotTrackAtomicOperations()
String	dumpActiveAtomicOperations()
void	endAtomicOperation(boolean rollback) Ends the current atomic operation on this manager.
void	ensureThatComponentsUnlocked()
void	executeInsideAtomicOperation(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()
static OAtomicOperation	getCurrentOperation()
void	releaseAtomicOperations(long id)
void	releaseComponentOperations(long freezeId)
void	releaseReadLock(ODurableComponent durableComponent)
OAtomicOperation	startAtomicOperation()
void	trackAtomicOperations()
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 Detail

OAtomicOperationsManager

public OAtomicOperationsManager(OAbstractPaginatedStorage storage,
                                AtomicOperationsTable atomicOperationsTable)

Method Detail

startAtomicOperation

public OAtomicOperation startAtomicOperation()
                                      throws IOException

Throws:

IOException

calculateInsideAtomicOperation

public <T> T calculateInsideAtomicOperation(TxFunction<T> function)
                                     throws IOException

Throws:

IOException

executeInsideAtomicOperation

public void executeInsideAtomicOperation(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)

alarmClearOfAtomicOperation

public static void alarmClearOfAtomicOperation()

freezeAtomicOperations

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

releaseAtomicOperations

public void releaseAtomicOperations(long id)

getCurrentOperation

public static OAtomicOperation getCurrentOperation()

freezeComponentOperations

public long freezeComponentOperations()

releaseComponentOperations

public void releaseComponentOperations(long freezeId)

endAtomicOperation

public void endAtomicOperation(boolean rollback)
                        throws IOException

Ends the current atomic operation on this manager.

Parameters:

rollback - true to indicate a rollback, false for successful commit.

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 id 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)

trackAtomicOperations

public void trackAtomicOperations()

Specified by:

trackAtomicOperations in interface OAtomicOperationsMangerMXBean

doNotTrackAtomicOperations

public void doNotTrackAtomicOperations()

Specified by:

doNotTrackAtomicOperations in interface OAtomicOperationsMangerMXBean

dumpActiveAtomicOperations

public String dumpActiveAtomicOperations()

Specified by:

dumpActiveAtomicOperations in interface OAtomicOperationsMangerMXBean