protected class RamJournalRM.JournalFile extends AbstractJournalRM.JournalFile
Modifier and Type | Field and Description |
---|---|
protected ReadBuffer |
m_bufRead
The buffer that accesses the file contents.
|
protected WriteBuffer |
m_bufWrite
The buffer that stores the file contents.
|
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 |
---|
JournalFile(int nFile)
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.
|
protected String |
getDescription()
Format the object attributes into a String for inclusion in the String returned from the
AbstractJournalRM.JournalFile.toString() method. |
void |
notifyWriteCompleted()
Called by the CollectorDaemon the first time that the JournalFile is encountered in its FULL state and its data has all been written.
|
Binary |
read(long lTicket)
Read the Binary associated with the specified ticket from the journal file.
|
compareAndSetOffset, compareAndSetState, evacuate, getBytesWritten, getFileId, getNextJournalFile, getOffset, getOffset, getReleased, getState, getState, isAppending, isReserved, release, setNextJournalFile, setReserved, setState, toString, touch
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
close
protected volatile WriteBuffer m_bufWrite
protected volatile ReadBuffer m_bufRead
public JournalFile(int nFile)
nFile
- the file number in the range 0-511 (inclusive)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)
protected String getDescription()
AbstractJournalRM.JournalFile.toString()
method.getDescription
in class AbstractJournalRM.JournalFile
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
public void notifyWriteCompleted()
notifyWriteCompleted
in class AbstractJournalRM.JournalFile