Package | Description |
---|---|
com.tangosol.io.journal |
Contains classes related to the journaling services.
|
Modifier and Type | Method and Description |
---|---|
FlashJournalRM.Buffer |
FlashJournalRM.BufferPool.allocate(byte[] abOv)
Allocate a buffer from the buffer pool.
|
FlashJournalRM.Buffer |
FlashJournalRM.JournalFile.allocateBuffer()
Allocate a Buffer to use with this JournalFile.
|
FlashJournalRM.Buffer |
FlashJournalRM.Buffer.getNext()
Get the next buffer in a linked list of buffers.
|
Modifier and Type | Method and Description |
---|---|
void |
FlashJournalRM.WriterDaemon.enqueueBuffer(FlashJournalRM.JournalFile jrnlfile,
FlashJournalRM.Buffer buf,
int cbBuffer)
Notify the writer thread that a buffer needs to be written.
|
void |
FlashJournalRM.BufferPool.release(FlashJournalRM.Buffer buf)
Return a buffer to the pool.
|
void |
FlashJournalRM.Buffer.setNext(FlashJournalRM.Buffer buf)
Set the next buffer in a linked list of buffers.
|
Modifier and Type | Method and Description |
---|---|
protected void |
FlashJournalRM.WriterDaemon.PendingWriteTask.processWriteException(IOException ioe,
List<FlashJournalRM.Buffer> listBuffer,
ByteBuffer[] aniobuf,
FlashJournalRM.JournalFile jrnlfile)
Process IOException while flushing the buffers to disk.
|
protected void |
FlashJournalRM.WriterDaemon.PendingWriteTask.writeRemainder(IOException e,
List<FlashJournalRM.Buffer> listBuffer,
ByteBuffer[] aniobuf,
boolean fSingleBlockWrite)
Write what has not been written (remainder) to disk.
|
Constructor and Description |
---|
PendingWriteTask(FlashJournalRM.JournalFile jrnlfile,
FlashJournalRM.Buffer buf,
int cbBuffer)
Construct a PendingWriteInfo "struct".
|