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-orientechnologies.com)

Field Summary

Fields

Modifier and Type	Field and Description
static String	MBEAN_NAME

Constructor Summary

Constructors

Constructor and Description
OAtomicOperationsManager(OAbstractPaginatedStorage storage)

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)
void	doNotTrackAtomicOperations()
String	dumpActiveAtomicOperations()
OAtomicOperation	endAtomicOperation(boolean rollback, Exception exception, ODurableComponent component)
OAtomicOperation	endAtomicOperation(boolean rollback, Exception exception, String lockName)
void	ensureThatComponentsUnlocked()
long	freezeAtomicOperations(Class<? extends OException> exceptionClass, String message)
OAtomicOperation	getCurrentOperation()
boolean	isFrozen()
void	registerMBean()
void	releaseAtomicOperations(long id)
void	releaseReadLock(ODurableComponent durableComponent)
OAtomicOperation	startAtomicOperation(ODurableComponent durableComponent, boolean trackNonTxOperations)
OAtomicOperation	startAtomicOperation(String lockName, boolean trackNonTxOperations) Starts atomic operation inside of current thread.
void	switchOffUnsafeMode() Switch off unsafe mode.
void	switchOnUnsafeMode() Switch off unsafe mode.
void	trackAtomicOperations()
void	unregisterMBean()

Methods inherited from class java.lang.Object

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

Field Detail

MBEAN_NAME

public static final String MBEAN_NAME

See Also:

Constant Field Values

Constructor Detail

OAtomicOperationsManager

public OAtomicOperationsManager(OAbstractPaginatedStorage storage)

Method Detail

startAtomicOperation

public OAtomicOperation startAtomicOperation(ODurableComponent durableComponent,
                                             boolean trackNonTxOperations)
                                      throws IOException

Throws:

IOException

See Also:

startAtomicOperation(String, boolean)

startAtomicOperation

public OAtomicOperation startAtomicOperation(String lockName,
                                             boolean trackNonTxOperations)
                                      throws IOException

Starts atomic operation inside of current thread. If atomic operation has been already started, current atomic operation instance will be returned. All durable components have to call this method at the beginning of any data modification operation.

In current implementation of atomic operation, each component which is participated in atomic operation is hold under exclusive lock till atomic operation will not be completed (committed or rollbacked).

If other thread is going to read data from component it has to acquire read lock inside of atomic operation manager acquireReadLock(ODurableComponent), otherwise data consistency will be compromised.

Atomic operation may be delayed if start of atomic operations is prohibited by call of freezeAtomicOperations(Class, String) method. If mentioned above method is called then execution of current method will be stopped till call of releaseAtomicOperations(long) method or exception will be thrown. Concrete behaviour depends on real values of parameters of freezeAtomicOperations(Class, String) method.

Parameters:

trackNonTxOperations - If this flag set to true then special record ONonTxOperationPerformedWALRecord will be added to WAL in case of atomic operation is started outside of active storage transaction. During storage restore procedure this record is monitored and if given record is present then rebuild of all indexes is performed.

lockName - Name of lock (usually name of component) which is going participate in atomic operation.

Returns:

Instance of active atomic operation.

Throws:

IOException

switchOnUnsafeMode

public void switchOnUnsafeMode()

Switch off unsafe mode. During this mode it is not guaranteed that operations will support ACID properties but system performance will be faster.

To switch off unsafe mode call switchOffUnsafeMode()

switchOffUnsafeMode

public void switchOffUnsafeMode()

Switch off unsafe mode. It is highly recommended to call OStorage.synch() after calling of this method. Otherwise there is risk that database may be in broken state after crash/restore cycle if this method will not be called.

freezeAtomicOperations

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

isFrozen

public boolean isFrozen()

releaseAtomicOperations

public void releaseAtomicOperations(long id)

getCurrentOperation

public OAtomicOperation getCurrentOperation()

endAtomicOperation

public OAtomicOperation endAtomicOperation(boolean rollback,
                                           Exception exception,
                                           ODurableComponent component)
                                    throws IOException

Throws:

IOException

endAtomicOperation

public OAtomicOperation endAtomicOperation(boolean rollback,
                                           Exception exception,
                                           String lockName)
                                    throws IOException

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)

registerMBean

public void registerMBean()

unregisterMBean

public void unregisterMBean()

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