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

Interface OAtomicOperation

public interface OAtomicOperation

Method Summary

Modifier and Type	Method and Description
void	addDeletedRecordPosition(int clusterId, int pageIndex, int recordPosition)
void	addDeletedRidBag(OBonsaiBucketPointer rootPointer)
long	addFile(String fileName)
void	addLockedObject(String lockName)
void	addMetadata(OAtomicOperationMetadata<?> metadata)
OCacheEntry	addPage(long fileId)
OLogSequenceNumber	commitChanges(OWriteAheadLog writeAheadLog)
boolean	containsInLockedObjects(String lockName)
void	decrementComponentOperations()
void	deleteFile(long fileId)
String	fileNameById(long fileId)
long	filledUpTo(long fileId)
Set<Integer>	getBookedRecordPositions(int clusterId, int pageIndex)
int	getComponentOperations()
Set<OBonsaiBucketPointer>	getDeletedBonsaiPointers()
OAtomicOperationMetadata<?>	getMetadata(String key)
long	getOperationUnitId()
void	incrementComponentOperations()
boolean	isFileExists(String fileName)
boolean	isRollbackInProgress()
long	loadFile(String fileName)
OCacheEntry	loadPageForRead(long fileId, long pageIndex, boolean checkPinnedPages, int pageCount)
OCacheEntry	loadPageForWrite(long fileId, long pageIndex, boolean checkPinnedPages, int pageCount, boolean verifyChecksum)
Iterable<String>	lockedObjects()
void	releasePageFromRead(OCacheEntry cacheEntry)
void	releasePageFromWrite(OCacheEntry cacheEntry)
void	rollbackInProgress()
void	truncateFile(long fileId)

Method Detail

getOperationUnitId

long getOperationUnitId()

loadPageForWrite

OCacheEntry loadPageForWrite(long fileId,
                             long pageIndex,
                             boolean checkPinnedPages,
                             int pageCount,
                             boolean verifyChecksum)
                      throws IOException

Throws:

IOException

loadPageForRead

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

Throws:

IOException

addMetadata

void addMetadata(OAtomicOperationMetadata<?> metadata)

getMetadata

OAtomicOperationMetadata<?> getMetadata(String key)

addDeletedRidBag

void addDeletedRidBag(OBonsaiBucketPointer rootPointer)

getDeletedBonsaiPointers

Set<OBonsaiBucketPointer> getDeletedBonsaiPointers()

addPage

OCacheEntry addPage(long fileId)
             throws IOException

Throws:

IOException

releasePageFromRead

void releasePageFromRead(OCacheEntry cacheEntry)

releasePageFromWrite

void releasePageFromWrite(OCacheEntry cacheEntry)
                   throws IOException

Throws:

IOException

filledUpTo

long filledUpTo(long fileId)

addFile

long addFile(String fileName)
      throws IOException

Throws:

IOException

loadFile

long loadFile(String fileName)
       throws IOException

Throws:

IOException

deleteFile

void deleteFile(long fileId)
         throws IOException

Throws:

IOException

isFileExists

boolean isFileExists(String fileName)

fileNameById

String fileNameById(long fileId)

truncateFile

void truncateFile(long fileId)
           throws IOException

Throws:

IOException

containsInLockedObjects

boolean containsInLockedObjects(String lockName)

addLockedObject

void addLockedObject(String lockName)

rollbackInProgress

void rollbackInProgress()

isRollbackInProgress

boolean isRollbackInProgress()

commitChanges

OLogSequenceNumber commitChanges(OWriteAheadLog writeAheadLog)
                          throws IOException

Throws:

IOException

lockedObjects

Iterable<String> lockedObjects()

addDeletedRecordPosition

void addDeletedRecordPosition(int clusterId,
                              int pageIndex,
                              int recordPosition)

getBookedRecordPositions

Set<Integer> getBookedRecordPositions(int clusterId,
                                      int pageIndex)

incrementComponentOperations

void incrementComponentOperations()

decrementComponentOperations

void decrementComponentOperations()

getComponentOperations

int getComponentOperations()