Package com.illumon.iris.db.v2
Class BaseTable.ListenerImpl
java.lang.Object
com.illumon.util.referencecounting.ReferenceCounted
com.illumon.iris.db.util.liveness.LivenessArtifact
com.illumon.iris.db.v2.InstrumentedListenerBase
com.illumon.iris.db.v2.InstrumentedListener
com.illumon.iris.db.v2.BaseTable.ListenerImpl
- All Implemented Interfaces:
com.fishlib.base.log.LogOutputAppendable,NotificationQueue.Dependency,LivenessManager,LivenessNode,LivenessReferent,Listener,ListenerBase,Serializable
- Enclosing class:
- BaseTable
public static class BaseTable.ListenerImpl extends InstrumentedListener
Simplest appropriate legacy InstrumentedListener implementation for BaseTable and descendants.
It's expected that most use-cases will require overriding onUpdate() - the default implementation simply passes
index updates through to the dependent's listeners.
It is preferred to use
BaseTable.ShiftAwareListenerImpl over BaseTable.ListenerImpl- See Also:
- Serialized Form
-
Nested Class Summary
Nested classes/interfaces inherited from class com.illumon.iris.db.v2.InstrumentedListener
InstrumentedListener.NotificationNested classes/interfaces inherited from class com.illumon.iris.db.v2.InstrumentedListenerBase
InstrumentedListenerBase.ErrorNotification, InstrumentedListenerBase.NotificationBase -
Constructor Summary
Constructors Constructor Description ListenerImpl(String description, DynamicTable parent, DynamicTable dependent) -
Method Summary
Modifier and Type Method Description booleancanExecute(long step)Check if this listener is ready to execute.protected voiddestroy()Attempt to release (destructively when necessary) resources held by this object.voiddropReference()Drop a previously-retained reference to this referent.WeakReference<? extends LivenessReferent>getWeakReference()Get aWeakReferenceto this referent.voidinitializeTransientFieldsForLiveness()Package-private forSerializablesub-classes to use inreadObjectonly.voidonFailureInternal(Throwable originalException, UpdatePerformanceTracker.Entry sourceEntry)protected voidonReferenceCountAtZero()Callback method that will be invoked when the reference count returns to zero.voidonUpdate(Index added, Index removed, Index modified)Process notification of table changes.booleantryManage(LivenessReferent referent)Attempt to add the specified referent to this manager.booleantryRetainReference()If this referent is "live", behave asLivenessReferent.retainReference()and return true.Methods inherited from class com.illumon.iris.db.v2.InstrumentedListener
getNotification, setInitialImageMethods inherited from class com.illumon.iris.db.v2.InstrumentedListenerBase
append, getEntry, getErrorNotification, onFailure, onFailureInternalWithDependent, satisfied, setVerboseLogging, toStringMethods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact
manageWithCurrentScope, unmanage, unmanageMethods inherited from class com.illumon.util.referencecounting.ReferenceCounted
decrementReferenceCount, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCountMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface com.illumon.iris.db.v2.ListenerBase
getErrorNotification, onFailureMethods inherited from interface com.illumon.iris.db.util.liveness.LivenessManager
manage, tryManageMethods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent
dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference
-
Constructor Details
-
Method Details
-
onUpdate
Description copied from interface:ListenerProcess notification of table changes.- Parameters:
added- rows addedremoved- rows removedmodified- rows modified
-
onFailureInternal
public final void onFailureInternal(Throwable originalException, UpdatePerformanceTracker.Entry sourceEntry)- Specified by:
onFailureInternalin classInstrumentedListenerBase
-
canExecute
public boolean canExecute(long step)Description copied from class:InstrumentedListenerBaseCheck if this listener is ready to execute.- Overrides:
canExecutein classInstrumentedListenerBase- Returns:
- if this listener is ready to execute
-
destroy
protected void destroy()Attempt to release (destructively when necessary) resources held by this object. This may render the object unusable for subsequent operations. Implementations should be sure to call super.destroy().
This is intended to only ever be used as a side effect of decreasing the reference count to 0.
-
initializeTransientFieldsForLiveness
Package-private forSerializablesub-classes to use inreadObjectonly. Public to allow unit tests in another package to work around mock issues where the constructor is never invoked. -
tryRetainReference
public final boolean tryRetainReference()Description copied from interface:LivenessReferentIf this referent is "live", behave asLivenessReferent.retainReference()and return true. Otherwise, returns false rather than throwing an exception.- Specified by:
tryRetainReferencein interfaceLivenessReferent- Returns:
- True if this referent was retained, false otherwise
-
dropReference
public final void dropReference()Description copied from interface:LivenessReferentDrop a previously-retained reference to this referent.- Specified by:
dropReferencein interfaceLivenessReferent
-
getWeakReference
Description copied from interface:LivenessReferentGet aWeakReferenceto this referent. This may be cached, or newly created.- Specified by:
getWeakReferencein interfaceLivenessReferent- Returns:
- A new or cached reference to this referent
-
tryManage
Description copied from interface:LivenessManagerAttempt to add the specified referent to this manager.- Specified by:
tryManagein interfaceLivenessManager- Parameters:
referent- The referent to add- Returns:
- Whether the referent was in fact added
-
onReferenceCountAtZero
protected final void onReferenceCountAtZero()Description copied from class:ReferenceCountedCallback method that will be invoked when the reference count returns to zero.- Specified by:
onReferenceCountAtZeroin classReferenceCounted
-