Skip navigation links

com.tangosol.io.journal
Class FlashJournalRM.WriterDaemon.PendingWriteTask

java.lang.Object
com.tangosol.io.journal.FlashJournalRM.WriterDaemon.PendingWriteTask

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

FlashJournalRM.WriterDaemon

protected class FlashJournalRM.WriterDaemon.PendingWriteTask

extends java.lang.Object

implements java.lang.Runnable

A task that gets queued to perform an asynchronous appending write on the WriterDaemon thread.

Constructor Summary

FlashJournalRM.WriterDaemon.PendingWriteTask(FlashJournalRM.JournalFile jrnlfile, FlashJournalRM.Buffer buf, int cbBuffer)
Construct a PendingWriteInfo "struct".

Method Summary

protected void	processWriteException(java.io.IOException e, java.util.ArrayList listBuffer, java.nio.ByteBuffer[] aniobuf) Process IOException while flushing the buffers to disk
void	run() Execute the task, writing the buffer to the end of the file.

Constructor Detail

FlashJournalRM.WriterDaemon.PendingWriteTask

public FlashJournalRM.WriterDaemon.PendingWriteTask(FlashJournalRM.JournalFile jrnlfile,
                                                    FlashJournalRM.Buffer buf,
                                                    int cbBuffer)

Construct a PendingWriteInfo "struct".

Parameters:

jrnlfile - the file to append to

buf - the buffer to append

cbBuffer - the number of bytes to append from the buffer

Method Detail

run

public void run()

Execute the task, writing the buffer to the end of the file.

Specified by:

run in interface java.lang.Runnable

processWriteException

protected void processWriteException(java.io.IOException e,
                                     java.util.ArrayList listBuffer,
                                     java.nio.ByteBuffer[] aniobuf)

Process IOException while flushing the buffers to disk

Parameters:

e - the IOException

listBuffer - the list of buffers to be flushed to disk

aniobuf - the array of byte buffers to be flushed to disk

Skip navigation links