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

Class PageReadWriteManagerImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.persistence.pagemem.PageReadWriteManagerImpl

All Implemented Interfaces:

PageReadWriteManager

Direct Known Subclasses:

DefragmentationPageReadWriteManager

public class PageReadWriteManagerImpl
extends Object
implements PageReadWriteManager

Field Summary

Fields

Modifier and Type	Field and Description
protected PageStoreCollection	pageStores

Constructor Summary

Constructors

Constructor and Description
PageReadWriteManagerImpl(GridKernalContext ctx, PageStoreCollection pageStores, String name)

Method Summary

Modifier and Type	Method and Description
long	allocatePage(int grpId, int partId, byte flags) Allocates a page for the given page space.
void	read(int grpId, long pageId, ByteBuffer pageBuf, boolean keepCrc) Reads a page for the given cache ID.
String	toString()
PageStore	write(int grpId, long pageId, ByteBuffer pageBuf, int tag, boolean calculateCrc) Writes the page for the given cache ID.

Methods inherited from class java.lang.Object

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

Field Detail

pageStores

@GridToStringExclude
protected final PageStoreCollection pageStores

Constructor Detail

PageReadWriteManagerImpl

public PageReadWriteManagerImpl(GridKernalContext ctx,
                                PageStoreCollection pageStores,
                                String name)

Parameters:

ctx - Kernal context.

pageStores - Page stores.

Method Detail

read

public void read(int grpId,
                 long pageId,
                 ByteBuffer pageBuf,
                 boolean keepCrc)
          throws IgniteCheckedException

Reads a page for the given cache ID. Cache ID may be 0 if the page is a meta page.

Specified by:

read in interface PageReadWriteManager

Parameters:

grpId - Cache group ID.

pageId - PageID to read.

pageBuf - Page buffer to write to.

keepCrc - Keep CRC flag.

Throws:

IgniteCheckedException - If failed to read the page.

write

public PageStore write(int grpId,
                       long pageId,
                       ByteBuffer pageBuf,
                       int tag,
                       boolean calculateCrc)
                throws IgniteCheckedException

Writes the page for the given cache ID. Cache ID may be 0 if the page is a meta page.

Specified by:

write in interface PageReadWriteManager

Parameters:

grpId - Cache group ID.

pageId - Page ID.

pageBuf - Page buffer to write.

Throws:

IgniteCheckedException - If failed to write page.

allocatePage

public long allocatePage(int grpId,
                         int partId,
                         byte flags)
                  throws IgniteCheckedException

Allocates a page for the given page space.

Specified by:

allocatePage in interface PageReadWriteManager

Parameters:

grpId - Cache group ID.

partId - Partition ID. Used only if flags is equal to PageIdAllocator.FLAG_DATA.

flags - Page allocation flags.

Returns:

Allocated page ID.

Throws:

IgniteCheckedException - If IO exception occurred while allocating a page ID.

toString

public String toString()

Overrides:

toString in class Object