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

Class ODurableComponent

java.lang.Object

com.orientechnologies.common.concur.resource.OSharedResourceAbstract

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

Direct Known Subclasses:

BTree, CellBTreeMultiValueV2, CellBTreeSingleValueV1, CellBTreeSingleValueV3, FreeSpaceMap, HashTableDirectory, LocalHashTableV2, NormalizedKeyBTreeValue, OClusterPositionMap, OHashTableDirectory, OLocalHashTableV3, OPaginatedCluster, OSBTreeBonsaiLocal, OSBTreeV1, OSBTreeV2, OVersionPositionMap

public abstract class ODurableComponent
extends OSharedResourceAbstract

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.

Since:

8/27/13

Author:

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

Field Summary

Fields

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

Fields inherited from class com.orientechnologies.common.concur.resource.OSharedResourceAbstract

lock

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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	loadOrAddPageForWrite(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean verifyCheckSum)
protected OCacheEntry	loadPageForRead(OAtomicOperation atomicOperation, long fileId, long pageIndex)
protected static OCacheEntry	loadPageForWrite(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean verifyCheckSum)
protected long	openFile(OAtomicOperation atomicOperation, String fileName)
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.OSharedResourceAbstract

acquireExclusiveLock, acquireSharedLock, releaseExclusiveLock, releaseSharedLock

Methods inherited from class java.lang.Object

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

Field Details

atomicOperationsManager

protected final OAtomicOperationsManager atomicOperationsManager

storage

protected final OAbstractPaginatedStorage storage

readCache

protected final OReadCache readCache

writeCache

protected final OWriteCache writeCache

Constructor Details

ODurableComponent

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

Method Details

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 static OCacheEntry loadPageForWrite(OAtomicOperation atomicOperation,
 long fileId,
 long pageIndex,
 boolean verifyCheckSum)
                                       throws IOException

Throws:

IOException

loadOrAddPageForWrite

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

Throws:

IOException

loadPageForRead

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

Throws:

IOException

addPage

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

Throws:

IOException

releasePageFromWrite

protected void releasePageFromWrite(OAtomicOperation atomicOperation,
 OCacheEntry cacheEntry)
                             throws IOException

Throws:

IOException

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