Skip navigation links

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:

com.oracle.common.base.Disposable

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

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

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

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

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

RamJournalRM.JournalFile

public RamJournalRM.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 java.lang.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()

Specified by:

dispose in interface com.oracle.common.base.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

Skip navigation links