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

Class ODurableComponent

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAdaptive

com.orientechnologies.orient.core.storage.impl.local.paginated.base.ODurableComponent

Direct Known Subclasses:

CellBTreeMultiValueV2, OCellBTreeMultiValueV1, OCellBTreeSingleValue, OClusterPositionMap, OHashTableDirectory, OLocalHashTable, OPaginatedCluster, OSBTree, OSBTreeBonsaiLocal

public abstract class ODurableComponent
extends OSharedResourceAdaptive

Base class for all durable data structures, that is data structures state of which can be consistently restored after system crash but results of last operations in small interval before crash may be lost. This class contains methods which are used to support such concepts as:

1. "atomic operation" - set of operations which should be either applied together or not. It includes not only changes on current data structure but on all durable data structures which are used by current one during implementation of specific operation.
2. write ahead log - log of all changes which were done with page content after loading it from cache.

Since:

8/27/13

Author:

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

Field Summary

Fields

Modifier and Type	Field and Description
protected OAtomicOperationsManager	atomicOperationsManager
protected OReadCache	readCache
protected OAbstractPaginatedStorage	storage
protected OWriteCache	writeCache

Constructor Summary

Constructors

Constructor and Description
ODurableComponent(OAbstractPaginatedStorage storage, String name, String extension, String lockName)

Method Summary

Modifier and Type	Method and Description
protected long	addFile(OAtomicOperation atomicOperation, String fileName)
protected OCacheEntry	addPage(OAtomicOperation atomicOperation, long fileId)
protected <T> T	calculateInsideComponentOperation(OAtomicOperation atomicOperation, TxFunction<T> function)
protected void	deleteFile(OAtomicOperation atomicOperation, long fileId)
protected void	executeInsideComponentOperation(OAtomicOperation operation, TxConsumer consumer)
String	getExtension()
protected long	getFilledUpTo(OAtomicOperation atomicOperation, long fileId)
String	getFullName()
String	getLockName()
String	getName()
protected boolean	isFileExists(OAtomicOperation atomicOperation, String fileName)
protected OCacheEntry	loadPageForRead(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean checkPinnedPages)
protected OCacheEntry	loadPageForRead(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean checkPinnedPages, int pageCount)
protected OCacheEntry	loadPageForWrite(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean checkPinnedPages, boolean verifyCheckSum)
protected long	openFile(OAtomicOperation atomicOperation, String fileName)
protected void	pinPage(OAtomicOperation atomicOperation, OCacheEntry cacheEntry)
protected void	releasePageFromRead(OAtomicOperation atomicOperation, OCacheEntry cacheEntry)
protected void	releasePageFromWrite(OAtomicOperation atomicOperation, OCacheEntry cacheEntry)
void	setName(String name)
protected void	truncateFile(OAtomicOperation atomicOperation, long filedId)
protected boolean	tryExecuteInsideComponentOperation(OAtomicOperation operation, TxConsumer consumer)

Methods inherited from class com.orientechnologies.common.concur.resource.OSharedResourceAdaptive

acquireExclusiveLock, acquireSharedLock, addUser, assertExclusiveLockHold, assertSharedLockHold, getUsers, isConcurrent, releaseExclusiveLock, releaseSharedLock, removeUser, tryAcquireExclusiveLock, tryAcquireSharedLock

Methods inherited from class java.lang.Object

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

Field Detail

atomicOperationsManager

protected final OAtomicOperationsManager atomicOperationsManager

storage

protected final OAbstractPaginatedStorage storage

readCache

protected final OReadCache readCache

writeCache

protected final OWriteCache writeCache

Constructor Detail

ODurableComponent

public ODurableComponent(OAbstractPaginatedStorage storage,
                         String name,
                         String extension,
                         String lockName)

Method Detail

getLockName

public String getLockName()

getName

public String getName()

setName

public void setName(String name)

getFullName

public String getFullName()

getExtension

public String getExtension()

calculateInsideComponentOperation

protected <T> T calculateInsideComponentOperation(OAtomicOperation atomicOperation,
                                                  TxFunction<T> function)

executeInsideComponentOperation

protected void executeInsideComponentOperation(OAtomicOperation operation,
                                               TxConsumer consumer)

tryExecuteInsideComponentOperation

protected boolean tryExecuteInsideComponentOperation(OAtomicOperation operation,
                                                     TxConsumer consumer)

getFilledUpTo

protected long getFilledUpTo(OAtomicOperation atomicOperation,
                             long fileId)

loadPageForWrite

protected OCacheEntry loadPageForWrite(OAtomicOperation atomicOperation,
                                       long fileId,
                                       long pageIndex,
                                       boolean checkPinnedPages,
                                       boolean verifyCheckSum)
                                throws IOException

Throws:

IOException

loadPageForRead

protected OCacheEntry loadPageForRead(OAtomicOperation atomicOperation,
                                      long fileId,
                                      long pageIndex,
                                      boolean checkPinnedPages)
                               throws IOException

Throws:

IOException

loadPageForRead

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

Throws:

IOException

pinPage

protected void pinPage(OAtomicOperation atomicOperation,
                       OCacheEntry cacheEntry)

addPage

protected OCacheEntry addPage(OAtomicOperation atomicOperation,
                              long fileId)
                       throws IOException

Throws:

IOException

releasePageFromWrite

protected void releasePageFromWrite(OAtomicOperation atomicOperation,
                                    OCacheEntry cacheEntry)

releasePageFromRead

protected void releasePageFromRead(OAtomicOperation atomicOperation,
                                   OCacheEntry cacheEntry)

addFile

protected long addFile(OAtomicOperation atomicOperation,
                       String fileName)
                throws IOException

Throws:

IOException

openFile

protected long openFile(OAtomicOperation atomicOperation,
                        String fileName)
                 throws IOException

Throws:

IOException

deleteFile

protected void deleteFile(OAtomicOperation atomicOperation,
                          long fileId)
                   throws IOException

Throws:

IOException

isFileExists

protected boolean isFileExists(OAtomicOperation atomicOperation,
                               String fileName)

truncateFile

protected void truncateFile(OAtomicOperation atomicOperation,
                            long filedId)
                     throws IOException

Throws:

IOException