Skip navigation links

com.tangosol.io.journal
Class RamJournalRM.FlashConsumer

java.lang.Object
com.tangosol.io.journal.RamJournalRM.FlashConsumer

All Implemented Interfaces:

Journal.JournalConsumer, Disposable

Enclosing class:

RamJournalRM

protected class RamJournalRM.FlashConsumer

extends java.lang.Object

implements Journal.JournalConsumer

The FlashConsumer is a conduit between this RamJournalRM and the FlashJournalRM, allowing this journal to read/write to/from the other flash journal, and for the flash journal to notify this journal of lifecycle and other events.

Constructor Summary

protected

RamJournalRM.FlashConsumer()

Method Summary

void	dedupe(byte[][] aab) This method may be invoked by the Journal implementation to request that any immutable byte arrays managed by the consumer be de-duplicated.
void	dispose()
void	evacuate(long lTicketMask, long lTicketValue) This method may be invoked by the Journal implementation to request that the consumer evacuate a particular journal file.
java.lang.String	getDescription() Format a String description of the Consumer.
Journal	getJournal() Obtain the flash Journal instance.
void	notifyRamJournalDisposed() Notifies the JournalConsumer that the RamJournalRM that uses it has been disposed.
void	setJournal(Journal jrnl) Provide the FlashConsumer with a Journal instance that provides flash storage.

Constructor Detail

RamJournalRM.FlashConsumer

protected RamJournalRM.FlashConsumer()

Method Detail

evacuate

public void evacuate(long lTicketMask,
                     long lTicketValue)

This method may be invoked by the Journal implementation to request that the consumer evacuate a particular journal file.

Specified by:

evacuate in interface Journal.JournalConsumer

Parameters:

lTicketMask - indicates which bits of the tickets to check

lTicketValue - indicates what bit pattern needs to be matched on the tickets in order to select them for evacuation

dedupe

public void dedupe(byte[][] aab)

This method may be invoked by the Journal implementation to request that any immutable byte arrays managed by the consumer be de-duplicated.

Specified by:

dedupe in interface Journal.JournalConsumer

Parameters:

aab - an array of byte[] objects for intern-ing byte[] references

getDescription

public java.lang.String getDescription()

Format a String description of the Consumer.

Specified by:

getDescription in interface Journal.JournalConsumer

Returns:

a comma-delimited key-value description of this object

dispose

public void dispose()

getJournal

public Journal getJournal()

Obtain the flash Journal instance.

Returns:

the Journal that provides flash storage to the RamJournalRM

setJournal

public void setJournal(Journal jrnl)

Provide the FlashConsumer with a Journal instance that provides flash storage.

Parameters:

jrnl - a Journal from a FlashJournalRM

notifyRamJournalDisposed

public void notifyRamJournalDisposed()

Notifies the JournalConsumer that the RamJournalRM that uses it has been disposed.

Skip navigation links