Skip navigation links

com.tangosol.io.journal
Class AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile

java.lang.Object
com.tangosol.io.journal.AbstractJournalRM.JournalFile
com.tangosol.io.journal.AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile

All Implemented Interfaces:

com.oracle.common.base.Disposable

Enclosing class:

AbstractJournalRM.CollectorDaemon

protected class AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile

extends AbstractJournalRM.JournalFile

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

Field Summary

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

AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile()
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.
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, getDescription, getFileId, getNextJournalFile, getOffset, getOffset, getReleased, getState, getState, isAppending, isReserved, notifyWriteCompleted, release, setNextJournalFile, setReserved, setState, toString, touch

Constructor Detail

AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile

public AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile()

Construct a Journal File.

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

dispose

public void dispose()

Specified by:

dispose in interface com.oracle.common.base.Disposable

Specified by:

dispose in class AbstractJournalRM.JournalFile

Skip navigation links