com.tangosol.io.journal

Class RamJournalRM.JournalFile

java.lang.Object

com.tangosol.io.journal.AbstractJournalRM.JournalFile

com.tangosol.io.journal.RamJournalRM.JournalFile

All Implemented Interfaces:

Disposable, AutoCloseable

Enclosing class:

RamJournalRM

protected class RamJournalRM.JournalFile
extends AbstractJournalRM.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

Fields

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.

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, STATE_RESERVED

Constructor Summary

Constructors

Constructor and Description
JournalFile(int nFile) Construct a Journal File.

Method Summary

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.

Methods inherited from class com.tangosol.io.journal.AbstractJournalRM.JournalFile

compareAndSetOffset, compareAndSetState, evacuate, getBytesWritten, getFileId, getNextJournalFile, getOffset, getOffset, getReleased, getState, getState, isAppending, isReserved, release, setNextJournalFile, setReserved, setState, toString, touch

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.oracle.common.base.Disposable

close

Field Detail

m_bufWrite

protected volatile WriteBuffer m_bufWrite

The buffer that stores the file contents.

m_bufRead

protected volatile ReadBuffer m_bufRead

The buffer that accesses the file contents.

Constructor Detail

JournalFile

public JournalFile(int nFile)

Construct a Journal File.

Parameters:

nFile - the file number in the range 0-511 (inclusive)

Method Detail

enqueue

public 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.

Specified by:

enqueue in class AbstractJournalRM.JournalFile

Parameters:

bin - the value to append to the journal file

Returns:

a ticket if the Binary has successfully been enqueued, or 0L if the file is full

read

public Binary read(long lTicket)

Read the Binary associated with the specified ticket from the journal file.

Specified by:

read in class AbstractJournalRM.JournalFile

Parameters:

lTicket - a ticket previously returned from AbstractJournalRM.JournalFile.enqueue(com.tangosol.util.Binary)

Returns:

the Binary value that is associated with the ticket

getDescription

protected String getDescription()

Format the object attributes into a String for inclusion in the String returned from the AbstractJournalRM.JournalFile.toString() method.

Overrides:

getDescription in class AbstractJournalRM.JournalFile

Returns:

a comma-delimited String listing the attributes of this object in the form "attribute=value"

dispose

public void dispose()

Invoked when all resources owned by the implementer can safely be released.

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.

Specified by:

dispose in interface Disposable

Specified by:

dispose in class AbstractJournalRM.JournalFile

notifyWriteCompleted

public 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.

Overrides:

notifyWriteCompleted in class AbstractJournalRM.JournalFile