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.WriterDaemon.notifyFileFull(FlashJournalRM.JournalFile jrnlfile) |
Notify the writer thread that a file is done being written to.
|
void |
FlashJournalRM.PreparerDaemon.notifyItemQueued(FlashJournalRM.JournalFile jrnlfile,
long lTicket) |
Notify the PreparerDaemon that an item has been queued to be written
to the specified JournalFile.
|
void |
FlashJournalRM.PreparerDaemon.notifyJournalFileFull(FlashJournalRM.JournalFile jrnlfile) |
Notify the PreparerDaemon that the specified JournalFile has been
cut off for new additions.
|
protected abstract void |
FlashJournalRM.CongestionPolicy.onCongestion(FlashJournalRM.JournalFile jrnlfile) |
Invoked when it is determined the provided jrnlfile has
become congested.
|
protected void |
FlashJournalRM.FailCongestionPolicy.onCongestion(FlashJournalRM.JournalFile jrnlfile) |
Invoked when it is determined the provided jrnlfile has
become congested.
|
protected void |
FlashJournalRM.WaitCongestionPolicy.onCongestion(FlashJournalRM.JournalFile jrnlfile) |
Invoked when it is determined the provided jrnlfile has
become congested.
|
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 boolean |
FlashJournalRM.WriterDaemon.PendingWriteTask.writeToFile(FlashJournalRM.JournalFile jrnlfile,
ByteBuffer[] aniobuf,
List listBuffer,
int cb) |
|