|
Oracle® Coherence Java API Reference Release 3.7.1.0 E22843-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.tangosol.io.journal.AbstractJournalRM.JournalFile
com.tangosol.io.journal.RamJournalRM.JournalFile
protected class RamJournalRM.JournalFile
A JournalFile is created for each RAM buffer used to store the journal contents. It is created in an initial "append" mode, it then transitions to a "full" mode, and once enough of its storage has been released it transitions to an "evacuating" mode, which (once evacuated) becomes "garbage" and (upon deletion) is "discarded".
Field Summary | |
---|---|
protected ReadBuffer |
m_bufRead The buffer that accesses the file contents. |
protected WriteBuffer |
m_bufWrite The buffer that stores the file contents. |
Fields inherited from class com.tangosol.io.journal.AbstractJournalRM.JournalFile |
---|
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 |
Constructor Summary | |
---|---|
RamJournalRM.JournalFile(int nFile) Construct a Journal File. |
Method Summary | |
---|---|
void |
dispose() |
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 java.lang.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. |
Methods inherited from class com.tangosol.io.journal.AbstractJournalRM.JournalFile |
---|
evacuate, getBytesWritten, getFileId, getNextJournalFile, getOffset, getReleased, getState, isAppending, release, setNextJournalFile, setState, toString, touch |
Field Detail |
---|
protected volatile WriteBuffer m_bufWrite
protected volatile ReadBuffer m_bufRead
Constructor Detail |
---|
public RamJournalRM.JournalFile(int nFile)
nFile
- the file number in the range 0-511 (inclusive)Method Detail |
---|
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 java.lang.String getDescription()
AbstractJournalRM.JournalFile.toString()
method.getDescription
in class AbstractJournalRM.JournalFile
public void dispose()
dispose
in class AbstractJournalRM.JournalFile
public void notifyWriteCompleted()
notifyWriteCompleted
in class AbstractJournalRM.JournalFile
|
Oracle® Coherence Java API Reference Release 3.7.1.0 E22843-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |