protected class AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile extends AbstractJournalRM.JournalFile
AbstractJournalRM.JournalFile
implementation returned when the journal has consumed all known capacity. This implementation triggers an exhaustive evacuation
ensuring data structures are compact thus any released memory is reclaimed.m_cbReleased, m_cbWritten, m_fNotifiedFull, m_jrnlfileNext, m_lStateOffset, m_nFile, STATE_APPENDING, STATE_CONGESTION, STATE_DISCARDED, STATE_EVACUATING, STATE_FULL, STATE_GARBAGE, STATE_MASK, STATE_RESERVED
Constructor and Description |
---|
InvokeGCJournalFile()
Construct a Journal File.
|
Modifier and Type | Method and Description |
---|---|
void |
dispose()
Invoked when all resources owned by the implementer can safely be released.
|
long |
enqueue(Binary bin)
Enqueue a Binary value to be written to this file, returning a ticket, or return 0L if this file is full and the append has to occur to a new file.
|
Binary |
read(long lTicket)
Read the Binary associated with the specified ticket from the journal file.
|
compareAndSetOffset, compareAndSetState, evacuate, getBytesWritten, getDescription, getFileId, getNextJournalFile, getOffset, getOffset, getReleased, getState, getState, isAppending, isReserved, notifyWriteCompleted, release, setNextJournalFile, setReserved, setState, toString, touch
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close
public long enqueue(Binary bin)
enqueue
in class AbstractJournalRM.JournalFile
bin
- the value to append to the journal filepublic Binary read(long lTicket)
read
in class AbstractJournalRM.JournalFile
lTicket
- a ticket previously returned from AbstractJournalRM.JournalFile.enqueue(com.tangosol.util.Binary)
public void dispose()
Once disposed of the object should no longer be considered to be usable.
Note the Disposable interface is compatible with try-with-resources which will automatically invoke this method.
dispose
in interface Disposable
dispose
in class AbstractJournalRM.JournalFile