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, PageLockListener

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.Stripe

Field Summary

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

bucketsSize, changed, name

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

grpId, pageMem, reuseList, rnd, wal

Constructor Summary

Constructors

Constructor and Description
ReuseListImpl(int cacheId, String name, PageMemory pageMem, IgniteWriteAheadLogManager wal, long metaPageId, boolean initNew)

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 boolean	isReuseBucket(int bucket)
long	recycledPagesCount()
long	takeRecycledPage()
String	toString()

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

init, put, removeDataPage, saveMetadata, storedPagesCount, takeEmptyPage

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

acquirePage, allocatePage, allocatePageNoReuse, groupId, init, needWalDeltaRecord, onBeforeReadLock, onBeforeWriteLock, onReadLock, onReadUnlock, onWriteLock, onWriteUnlock, 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)
              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.

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.

toString

public String toString()

Overrides:

toString in class Object