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.Notification
Nested 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 boolean
canExecute(long step)
Check if this listener is ready to execute.protected void
destroy()
Attempt to release (destructively when necessary) resources held by this object.void
dropReference()
Drop a previously-retained reference to this referent.WeakReference<? extends LivenessReferent>
getWeakReference()
Get aWeakReference
to this referent.void
initializeTransientFieldsForLiveness()
Package-private forSerializable
sub-classes to use inreadObject
only.void
onFailureInternal(Throwable originalException, UpdatePerformanceTracker.Entry sourceEntry)
protected void
onReferenceCountAtZero()
Callback method that will be invoked when the reference count returns to zero.void
onUpdate(Index added, Index removed, Index modified)
Process notification of table changes.boolean
tryManage(LivenessReferent referent)
Attempt to add the specified referent to this manager.boolean
tryRetainReference()
If this referent is "live", behave asLivenessReferent.retainReference()
and return true.Methods inherited from class com.illumon.iris.db.v2.InstrumentedListener
getNotification, setInitialImage
Methods inherited from class com.illumon.iris.db.v2.InstrumentedListenerBase
append, getEntry, getErrorNotification, onFailure, onFailureInternalWithDependent, satisfied, setVerboseLogging, toString
Methods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact
manageWithCurrentScope, unmanage, unmanage
Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted
decrementReferenceCount, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCount
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface com.illumon.iris.db.v2.ListenerBase
getErrorNotification, onFailure
Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessManager
manage, tryManage
Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent
dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference
-
Constructor Details
-
Method Details
-
onUpdate
Description copied from interface:Listener
Process notification of table changes.- Parameters:
added
- rows addedremoved
- rows removedmodified
- rows modified
-
onFailureInternal
public final void onFailureInternal(Throwable originalException, UpdatePerformanceTracker.Entry sourceEntry)- Specified by:
onFailureInternal
in classInstrumentedListenerBase
-
canExecute
public boolean canExecute(long step)Description copied from class:InstrumentedListenerBase
Check if this listener is ready to execute.- Overrides:
canExecute
in 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 forSerializable
sub-classes to use inreadObject
only. 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:LivenessReferent
If this referent is "live", behave asLivenessReferent.retainReference()
and return true. Otherwise, returns false rather than throwing an exception.- Specified by:
tryRetainReference
in interfaceLivenessReferent
- Returns:
- True if this referent was retained, false otherwise
-
dropReference
public final void dropReference()Description copied from interface:LivenessReferent
Drop a previously-retained reference to this referent.- Specified by:
dropReference
in interfaceLivenessReferent
-
getWeakReference
Description copied from interface:LivenessReferent
Get aWeakReference
to this referent. This may be cached, or newly created.- Specified by:
getWeakReference
in interfaceLivenessReferent
- Returns:
- A new or cached reference to this referent
-
tryManage
Description copied from interface:LivenessManager
Attempt to add the specified referent to this manager.- Specified by:
tryManage
in interfaceLivenessManager
- Parameters:
referent
- The referent to add- Returns:
- Whether the referent was in fact added
-
onReferenceCountAtZero
protected final void onReferenceCountAtZero()Description copied from class:ReferenceCounted
Callback method that will be invoked when the reference count returns to zero.- Specified by:
onReferenceCountAtZero
in classReferenceCounted
-