org.apache.ignite.internal.processors.cache.persistence.freelist

Class AbstractFreeList<T extends Storable>

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.DataStructure

org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

org.apache.ignite.internal.processors.cache.persistence.freelist.AbstractFreeList<T>

All Implemented Interfaces:

FreeList<T>, ReuseList

Direct Known Subclasses:

CacheFreeList, PartitionMetaStorageImpl

public abstract class AbstractFreeList<T extends Storable>
extends PagesList
implements FreeList<T>, ReuseList

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

PagesList.PagesCache, PagesList.Stripe

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

bucketsSize, changed, DFLT_PAGES_LIST_TRY_LOCK_ATTEMPTS, IGNITE_PAGES_LIST_STRIPES_PER_BUCKET, IGNITE_PAGES_LIST_TRY_LOCK_ATTEMPTS, log, name, pageCacheChanged

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.DataStructure

grpId, grpName, lockLsnr, metrics, NOOP_LSNR, pageFlag, pageIoRslvr, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor and Description
AbstractFreeList(int cacheGrpId, String name, DataRegion dataRegion, ReuseList reuseList, IgniteWriteAheadLogManager wal, long metaPageId, boolean initNew, PageLockListener lockLsnr, GridKernalContext ctx, AtomicLong pageListCacheLimit, byte pageFlag)

Method Summary

Modifier and Type	Method and Description
void	addForRecycle(ReuseBag bag)
protected boolean	casBucket(int bucket, PagesList.Stripe[] exp, PagesList.Stripe[] upd)
void	dumpStatistics(IgniteLogger log)
int	emptyDataPages()
long	freeSpace() Calculates free space tracked by this FreeListImpl instance.
protected PagesList.Stripe[]	getBucket(int bucket)
protected PagesList.PagesCache	getBucketCache(int bucket, boolean create)
protected int	getBucketIndex(int freeSpace) Gets bucket index by page freespace.
long	initRecycledPage(long pageId, byte flag, PageIO initIO) Converts recycled page id back to a usable id.
void	insertDataRow(T row, IoStatisticsHolder statHolder)
void	insertDataRows(Collection<T> rows, IoStatisticsHolder statHolder) Reduces the workload on the free list by writing multiple rows into a single memory page at once.
protected boolean	isReuseBucket(int bucket)
long	recycledPagesCount()
void	removeDataRowByLink(long link, IoStatisticsHolder statHolder)
long	takeRecycledPage()
String	toString()
<S,R> R	updateDataRow(long link, PageHandler<S,R> pageHnd, S arg, IoStatisticsHolder statHolder)
boolean	updateDataRow(long link, T row, IoStatisticsHolder statHolder)

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.freelist.PagesList

bucketsCount, bucketSize, cachedPagesCount, init, initRecycledPage0, initReusedPage, name, put, removeDataPage, saveMetadata, storedPagesCount, stripesCount, takeEmptyPage

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.DataStructure

acquirePage, allocatePage, allocatePage, allocatePageNoReuse, groupId, init, needWalDeltaRecord, pageSize, randomInt, read, read, readLock, readUnlock, recyclePage, releasePage, tryWriteLock, write, write, write, write, writeLock, writeUnlock, writeUnlock

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractFreeList

public AbstractFreeList(int cacheGrpId,
                        String name,
                        DataRegion dataRegion,
                        ReuseList reuseList,
                        IgniteWriteAheadLogManager wal,
                        long metaPageId,
                        boolean initNew,
                        PageLockListener lockLsnr,
                        GridKernalContext ctx,
                        AtomicLong pageListCacheLimit,
                        byte pageFlag)
                 throws IgniteCheckedException

Parameters:

cacheGrpId - Cache group ID.

name - Name (for debug purpose).

dataRegion - Data region.

reuseList - Reuse list or null if this free list will be a reuse list for itself.

wal - Write ahead log manager.

metaPageId - Metadata page ID.

initNew - True if new metadata should be initialized.

pageFlag - Default flag value for allocated pages.

Throws:

IgniteCheckedException - If failed.

Method Detail

freeSpace

public long freeSpace()

Calculates free space tracked by this FreeListImpl instance.

Returns:

Free space available for use, in bytes.

dumpStatistics

public void dumpStatistics(IgniteLogger log)

Specified by:

dumpStatistics in interface FreeList<T extends Storable>

Parameters:

log - Logger.

getBucketIndex

protected int getBucketIndex(int freeSpace)

Gets bucket index by page freespace.

Specified by:

getBucketIndex in class PagesList

Returns:

Bucket index or -1 if page doesn't belong to any bucket.

insertDataRow

public void insertDataRow(T row,
                          IoStatisticsHolder statHolder)
                   throws IgniteCheckedException

Specified by:

insertDataRow in interface FreeList<T extends Storable>

Parameters:

row - Row.

statHolder - Statistics holder to track IO operations.

Throws:

IgniteCheckedException - If failed.

insertDataRows

public void insertDataRows(Collection<T> rows,
                           IoStatisticsHolder statHolder)
                    throws IgniteCheckedException

Reduces the workload on the free list by writing multiple rows into a single memory page at once.

Rows are sequentially added to the page as long as there is enough free space on it. If the row is large then those fragments that occupy the whole memory page are written to other pages, and the remainder is added to the current one.

Specified by:

insertDataRows in interface FreeList<T extends Storable>

Parameters:

rows - Rows.

statHolder - Statistics holder to track IO operations.

Throws:

IgniteCheckedException - If failed.

updateDataRow

public boolean updateDataRow(long link,
                             T row,
                             IoStatisticsHolder statHolder)
                      throws IgniteCheckedException

Specified by:

updateDataRow in interface FreeList<T extends Storable>

Parameters:

link - Row link.

row - New row data.

statHolder - Statistics holder to track IO operations.

Returns:

True if was able to update row.

Throws:

IgniteCheckedException - If failed.

updateDataRow

public <S,R> R updateDataRow(long link,
                             PageHandler<S,R> pageHnd,
                             S arg,
                             IoStatisticsHolder statHolder)
                      throws IgniteCheckedException

Specified by:

updateDataRow in interface FreeList<T extends Storable>

Type Parameters:

S - Argument type.

R - Result type.

Parameters:

link - Row link.

pageHnd - Page handler.

arg - Handler argument.

statHolder - Statistics holder to track IO operations.

Returns:

Result.

Throws:

IgniteCheckedException - If failed.

removeDataRowByLink

public void removeDataRowByLink(long link,
                                IoStatisticsHolder statHolder)
                         throws IgniteCheckedException

Specified by:

removeDataRowByLink in interface FreeList<T extends Storable>

Parameters:

link - Row link.

statHolder - Statistics holder to track IO operations.

Throws:

IgniteCheckedException - If failed.

getBucket

protected PagesList.Stripe[] getBucket(int bucket)

Specified by:

getBucket in class PagesList

Parameters:

bucket - Bucket index.

Returns:

Bucket.

casBucket

protected boolean casBucket(int bucket,
                            PagesList.Stripe[] exp,
                            PagesList.Stripe[] upd)

Specified by:

casBucket in class PagesList

Parameters:

bucket - Bucket index.

exp - Expected bucket.

upd - Updated bucket.

Returns:

true If succeeded.

isReuseBucket

protected boolean isReuseBucket(int bucket)

Specified by:

isReuseBucket in class PagesList

Parameters:

bucket - Bucket index.

Returns:

true If it is a reuse bucket.

getBucketCache

protected PagesList.PagesCache getBucketCache(int bucket,
                                              boolean create)

Specified by:

getBucketCache in class PagesList

Parameters:

bucket - Bucket index.

Returns:

Bucket cache.

emptyDataPages

public int emptyDataPages()

Returns:

Number of empty data pages in free list.

addForRecycle

public void addForRecycle(ReuseBag bag)
                   throws IgniteCheckedException

Specified by:

addForRecycle in interface ReuseList

Parameters:

bag - Reuse bag.

Throws:

IgniteCheckedException - If failed.

takeRecycledPage

public long takeRecycledPage()
                      throws IgniteCheckedException

Specified by:

takeRecycledPage in interface ReuseList

Returns:

Page ID or 0 if none available.

Throws:

IgniteCheckedException - If failed.

initRecycledPage

public long initRecycledPage(long pageId,
                             byte flag,
                             PageIO initIO)
                      throws IgniteCheckedException

Converts recycled page id back to a usable id. Might modify page content as well if flag is changing.

Specified by:

initRecycledPage in interface ReuseList

Parameters:

pageId - Id of the recycled page.

flag - Flag value for the page. One of PageIdAllocator.FLAG_DATA, PageIdAllocator.FLAG_IDX or PageIdAllocator.FLAG_AUX.

initIO - Page IO to reinit reused page.

Returns:

Updated page id.

Throws:

IgniteCheckedException - If failed.

See Also:

FullPageId

recycledPagesCount

public long recycledPagesCount()
                        throws IgniteCheckedException

Specified by:

recycledPagesCount in interface ReuseList

Returns:

Number of recycled pages it contains.

Throws:

IgniteCheckedException - If failed.

toString

public String toString()

Overrides:

toString in class Object