Package | Description |
---|---|
com.tangosol.io.journal |
Contains classes related to the journaling services.
|
Modifier and Type | Method and Description |
---|---|
protected FlashJournalRM.JournalFile |
FlashJournalRM.getJournalFile(int nFileId)
Obtain a JournalFile by its ID.
|
FlashJournalRM.JournalFile |
FlashJournalRM.JournalFile.getNextJournalFile()
Determine the JournalFile for the file in the journal that follows the file represented by this JournalFile.
|
protected FlashJournalRM.JournalFile |
FlashJournalRM.instantiateJournalFile(int nFile)
Factory: Instantiate a JournalFile or subclass thereof.
|
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.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.WaitCongestionPolicy.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.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)
Write the provided buffers to the
FlashJournalRM.JournalFile . |
Constructor and Description |
---|
FileFullTask(FlashJournalRM.JournalFile jrnlfile)
Construct a FileFullInfo "struct".
|
PendingWriteTask(FlashJournalRM.JournalFile jrnlfile, FlashJournalRM.Buffer buf, int cbBuffer)
Construct a PendingWriteInfo "struct".
|