com.orientechnologies.orient.core.storage.cache.local.twoq

Class O2QCache

java.lang.Object

com.orientechnologies.orient.core.storage.cache.local.twoq.O2QCache

All Implemented Interfaces:

OReadCache

public class O2QCache
extends Object
implements OReadCache

Since:

7/24/13

Author:

Andrey Lomakin

Field Summary

Fields

Modifier and Type	Field and Description
static String	CACHE_STATE_FILE File which contains stored state of disk cache after storage close.
static String	CACHE_STATISTIC_FILE_EXTENSION Extension for file which contains stored state of disk cache after storage close.
static int	MAX_PERCENT_OF_PINED_PAGES Maximum percent of pinned pages which may be contained in this cache.
static int	MIN_CACHE_SIZE Minimum size of memory which may be allocated by cache (in pages).

Constructor Summary

Constructors

Constructor and Description
O2QCache(long readCacheMaxMemory, int pageSize, boolean checkMinSize, int percentOfPinnedPages)

Method Summary

Modifier and Type	Method and Description
long	addFile(String fileName, long fileId, OWriteCache writeCache)
long	addFile(String fileName, OWriteCache writeCache)
OCacheEntry	allocateNewPage(long fileId, OWriteCache writeCache, boolean verifyChecksums)
void	changeMaximumAmountOfMemory(long readCacheMaxMemory) Changes amount of memory which may be used by given cache.
void	clear()
void	closeFile(long fileId, boolean flush, OWriteCache writeCache)
void	closeStorage(OWriteCache writeCache) Performs following steps: If flag OGlobalConfiguration.STORAGE_KEEP_DISK_CACHE_STATE is set to true saves state of all queues of 2Q cache into file CACHE_STATE_FILE.The only exception is pinned pages they need to pinned again. Closes all files and flushes all data associated to them.
void	deleteFile(long fileId, OWriteCache writeCache)
void	deleteStorage(OWriteCache writeCache)
long	getUsedMemory()
OCacheEntry	load(long fileId, long pageIndex, boolean checkPinnedPages, OWriteCache writeCache, int pageCount, boolean verifyChecksums)
void	loadCacheState(OWriteCache writeCache) Loads state of 2Q cache queues stored during storage close closeStorage(OWriteCache) back into memory if flag OGlobalConfiguration.STORAGE_KEEP_DISK_CACHE_STATE is set to true.
void	pinPage(OCacheEntry cacheEntry)
void	release(OCacheEntry cacheEntry, OWriteCache writeCache)
void	storeCacheState(OWriteCache writeCache) Stores state of queues of 2Q cache inside of CACHE_STATE_FILE file if flag OGlobalConfiguration.STORAGE_KEEP_DISK_CACHE_STATE is set to true.
void	truncateFile(long fileId, OWriteCache writeCache)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_PERCENT_OF_PINED_PAGES

public static final int MAX_PERCENT_OF_PINED_PAGES

Maximum percent of pinned pages which may be contained in this cache.

See Also:

Constant Field Values

MIN_CACHE_SIZE

public static final int MIN_CACHE_SIZE

Minimum size of memory which may be allocated by cache (in pages). This parameter is used only if related flag is set in constrictor of cache.

See Also:

Constant Field Values

CACHE_STATE_FILE

public static final String CACHE_STATE_FILE

File which contains stored state of disk cache after storage close.

See Also:

Constant Field Values

CACHE_STATISTIC_FILE_EXTENSION

public static final String CACHE_STATISTIC_FILE_EXTENSION

Extension for file which contains stored state of disk cache after storage close.

See Also:

Constant Field Values

Constructor Detail

O2QCache

public O2QCache(long readCacheMaxMemory,
                int pageSize,
                boolean checkMinSize,
                int percentOfPinnedPages)

Parameters:

readCacheMaxMemory - Maximum amount of direct memory which can allocated by disk cache in bytes.

pageSize - Cache page size in bytes.

checkMinSize - If this flat is set size of cache may be MIN_CACHE_SIZE or bigger.

percentOfPinnedPages - Maximum percent of pinned pages which may be hold by this cache.

See Also:

MAX_PERCENT_OF_PINED_PAGES

Method Detail

addFile

public long addFile(String fileName,
                    OWriteCache writeCache)
             throws IOException

Specified by:

addFile in interface OReadCache

Throws:

IOException

addFile

public long addFile(String fileName,
                    long fileId,
                    OWriteCache writeCache)
             throws IOException

Specified by:

addFile in interface OReadCache

Throws:

IOException

pinPage

public void pinPage(OCacheEntry cacheEntry)
             throws IOException

Specified by:

pinPage in interface OReadCache

Throws:

IOException

changeMaximumAmountOfMemory

public void changeMaximumAmountOfMemory(long readCacheMaxMemory)
                                 throws IllegalStateException

Changes amount of memory which may be used by given cache. This method may consume many resources if amount of memory provided in parameter is much less than current amount of memory.

Parameters:

readCacheMaxMemory - New maximum size of cache in bytes.

Throws:

IllegalStateException - In case of new size of disk cache is too small to hold existing pinned pages.

load

public OCacheEntry load(long fileId,
                        long pageIndex,
                        boolean checkPinnedPages,
                        OWriteCache writeCache,
                        int pageCount,
                        boolean verifyChecksums)
                 throws IOException

Specified by:

load in interface OReadCache

Throws:

IOException

allocateNewPage

public OCacheEntry allocateNewPage(long fileId,
                                   OWriteCache writeCache,
                                   boolean verifyChecksums)
                            throws IOException

Specified by:

allocateNewPage in interface OReadCache

Throws:

IOException

release

public void release(OCacheEntry cacheEntry,
                    OWriteCache writeCache)

Specified by:

release in interface OReadCache

clear

public void clear()

Specified by:

clear in interface OReadCache

truncateFile

public void truncateFile(long fileId,
                         OWriteCache writeCache)
                  throws IOException

Specified by:

truncateFile in interface OReadCache

Throws:

IOException

closeFile

public void closeFile(long fileId,
                      boolean flush,
                      OWriteCache writeCache)
               throws IOException

Specified by:

closeFile in interface OReadCache

Throws:

IOException

deleteFile

public void deleteFile(long fileId,
                       OWriteCache writeCache)
                throws IOException

Specified by:

deleteFile in interface OReadCache

Throws:

IOException

closeStorage

public void closeStorage(OWriteCache writeCache)
                  throws IOException

Performs following steps:

1. If flag OGlobalConfiguration.STORAGE_KEEP_DISK_CACHE_STATE is set to true saves state of all queues of 2Q cache into file CACHE_STATE_FILE.The only exception is pinned pages they need to pinned again.
2. Closes all files and flushes all data associated to them.

Specified by:

closeStorage in interface OReadCache

Parameters:

writeCache - Write cache all files of which should be closed. In terms of cache write cache = storage.

Throws:

IOException

loadCacheState

public void loadCacheState(OWriteCache writeCache)

Loads state of 2Q cache queues stored during storage close closeStorage(OWriteCache) back into memory if flag OGlobalConfiguration.STORAGE_KEEP_DISK_CACHE_STATE is set to true. If maximum size of cache was decreased cache state will not be restored.

Specified by:

loadCacheState in interface OReadCache

Parameters:

writeCache - Write cache is used to load pages back into cache if needed.

See Also:

closeStorage(OWriteCache)

storeCacheState

public void storeCacheState(OWriteCache writeCache)

Stores state of queues of 2Q cache inside of CACHE_STATE_FILE file if flag OGlobalConfiguration.STORAGE_KEEP_DISK_CACHE_STATE is set to true. Following format is used to store queue state:

1. Max cache size, single item (long)
2. File id or -1 if end of queue is reached (int)
3. Page index (long), is absent if end of the queue is reached

Specified by:

storeCacheState in interface OReadCache

Parameters:

writeCache - Write cache which manages files cache state of which is going to be stored.

deleteStorage

public void deleteStorage(OWriteCache writeCache)
                   throws IOException

Specified by:

deleteStorage in interface OReadCache

Throws:

IOException

getUsedMemory

public long getUsedMemory()

Specified by:

getUsedMemory in interface OReadCache