java.lang.Object
- xyz.cofe.cbuffer.page.CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
- - xyz.cofe.cbuffer.page.CCachePagedData

All Implemented Interfaces:

Flushable, ExtendablePages<UsedPagesInfo>, PagedData<UsedPagesInfo>, PageLock, ReduciblePages<UsedPagesInfo>, ResizablePages<UsedPagesInfo>
```
public class CCachePagedData
extends CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
implements PageLock
```
Кеш страниц, с разделением на быструю и медленную память с поддержкой многопоточности

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class CCachePagedData.State

Field Summary

Fields
Modifier and Type Field Description

protected Object closeSync
- Fields inherited from class xyz.cofe.cbuffer.page.CachePagedDataBase
  state

Constructor Summary

Constructors
Modifier	Constructor	Description
`protected`	`CCachePagedData(CCachePagedData.State state)`
	`CCachePagedData(DirtyPagedDataSafe cachePages, ResizablePages<UsedPagesInfo> persistentPages)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected int`	`allocCachePage()`	Выделение свободной страницы
`protected int`	`cache2persist(int cachePage)`	Возвращает индекс постоянной страницы для кешированной страницы
`protected int`	`cache2persist_mut(int cachePage)`
`protected xyz.cofe.fn.Tuple2<List<Integer>,List<Integer>>`	`cleanDirtyPages()`	Получение списка чистых/грязных страниц
`void`	`close()`
`protected boolean`	`dirty(int cachePage)`	Проверка, что страница является "грязной"
`protected boolean`	`dirty_mut(int cachePage)`
`xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo>`	`extendPages(int pages)`	Расширение кол-ва используемых страниц
`void`	`flush()`	Принудительная запись накопившийся изменений на диск/носитель информации
`protected int`	`flush(int cachePage)`	Сохранение страницы кеша
`protected int`	`flush_mut(int cachePage)`
`protected boolean`	`isClosed()`
`protected List<Lock>`	`lockPersistPages(int from, int toExc, Function<ReadWriteLock,Lock> lockType)`
`protected byte[]`	`map(int cachePage, int persistPage)`	Проецирование страницы из постоянной памяти на кеш
`UsedPagesInfo`	`memoryInfo()`	Получение информации о памяти
`protected int`	`persist2cache(int persistPage)`	Возвращает индекс кешированной страницы для постоянной страницы
`protected int`	`persist2cache_mut(int persistPage)`
`byte[]`	`readPage(int page)`	Чтение страницы.
`protected byte[]`	`readPage_alloc(int page)`
`protected byte[]`	`readPage_mapped(int cidx, int page)`
`void`	`readPageLock(int from, int toExc, Runnable code)`	Блокировка диапазона страниц для чтения - shared блокировка
`xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo>`	`reducePages(int pages)`	Уменьшение кол-ва используемых страниц
`xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo>`	`resizeCachePages(int pages)`	Изменение размера кеша.
`xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo>`	`resizePages(int pages)`	Изменение кол-ва выделенных страниц
`protected int`	`unmap(int cachePage)`	выгрузка страницы
`protected int`	`unmapCandidate(List<Integer> pages, boolean clean)`	Выбор кандидата (страница кеша) на выгрузку
`void`	`writePage(int page, byte[] data)`	Запись страницы
`protected void`	`writePage_alloc(int page, byte[] data)`
`protected void`	`writePage_mapped(int cidx, int page, byte[] data)`
`void`	`writePageLock(int from, int toExc, Runnable code)`	Блокировка диапазона страниц для записи - эксклюзивная блокировка

Methods inherited from class xyz.cofe.cbuffer.page.CachePagedDataBase
cacheHitMiss, flush0

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - closeSync
```
protected final Object closeSync
```
- Constructor Detail
  - CCachePagedData
```
protected CCachePagedData(CCachePagedData.State state)
```
  - CCachePagedData
```
public CCachePagedData(DirtyPagedDataSafe cachePages,
                       ResizablePages<UsedPagesInfo> persistentPages)
```
- Method Detail
  - isClosed
```
protected boolean isClosed()
```
    Overrides:
    
    isClosed in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - close
```
public void close()
```
  - memoryInfo
```
public UsedPagesInfo memoryInfo()
```
    Description copied from interface: PagedData
    
    Получение информации о памяти
    
    Specified by:
    
    memoryInfo in interface PagedData<UsedPagesInfo>
    
    Overrides:
    
    memoryInfo in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Returns:
    
    Получение информации о памяти
  - persist2cache
```
protected int persist2cache(int persistPage)
```
    Description copied from class: CachePagedDataBase
    
    Возвращает индекс кешированной страницы для постоянной страницы
    
    Overrides:
    
    persist2cache in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    persistPage - постоянная страница, допустимые значения: от 0 и более
    
    Returns:
    
    значение: от 0 и более - целевая страница кеша, или -1 (и меньше) - страница не спроецирована
  - persist2cache_mut
```
protected int persist2cache_mut(int persistPage)
```
  - cache2persist
```
protected int cache2persist(int cachePage)
```
    Description copied from class: CachePagedDataBase
    
    Возвращает индекс постоянной страницы для кешированной страницы
    
    Overrides:
    
    cache2persist in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    cachePage - кешированная страница, допустимые значения: от 0 и более
    
    Returns:
    
    значение: от 0 и более - постоянная страница (индекс), или -1 (и меньше) - страница не спроецирована (свободная ячейка кеша)
  - cache2persist_mut
```
protected int cache2persist_mut(int cachePage)
```
    Overrides:
    
    cache2persist_mut in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - dirty
```
protected boolean dirty(int cachePage)
```
    Description copied from class: CachePagedDataBase
    
    Проверка, что страница является "грязной"
    
    Overrides:
    
    dirty in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    cachePage - индекс страницы кеша
    
    Returns:
    
    true - содержит не сохраненные изменения
  - dirty_mut
```
protected boolean dirty_mut(int cachePage)
```
    Overrides:
    
    dirty_mut in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - flush
```
protected int flush(int cachePage)
```
    Description copied from class: CachePagedDataBase
    
    Сохранение страницы кеша
    
    Overrides:
    
    flush in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    cachePage - индекс страницы кеша
    
    Returns:
    
    индекс persistentPage или значение меньше 0
  - flush_mut
```
protected int flush_mut(int cachePage)
```
    Overrides:
    
    flush_mut in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - flush
```
public void flush()
```
    Description copied from interface: Flushable
    
    Принудительная запись накопившийся изменений на диск/носитель информации
    
    Specified by:
    
    flush in interface Flushable
    
    Overrides:
    
    flush in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - unmap
```
protected int unmap(int cachePage)
```
    Description copied from class: CachePagedDataBase
    
    выгрузка страницы
    
    Overrides:
    
    unmap in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    cachePage - страница
    
    Returns:
    
    индекс persistentPage или значение меньше 0
  - cleanDirtyPages
```
protected xyz.cofe.fn.Tuple2<List<Integer>,List<Integer>> cleanDirtyPages()
```
    Description copied from class: CachePagedDataBase
    
    Получение списка чистых/грязных страниц
    
    Overrides:
    
    cleanDirtyPages in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Returns:
    
    чистые/грязные страницы (cachePage)
  - unmapCandidate
```
protected int unmapCandidate(List<Integer> pages,
                             boolean clean)
```
    Description copied from class: CachePagedDataBase
    
    Выбор кандидата (страница кеша) на выгрузку
    
    Overrides:
    
    unmapCandidate in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    pages - список страниц из которых выбор
    
    clean - true - это список чистых страниц,
    false - это список грязных страниц
    
    Returns:
    
    страница или -1 (и меньше),
  - allocCachePage
```
protected int allocCachePage()
```
    Description copied from class: CachePagedDataBase
    Выделение свободной страницы
    Возможные сценарии
    
    В кеше есть еще не размеченная область cache2prst[x] < 0
    
    В кеше есть чистые страницы которые можно занять
    
    В кеше нет чистых страниц, необходимо выгружать страницу
    
    Используется в CachePagedDataBase.readPage_alloc(int), CachePagedDataBase.writePage_alloc(int, byte[])
    Overrides:
    
    allocCachePage in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Returns:
    
    индекс страницы
  - map
```
protected byte[] map(int cachePage,
                     int persistPage)
```
    Description copied from class: CachePagedDataBase
    
    Проецирование страницы из постоянной памяти на кеш
    
    Overrides:
    
    map in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    cachePage - страница кеш-памяти
    
    persistPage - страница постоянной памяти
    
    Returns:
    
    содержание спроецированной страницы
  - readPage
```
public byte[] readPage(int page)
```
    Description copied from class: CachePagedDataBase
    Чтение страницы.
    Варианты
    
    Страница спроецирована
    Страница не спроецирована
    
    необходимо - выделить свободную страницу в кеше
    если не достигнут предел по кешу
    
    тогда занять свободную страницу
    иначе выгрузить редко используемую страницу и занять ее
    Specified by:
    
    readPage in interface PagedData<UsedPagesInfo>
    
    Overrides:
    
    readPage in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    page - индекс страницы, от 0 и более
    
    Returns:
    
    массив байтов, по размеру равный UsedPagesInfo.pageSize() или меньше, если последняя страница
  - readPage_mapped
```
protected byte[] readPage_mapped(int cidx,
                                 int page)
```
    Overrides:
    
    readPage_mapped in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - readPage_alloc
```
protected byte[] readPage_alloc(int page)
```
    Overrides:
    
    readPage_alloc in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - writePage
```
public void writePage(int page,
                      byte[] data)
```
    Description copied from class: CachePagedDataBase
    Запись страницы
    Возможные варианты
    Страница спроецирована (CachePagedDataBase.writePage_mapped(int, int, byte[]))
    
    изменить страницу в кеше
    отметить страницу как dirty (auto)
    
    Страница не спроецирована (CachePagedDataBase.writePage_alloc(int, byte[]))
    
    необходимо - выделить свободную страницу в кеше
    
    если не достигнут предел по кешу
    
    тогда занять свободную страницу
    иначе выгрузить редко используемую страницу и занять ее
    
    если data меньше pageSize
    
    считать страницу из persist в cache
    
    изменить страницу в кеше
    отметить страницу как dirty (auto)
    Specified by:
    
    writePage in interface PagedData<UsedPagesInfo>
    
    Overrides:
    
    writePage in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    page - индекс страницы, от 0 и более
    
    data - массив байтов, размер не должен превышать UsedPagesInfo.pageSize()
  - writePage_mapped
```
protected void writePage_mapped(int cidx,
                                int page,
                                byte[] data)
```
    Overrides:
    
    writePage_mapped in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - writePage_alloc
```
protected void writePage_alloc(int page,
                               byte[] data)
```
    Overrides:
    
    writePage_alloc in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
  - extendPages
```
public xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo> extendPages(int pages)
```
    Description copied from interface: ExtendablePages
    
    Расширение кол-ва используемых страниц
    
    Specified by:
    
    extendPages in interface ExtendablePages<UsedPagesInfo>
    
    Overrides:
    
    extendPages in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    pages - сколько страниц нужно добавить
    
    Returns:
    
    Сколько было и сколько стало памяти
  - reducePages
```
public xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo> reducePages(int pages)
```
    Description copied from interface: ReduciblePages
    
    Уменьшение кол-ва используемых страниц
    
    Specified by:
    
    reducePages in interface ReduciblePages<UsedPagesInfo>
    
    Overrides:
    
    reducePages in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    pages - сколько страниц нужно убрать
    
    Returns:
    
    Сколько было и сколько стало памяти
  - resizeCachePages
```
public xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo> resizeCachePages(int pages)
```
    Description copied from class: CachePagedDataBase
    
    Изменение размера кеша.
    
    Overrides:
    
    resizeCachePages in class CachePagedDataBase<CCachePagedData.State,UsedPagesInfo,DirtyPagedDataSafe>
    
    Parameters:
    
    pages - сколько страниц отвести под кеш
    
    Returns:
    
    Сколько было и сколько стало памяти
  - resizePages
```
public xyz.cofe.fn.Tuple2<UsedPagesInfo,UsedPagesInfo> resizePages(int pages)
```
    Description copied from interface: ResizablePages
    
    Изменение кол-ва выделенных страниц
    
    Specified by:
    
    resizePages in interface ResizablePages<UsedPagesInfo>
    
    Parameters:
    
    pages - целевое кол-во страниц
    
    Returns:
    
    Сколько было и сколько стало памяти
  - lockPersistPages
```
protected List<Lock> lockPersistPages(int from,
                                      int toExc,
                                      Function<ReadWriteLock,Lock> lockType)
```
  - writePageLock
```
public void writePageLock(int from,
                          int toExc,
                          Runnable code)
```
    Description copied from interface: PageLock
    
    Блокировка диапазона страниц для записи - эксклюзивная блокировка
    
    Specified by:
    
    writePageLock in interface PageLock
    
    Parameters:
    
    from - начало диапазона
    
    toExc - (исключительно) конец диапазона
    
    code - код исполняемый во время блокировки
  - readPageLock
```
public void readPageLock(int from,
                         int toExc,
                         Runnable code)
```
    Description copied from interface: PageLock
    
    Блокировка диапазона страниц для чтения - shared блокировка
    
    Specified by:
    
    readPageLock in interface PageLock
    
    Parameters:
    
    from - начало диапазона
    
    toExc - (исключительно) конец диапазона
    
    code - код исполняемый во время блокировки

Class CCachePagedData

Nested Class Summary

Field Summary

Fields inherited from class xyz.cofe.cbuffer.page.CachePagedDataBase

Constructor Summary

Method Summary

Methods inherited from class xyz.cofe.cbuffer.page.CachePagedDataBase

Methods inherited from class java.lang.Object

Field Detail

closeSync

Constructor Detail

CCachePagedData

CCachePagedData

Method Detail

isClosed

close

memoryInfo

persist2cache

persist2cache_mut

cache2persist

cache2persist_mut

dirty

dirty_mut

flush

flush_mut

flush

unmap

cleanDirtyPages

unmapCandidate

allocCachePage

map

readPage

readPage_mapped

readPage_alloc

writePage

writePage_mapped

writePage_alloc

extendPages

reducePages

resizeCachePages

resizePages

lockPersistPages

writePageLock

readPageLock