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

Class OAtomicOperation

java.lang.Object

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

public class OAtomicOperation
extends Object

Note: all atomic operations methods are designed in context that all operations on single files will be wrapped in shared lock.

Since:

12/3/13

Author:

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

Constructor Summary

Constructors

Constructor and Description
OAtomicOperation(OLogSequenceNumber startLSN, OOperationUnitId operationUnitId, OReadCache readCache, OWriteCache writeCache, int storageId, OPerformanceStatisticManager performanceStatisticManager)

Method Summary

Modifier and Type	Method and Description
long	addFile(String fileName)
void	addMetadata(OAtomicOperationMetadata<?> metadata) Add metadata with given key inside of atomic operation.
OCacheEntry	addPage(long fileId)
void	commitChanges(OWriteAheadLog writeAheadLog)
protected OPageCache	createPageCache(OReadCache readCache)
void	deleteFile(long fileId)
boolean	equals(Object o)
String	fileNameById(long fileId)
long	filledUpTo(long fileId)
OWALChanges	getChanges(long fileId, long pageIndex)
Map<String,OAtomicOperationMetadata<?>>	getMetadata()
OAtomicOperationMetadata<?>	getMetadata(String key)
OOperationUnitId	getOperationUnitId()
OLogSequenceNumber	getStartLSN()
int	hashCode()
boolean	isFileExists(long fileId)
boolean	isFileExists(String fileName)
long	loadFile(String fileName)
OCacheEntry	loadPage(long fileId, long pageIndex, boolean checkPinnedPages, int pageCount)
void	pinPage(OCacheEntry cacheEntry)
void	releasePage(OCacheEntry cacheEntry)
void	truncateFile(long fileId)

Methods inherited from class java.lang.Object

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

Constructor Detail

OAtomicOperation

public OAtomicOperation(OLogSequenceNumber startLSN,
                        OOperationUnitId operationUnitId,
                        OReadCache readCache,
                        OWriteCache writeCache,
                        int storageId,
                        OPerformanceStatisticManager performanceStatisticManager)

Method Detail

getStartLSN

public OLogSequenceNumber getStartLSN()

getOperationUnitId

public OOperationUnitId getOperationUnitId()

loadPage

public OCacheEntry loadPage(long fileId,
                            long pageIndex,
                            boolean checkPinnedPages,
                            int pageCount)
                     throws IOException

Throws:

IOException

addMetadata

public void addMetadata(OAtomicOperationMetadata<?> metadata)

Add metadata with given key inside of atomic operation. If metadata with the same key insist inside of atomic operation it will be overwritten.

Parameters:

metadata - Metadata to add.

See Also:

OAtomicOperationMetadata

getMetadata

public OAtomicOperationMetadata<?> getMetadata(String key)

Parameters:

key - Key of metadata which is looking for.

Returns:

Metadata by associated key or null if such metadata is absent.

getMetadata

public Map<String,OAtomicOperationMetadata<?>> getMetadata()

Returns:

All keys and associated metadata contained inside of atomic operation

pinPage

public void pinPage(OCacheEntry cacheEntry)
             throws IOException

Throws:

IOException

addPage

public OCacheEntry addPage(long fileId)
                    throws IOException

Throws:

IOException

releasePage

public void releasePage(OCacheEntry cacheEntry)

getChanges

public OWALChanges getChanges(long fileId,
                              long pageIndex)

filledUpTo

public long filledUpTo(long fileId)
                throws IOException

Throws:

IOException

addFile

public long addFile(String fileName)
             throws IOException

Throws:

IOException

loadFile

public long loadFile(String fileName)
              throws IOException

Throws:

IOException

deleteFile

public void deleteFile(long fileId)

isFileExists

public boolean isFileExists(String fileName)

isFileExists

public boolean isFileExists(long fileId)

fileNameById

public String fileNameById(long fileId)

truncateFile

public void truncateFile(long fileId)

commitChanges

public void commitChanges(OWriteAheadLog writeAheadLog)
                   throws IOException

Throws:

IOException

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

createPageCache

protected OPageCache createPageCache(OReadCache readCache)