Uses of Class
org.apache.hadoop.hbase.regionserver.wal.SyncFuture
Packages that use SyncFuture
-
Uses of SyncFuture in org.apache.hadoop.hbase.regionserver.wal
Fields in org.apache.hadoop.hbase.regionserver.wal declared as SyncFutureModifier and TypeFieldDescriptionprivate SyncFutureRingBufferTruck.syncEither this syncFuture is set or entry is set, but not both.private final SyncFuture[]FSHLog.RingBufferEventHandler.syncFuturesprivate SyncFutureFSHLog.SyncRunner.takeSyncFutureFields in org.apache.hadoop.hbase.regionserver.wal with type parameters of type SyncFutureModifier and TypeFieldDescriptionprivate static final Comparator<SyncFuture>AsyncFSWAL.SEQ_COMPARATORprivate final org.apache.hbase.thirdparty.com.google.common.cache.Cache<Thread,SyncFuture> SyncFutureCache.syncFutureCacheprivate final SortedSet<SyncFuture>AsyncFSWAL.syncFuturesprivate final BlockingQueue<SyncFuture>FSHLog.SyncRunner.syncFuturesMethods in org.apache.hadoop.hbase.regionserver.wal that return SyncFutureModifier and TypeMethodDescriptionSyncFutureCache.getIfPresentOrNew()protected final SyncFutureAbstractFSWAL.getSyncFuture(long sequence, boolean forceSync) private SyncFutureFSHLog.publishSyncOnRingBuffer(boolean forceSync) protected SyncFutureFSHLog.publishSyncOnRingBuffer(long sequence, boolean forceSync) (package private) SyncFutureSyncFuture.reset(long txid, boolean forceSync) Call this method to clear old usage and get it ready for new deploy.(package private) SyncFutureRingBufferTruck.unloadSync()Unload the truck of itsSyncFuturepayload.(package private) SyncFutureFSHLog.SafePointZigZagLatch.waitSafePoint(SyncFuture syncFuture) For Thread A to call when it is ready to wait on the 'safe point' to be attained.Methods in org.apache.hadoop.hbase.regionserver.wal with parameters of type SyncFutureModifier and TypeMethodDescriptionprotected final voidAbstractFSWAL.blockOnSync(SyncFuture syncFuture) private voidFSHLog.SafePointZigZagLatch.checkIfSyncFailed(SyncFuture syncFuture) (package private) voidRingBufferTruck.load(SyncFuture syncFuture) Load the truck with aSyncFuture.private voidAsyncFSWAL.markFutureDoneAndOffer(SyncFuture future, long txid, Throwable t) Helper that marks the future as DONE and offers it back to the cache.(package private) voidFSHLog.SyncRunner.offer(long sequence, SyncFuture[] syncFutures, int syncFutureCount) voidSyncFutureCache.offer(SyncFuture syncFuture) Offers the sync future back to the cache for reuse.private intFSHLog.SyncRunner.releaseSyncFuture(SyncFuture syncFuture, long currentSequence, Throwable t) Release the passedsyncFuture(package private) SyncFutureFSHLog.SafePointZigZagLatch.waitSafePoint(SyncFuture syncFuture) For Thread A to call when it is ready to wait on the 'safe point' to be attained.