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

Class DelayedDirtyPageWrite

java.lang.Object

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

All Implemented Interfaces:

ReplacedPageWriter

public class DelayedDirtyPageWrite
extends Object
implements ReplacedPageWriter

Not thread safe and stateful class for page replacement of one page with write() delay. This allows to write page content without holding segment lock. Page data is copied into temp buffer during writePage(FullPageId, ByteBuffer, int) and then sent to real implementation by finishReplacement().

Constructor Summary

Constructors

Constructor and Description
DelayedDirtyPageWrite(ReplacedPageWriter flushDirtyPage, ThreadLocal<ByteBuffer> byteBufThreadLoc, int pageSize, DelayedPageReplacementTracker tracker)

Method Summary

Modifier and Type	Method and Description
void	finishReplacement() Runs actual write if required.
void	writePage(FullPageId fullPageId, ByteBuffer byteBuf, int tag)

Methods inherited from class java.lang.Object

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

Constructor Detail

DelayedDirtyPageWrite

public DelayedDirtyPageWrite(ReplacedPageWriter flushDirtyPage,
                             ThreadLocal<ByteBuffer> byteBufThreadLoc,
                             int pageSize,
                             DelayedPageReplacementTracker tracker)

Parameters:

flushDirtyPage - real writer to save page to store.

byteBufThreadLoc - thread local buffers to use for pages copying.

pageSize - page size.

tracker - tracker to lock/unlock page reads.

Method Detail

writePage

public void writePage(FullPageId fullPageId,
                      ByteBuffer byteBuf,
                      int tag)

Specified by:

writePage in interface ReplacedPageWriter

Parameters:

fullPageId - Full page ID being evicted.

byteBuf - Buffer with page data.

tag - partition update tag, increasing counter.

finishReplacement

public void finishReplacement()
                       throws IgniteCheckedException

Runs actual write if required. Method is 'no op' if there was no page selected for replacement.

Throws:

IgniteCheckedException - if write failed.