Package org.terracotta.offheapstore.storage.listener

Class AbstractListenableStorageEngine<K,V>

java.lang.Object

org.terracotta.offheapstore.storage.listener.AbstractListenableStorageEngine<K,V>

All Implemented Interfaces:

ListenableStorageEngine<K,V>

Direct Known Subclasses:

PortabilityBasedStorageEngine

public abstract class AbstractListenableStorageEngine<K,V>
extends java.lang.Object
implements ListenableStorageEngine<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.Set<RecoveryStorageEngineListener<? super K,? super V>>	recoveryListeners
private java.util.Set<RuntimeStorageEngineListener<? super K,? super V>>	runtimeListeners

Constructor Summary

Constructors

Constructor	Description
AbstractListenableStorageEngine()

Method Summary

Modifier and Type	Method	Description
protected void	fireCleared()
protected void	fireCopied(int hash, long oldEncoding, long newEncoding, int metadata)
protected void	fireFreed(long encoding, int hash, java.nio.ByteBuffer binaryKey, boolean removed)
protected void	fireRecovered(java.util.concurrent.Callable<K> key, java.util.concurrent.Callable<V> value, java.nio.ByteBuffer binaryKey, java.nio.ByteBuffer binaryValue, int hash, int metadata, long encoding)
protected void	fireWritten(K key, V value, java.nio.ByteBuffer binaryKey, java.nio.ByteBuffer binaryValue, int hash, int metadata, long encoding)
protected boolean	hasListeners()
protected boolean	hasRecoveryListeners()
void	registerListener(StorageEngineListener<? super K,? super V> listener)

Methods inherited from class java.lang.Object

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

Field Detail

runtimeListeners

private final java.util.Set<RuntimeStorageEngineListener<? super K,? super V>> runtimeListeners

recoveryListeners

private final java.util.Set<RecoveryStorageEngineListener<? super K,? super V>> recoveryListeners

Constructor Detail

AbstractListenableStorageEngine

public AbstractListenableStorageEngine()

Method Detail

registerListener

public void registerListener(StorageEngineListener<? super K,? super V> listener)

Specified by:

registerListener in interface ListenableStorageEngine<K,V>

hasListeners

protected final boolean hasListeners()

hasRecoveryListeners

protected final boolean hasRecoveryListeners()

fireRecovered

protected final void fireRecovered(java.util.concurrent.Callable<K> key,
                                   java.util.concurrent.Callable<V> value,
                                   java.nio.ByteBuffer binaryKey,
                                   java.nio.ByteBuffer binaryValue,
                                   int hash,
                                   int metadata,
                                   long encoding)

fireWritten

protected final void fireWritten(K key,
                                 V value,
                                 java.nio.ByteBuffer binaryKey,
                                 java.nio.ByteBuffer binaryValue,
                                 int hash,
                                 int metadata,
                                 long encoding)

fireFreed

protected final void fireFreed(long encoding,
                               int hash,
                               java.nio.ByteBuffer binaryKey,
                               boolean removed)

fireCleared

protected final void fireCleared()

fireCopied

protected final void fireCopied(int hash,
                                long oldEncoding,
                                long newEncoding,
                                int metadata)