Package com.illumon.iris.db.tables.live
Class LiveTableRefreshCombiner
java.lang.Object
com.illumon.util.referencecounting.ReferenceCounted
com.illumon.iris.db.util.liveness.LivenessArtifact
com.illumon.iris.db.tables.live.LiveTableRefreshCombiner
- All Implemented Interfaces:
com.fishlib.base.log.LogOutputAppendable,LiveTable,LiveTableRegistrar,LivenessManager,LivenessNode,LivenessReferent,Serializable
public class LiveTableRefreshCombiner extends LivenessArtifact implements LiveTable, LiveTableRegistrar
Combines multiple
LiveTables into a single one, in order to allow for update parallelization within the
LiveTableMonitor.- See Also:
- Serialized Form
-
Constructor Summary
Constructors Constructor Description LiveTableRefreshCombiner() -
Method Summary
Modifier and Type Method Description voidaddTable(LiveTable liveTable)Add a table to this registrar.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.voidmaybeRefreshTable(LiveTable table, boolean onlyIfHaveLock)protected voidonReferenceCountAtZero()Callback method that will be invoked when the reference count returns to zero.voidrefresh()Refresh this LiveTable.voidremoveTable(LiveTable liveTable)Remove a table from this registrar.voidrequestRefresh(LiveTable table)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.util.liveness.LivenessArtifact
manageWithCurrentScope, unmanage, unmanageMethods inherited from class com.illumon.util.referencecounting.ReferenceCounted
append, decrementReferenceCount, incrementReferenceCount, resetReferenceCount, toString, 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.util.liveness.LivenessReferent
getReferentDescription, retainReference
-
Constructor Details
-
LiveTableRefreshCombiner
public LiveTableRefreshCombiner()
-
-
Method Details
-
refresh
public void refresh()Description copied from interface:LiveTableRefresh this LiveTable. -
addTable
Description copied from interface:LiveTableRegistrarAdd a table to this registrar.- Specified by:
addTablein interfaceLiveTableRegistrar- Parameters:
liveTable- The table to add
-
removeTable
Description copied from interface:LiveTableRegistrarRemove a table from this registrar.- Specified by:
removeTablein interfaceLiveTableRegistrar- Parameters:
liveTable- The table to remove
-
requestRefresh
- Specified by:
requestRefreshin interfaceLiveTableRegistrar
-
maybeRefreshTable
- Specified by:
maybeRefreshTablein interfaceLiveTableRegistrar
-
destroy
public 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
-