org.apache.ignite.internal.processors.cache.persistence.tree.reuse

Class ReuseListImpl

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.tree.reuse.ReuseListImpl

All Implemented Interfaces:

ReuseList

public class ReuseListImpl
extends PagesList
implements ReuseList

Reuse list.

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, log, name

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

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

Constructor Summary

Constructors

Constructor and Description
ReuseListImpl(int cacheId, String name, PageMemory pageMem, IgniteWriteAheadLogManager wal, long metaPageId, boolean initNew, PageLockListener lockLsnr, GridKernalContext ctx, AtomicLong pageListCacheLimit)

Method Summary

Modifier and Type	Method and Description
void	addForRecycle(ReuseBag bag)
protected boolean	casBucket(int bucket, PagesList.Stripe[] exp, PagesList.Stripe[] upd)
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.
protected boolean	isReuseBucket(int bucket)
long	recycledPagesCount()
long	takeRecycledPage()
String	toString()

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

bucketsCount, bucketSize, cachedPagesCount, init, 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

ReuseListImpl

public ReuseListImpl(int cacheId,
                     String name,
                     PageMemory pageMem,
                     IgniteWriteAheadLogManager wal,
                     long metaPageId,
                     boolean initNew,
                     PageLockListener lockLsnr,
                     GridKernalContext ctx,
                     AtomicLong pageListCacheLimit)
              throws IgniteCheckedException

Parameters:

cacheId - Cache ID.

name - Name (for debug purpose).

pageMem - Page memory.

wal - Write ahead log manager.

metaPageId - Metadata page ID.

initNew - True if new metadata should be initialized.

Throws:

IgniteCheckedException - If failed.

Method Detail

isReuseBucket

protected boolean isReuseBucket(int bucket)

Specified by:

isReuseBucket in class PagesList

Parameters:

bucket - Bucket index.

Returns:

true If it is a reuse bucket.

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.

recycledPagesCount

public long recycledPagesCount()
                        throws IgniteCheckedException

Specified by:

recycledPagesCount in interface ReuseList

Returns:

Number of recycled pages it contains.

Throws:

IgniteCheckedException - If failed.

getBucket

protected PagesList.Stripe[] getBucket(int bucket)

Specified by:

getBucket in class PagesList

Parameters:

bucket - Bucket index.

Returns:

Bucket.

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.

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.

getBucketCache

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

Specified by:

getBucketCache in class PagesList

Parameters:

bucket - Bucket index.

Returns:

Bucket cache.

toString

public String toString()

Overrides:

toString in class Object