Package org.apache.ignite.internal.pagemem

Class PageStoreManagerImpl

java.lang.Object

org.apache.ignite.internal.pagemem.PageStoreManagerImpl

All Implemented Interfaces:

PageStoreManager

public final class PageStoreManagerImpl
extends Object
implements PageStoreManager

The default implementation of PageStoreManager interface.

Constructor Summary

Constructors

Constructor	Description
PageStoreManagerImpl(int pageSize, boolean forceSync)	Constructs a new instance.

Method Summary

Modifier and Type	Method	Description
int	allocatePage(int grpId)	Allocates a page for the given page space.
void	exportStore(int grpId, Path destinationPath)	Exports the store.
boolean	isMetaPagePersisted(int grpId)	Checks if meta page for specified store is persisted.
int	metaPageId(int grpId)	Gets meta page ID for specified store.
int	pageCount(int grpId)	Gets page count.
void	read(int grpId, int pageId, ByteBuffer pageBuf)	Reads a page for the given group ID.
void	reservePage(int grpId, int pageId)	Reserves a page.
void	startStore(int grpId, Path path, boolean restorationMode)	Starts the store with the specified ID.
void	stopStore(int grpId)	Stops the store with the specified ID.
void	write(int grpId, int pageId, ByteBuffer pageBuf)	Writes the page for the given group ID.

Methods inherited from class java.lang.Object

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

Constructor Details

PageStoreManagerImpl

public PageStoreManagerImpl(int pageSize,
 boolean forceSync)

Constructs a new instance.

Parameters:

pageSize - Page size. Must be greater than 0.

forceSync -

Method Details

read

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

Description copied from interface: PageStoreManager

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

Specified by:

read in interface PageStoreManager

pageId - PageID to read.

pageBuf - Page buffer to write to.

Throws:

IgniteCheckedException - if fails.

write

public void write(int grpId,
 int pageId,
 ByteBuffer pageBuf)
           throws IgniteCheckedException

Description copied from interface: PageStoreManager

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

Specified by:

write in interface PageStoreManager

Parameters:

grpId - Group ID.

pageId - Page ID.

pageBuf - Page buffer to write.

Throws:

IgniteCheckedException - if fails.

allocatePage

public int allocatePage(int grpId)

Description copied from interface: PageStoreManager

Allocates a page for the given page space.

Specified by:

allocatePage in interface PageStoreManager

Parameters:

grpId - Group ID.

Returns:

Allocated page ID.

reservePage

public void reservePage(int grpId,
 int pageId)
                 throws IgniteCheckedException

Description copied from interface: PageStoreManager

Reserves a page.

Specified by:

reservePage in interface PageStoreManager

Parameters:

grpId - Group ID.

pageId - Page ID.

Throws:

IgniteCheckedException - if fails.

metaPageId

public int metaPageId(int grpId)

Description copied from interface: PageStoreManager

Gets meta page ID for specified store.

Specified by:

metaPageId in interface PageStoreManager

Parameters:

grpId - Group ID.

Returns:

Meta page ID.

isMetaPagePersisted

public boolean isMetaPagePersisted(int grpId)
                            throws IgniteCheckedException

Description copied from interface: PageStoreManager

Checks if meta page for specified store is persisted.

Specified by:

isMetaPagePersisted in interface PageStoreManager

Parameters:

grpId - Group ID.

Returns:

true if persisted, false otherwise.

Throws:

IgniteCheckedException - if fails.

pageCount

public int pageCount(int grpId)

Description copied from interface: PageStoreManager

Gets page count.

Specified by:

pageCount in interface PageStoreManager

Parameters:

grpId - Group ID.

Returns:

Page count.

startStore

public void startStore(int grpId,
 Path path,
 boolean restorationMode)
                throws IgniteCheckedException

Description copied from interface: PageStoreManager

Starts the store with the specified ID.

Specified by:

startStore in interface PageStoreManager

Parameters:

grpId - Group ID.

path - Path.

restorationMode - Flag indicating restoration mode.

Throws:

IgniteCheckedException - if fails.

stopStore

public void stopStore(int grpId)
               throws IgniteCheckedException

Description copied from interface: PageStoreManager

Stops the store with the specified ID.

Specified by:

stopStore in interface PageStoreManager

Parameters:

grpId - Group ID.

Throws:

IgniteCheckedException - if fails.

exportStore

public void exportStore(int grpId,
 Path destinationPath)
                 throws IgniteCheckedException

Description copied from interface: PageStoreManager

Exports the store.

Specified by:

exportStore in interface PageStoreManager

Parameters:

grpId - Group ID.

destinationPath - destination path.

Throws:

IgniteCheckedException - if fails.