public abstract class ODurableComponent extends OSharedResourceAdaptive
Modifier and Type | Field and Description |
---|---|
protected OAtomicOperationsManager |
atomicOperationsManager |
protected OReadCache |
readCache |
protected OAbstractPaginatedStorage |
storage |
protected OWriteCache |
writeCache |
Constructor and Description |
---|
ODurableComponent(OAbstractPaginatedStorage storage,
String name,
String extension,
String lockName) |
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 static OCacheEntry |
loadPageForWrite(OAtomicOperation atomicOperation,
long fileId,
long pageIndex,
boolean checkPinnedPages,
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) |
acquireExclusiveLock, acquireSharedLock, addUser, assertExclusiveLockHold, assertSharedLockHold, getUsers, isConcurrent, releaseExclusiveLock, releaseSharedLock, removeUser, tryAcquireExclusiveLock, tryAcquireSharedLock
protected final OAtomicOperationsManager atomicOperationsManager
protected final OAbstractPaginatedStorage storage
protected final OReadCache readCache
protected final OWriteCache writeCache
public ODurableComponent(OAbstractPaginatedStorage storage, String name, String extension, String lockName)
public String getLockName()
public String getName()
public void setName(String name)
public String getFullName()
public String getExtension()
protected <T> T calculateInsideComponentOperation(OAtomicOperation atomicOperation, TxFunction<T> function)
protected void executeInsideComponentOperation(OAtomicOperation operation, TxConsumer consumer)
protected boolean tryExecuteInsideComponentOperation(OAtomicOperation operation, TxConsumer consumer)
protected long getFilledUpTo(OAtomicOperation atomicOperation, long fileId)
protected static OCacheEntry loadPageForWrite(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean checkPinnedPages, boolean verifyCheckSum) throws IOException
IOException
protected OCacheEntry loadPageForRead(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean checkPinnedPages) throws IOException
IOException
protected OCacheEntry loadPageForRead(OAtomicOperation atomicOperation, long fileId, long pageIndex, boolean checkPinnedPages, int pageCount) throws IOException
IOException
protected OCacheEntry addPage(OAtomicOperation atomicOperation, long fileId) throws IOException
IOException
protected void releasePageFromWrite(OAtomicOperation atomicOperation, OCacheEntry cacheEntry) throws IOException
IOException
protected void releasePageFromRead(OAtomicOperation atomicOperation, OCacheEntry cacheEntry)
protected long addFile(OAtomicOperation atomicOperation, String fileName) throws IOException
IOException
protected long openFile(OAtomicOperation atomicOperation, String fileName) throws IOException
IOException
protected void deleteFile(OAtomicOperation atomicOperation, long fileId) throws IOException
IOException
protected boolean isFileExists(OAtomicOperation atomicOperation, String fileName)
protected void truncateFile(OAtomicOperation atomicOperation, long filedId) throws IOException
IOException
Copyright © 2009–2020 OrientDB. All rights reserved.