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

Class PagesList

java.lang.Object

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

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

Direct Known Subclasses:

AbstractFreeList, ReuseListImpl

public abstract class PagesList
extends DataStructure

Striped doubly-linked list of page IDs optionally organized in buckets.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PagesList.PagesCache Class to store page-list cache onheap.
static class	PagesList.Stripe

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicLongArray	bucketsSize
protected boolean	changed
protected IgniteLogger	log Logger.
protected String	name Name (for debug purposes).

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

grpId, grpName, lockLsnr, NOOP_LSNR, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PagesList(int cacheId, String name, PageMemory pageMem, int buckets, IgniteWriteAheadLogManager wal, long metaPageId, PageLockListener lockLsnr, GridKernalContext ctx)

Method Summary

Modifier and Type	Method and Description
int	bucketsCount() Buckets count.
long	bucketSize(int bucket) Bucket size.
int	cachedPagesCount(int bucket) Cached pages count.
protected abstract boolean	casBucket(int bucket, PagesList.Stripe[] exp, PagesList.Stripe[] upd)
protected abstract PagesList.Stripe[]	getBucket(int bucket)
protected abstract PagesList.PagesCache	getBucketCache(int bucket, boolean create)
protected abstract int	getBucketIndex(int freeSpace) Gets bucket index by page freespace.
protected void	init(long metaPageId, boolean initNew)
protected long	initReusedPage(long reusedPageId, long reusedPage, long reusedPageAddr, int partId, byte flag, PageIO initIo) Reused page must obtain correctly assembled page id, then initialized by proper PageIO instance and non-zero itemId of reused page id must be saved into special place.
protected abstract boolean	isReuseBucket(int bucket)
String	name() Pages list name.
protected void	put(@Nullable ReuseBag bag, long dataId, long dataPage, long dataAddr, int bucket, IoStatisticsHolder statHolder)
protected boolean	removeDataPage(long dataId, long dataPage, long dataAddr, AbstractDataPageIO dataIO, int bucket, IoStatisticsHolder statHolder) Removes data page from bucket, merges bucket list if needed.
void	saveMetadata(IoStatisticsHolder statHolder) Save metadata without exclusive lock on it.
protected long	storedPagesCount(int bucket) !!!
int	stripesCount(int bucket) Stripes count.
protected long	takeEmptyPage(int bucket, @Nullable IOVersions initIoVers, IoStatisticsHolder statHolder)

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, toString, wait, wait, wait

Field Detail

bucketsSize

protected final AtomicLongArray bucketsSize

changed

protected volatile boolean changed

name

protected final String name

Name (for debug purposes).

log

protected final IgniteLogger log

Logger.

Constructor Detail

PagesList

protected PagesList(int cacheId,
                    String name,
                    PageMemory pageMem,
                    int buckets,
                    IgniteWriteAheadLogManager wal,
                    long metaPageId,
                    PageLockListener lockLsnr,
                    GridKernalContext ctx)

Parameters:

cacheId - Cache ID.

name - Name (for debug purpose).

pageMem - Page memory.

buckets - Number of buckets.

wal - Write ahead log manager.

metaPageId - Metadata page ID.

Method Detail

init

protected final void init(long metaPageId,
                          boolean initNew)
                   throws IgniteCheckedException

Parameters:

metaPageId - Metadata page ID.

initNew - True if new list if created, false if should be initialized from metadata.

Throws:

IgniteCheckedException - If failed.

saveMetadata

public void saveMetadata(IoStatisticsHolder statHolder)
                  throws IgniteCheckedException

Save metadata without exclusive lock on it.

Throws:

IgniteCheckedException - If failed.

getBucketIndex

protected abstract int getBucketIndex(int freeSpace)

Gets bucket index by page freespace.

Returns:

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

getBucket

protected abstract PagesList.Stripe[] getBucket(int bucket)

Parameters:

bucket - Bucket index.

Returns:

Bucket.

casBucket

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

Parameters:

bucket - Bucket index.

exp - Expected bucket.

upd - Updated bucket.

Returns:

true If succeeded.

isReuseBucket

protected abstract boolean isReuseBucket(int bucket)

Parameters:

bucket - Bucket index.

Returns:

true If it is a reuse bucket.

getBucketCache

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

Parameters:

bucket - Bucket index.

Returns:

Bucket cache.

storedPagesCount

protected final long storedPagesCount(int bucket)
                               throws IgniteCheckedException

!!! For tests only, does not provide any correctness guarantees for concurrent access.

Parameters:

bucket - Bucket index.

Returns:

Number of pages stored in this list.

Throws:

IgniteCheckedException - If failed.

put

protected final void put(@Nullable
                         @Nullable ReuseBag bag,
                         long dataId,
                         long dataPage,
                         long dataAddr,
                         int bucket,
                         IoStatisticsHolder statHolder)
                  throws IgniteCheckedException

Parameters:

bag - Reuse bag.

dataId - Data page ID.

dataPage - Data page pointer.

dataAddr - Data page address.

bucket - Bucket.

statHolder - Statistics holder to track IO operations.

Throws:

IgniteCheckedException - If failed.

takeEmptyPage

protected long takeEmptyPage(int bucket,
                             @Nullable
                             @Nullable IOVersions initIoVers,
                             IoStatisticsHolder statHolder)
                      throws IgniteCheckedException

Parameters:

bucket - Bucket index.

initIoVers - Optional IO to initialize page.

statHolder - Statistics holder to track IO operations.

Returns:

Removed page ID.

Throws:

IgniteCheckedException - If failed.

initReusedPage

protected final long initReusedPage(long reusedPageId,
                                    long reusedPage,
                                    long reusedPageAddr,
                                    int partId,
                                    byte flag,
                                    PageIO initIo)
                             throws IgniteCheckedException

Reused page must obtain correctly assembled page id, then initialized by proper PageIO instance and non-zero itemId of reused page id must be saved into special place.

Parameters:

reusedPageId - Reused page id.

reusedPage - Reused page.

reusedPageAddr - Reused page address.

partId - Partition id.

flag - Flag.

initIo - Initial io.

Returns:

Prepared page id.

Throws:

IgniteCheckedException - In case of failure.

removeDataPage

protected final boolean removeDataPage(long dataId,
                                       long dataPage,
                                       long dataAddr,
                                       AbstractDataPageIO dataIO,
                                       int bucket,
                                       IoStatisticsHolder statHolder)
                                throws IgniteCheckedException

Removes data page from bucket, merges bucket list if needed.

Parameters:

dataId - Data page ID.

dataPage - Data page pointer.

dataAddr - Data page address.

dataIO - Data page IO.

bucket - Bucket index.

statHolder - Statistics holder to track IO operations.

Returns:

True if page was removed.

Throws:

IgniteCheckedException - If failed.

name

public String name()

Pages list name.

bucketsCount

public int bucketsCount()

Buckets count.

bucketSize

public long bucketSize(int bucket)

Bucket size.

Parameters:

bucket - Bucket.

stripesCount

public int stripesCount(int bucket)

Stripes count.

Parameters:

bucket - Bucket.

cachedPagesCount

public int cachedPagesCount(int bucket)

Cached pages count.

Parameters:

bucket - Bucket.