| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.regionserver.wal | 
| Modifier and Type | Field and Description | 
|---|---|
| private SyncFuture | RingBufferTruck. syncEither this syncFuture is set or entry is set, but not both. | 
| private SyncFuture[] | FSHLog.RingBufferEventHandler. syncFutures | 
| private SyncFuture | FSHLog.SyncRunner. takeSyncFuture | 
| Modifier and Type | Field and Description | 
|---|---|
| private ThreadLocal<SyncFuture> | AbstractFSWAL. cachedSyncFuturesMap of  SyncFutures owned by Thread objects. | 
| private static Comparator<SyncFuture> | AsyncFSWAL. SEQ_COMPARATOR | 
| private SortedSet<SyncFuture> | AsyncFSWAL. syncFutures | 
| private BlockingQueue<SyncFuture> | FSHLog.SyncRunner. syncFutures | 
| Modifier and Type | Method and Description | 
|---|---|
| protected SyncFuture | AbstractFSWAL. getSyncFuture(long sequence,
             boolean forceSync) | 
| private SyncFuture | FSHLog. publishSyncOnRingBuffer(boolean forceSync) | 
| protected SyncFuture | FSHLog. publishSyncOnRingBuffer(long sequence,
                       boolean forceSync) | 
| (package private) SyncFuture | SyncFuture. reset(long txid)Call this method to clear old usage and get it ready for new deploy. | 
| (package private) SyncFuture | SyncFuture. setForceSync(boolean forceSync) | 
| (package private) SyncFuture | RingBufferTruck. unloadSync()Unload the truck of its  SyncFuturepayload. | 
| (package private) SyncFuture | FSHLog.SafePointZigZagLatch. waitSafePoint(SyncFuture syncFuture)For Thread A to call when it is ready to wait on the 'safe point' to be attained. | 
| Modifier and Type | Method and Description | 
|---|---|
| private void | AsyncFSWAL. addTimeAnnotation(SyncFuture future,
                 String annotation) | 
| protected void | AbstractFSWAL. blockOnSync(SyncFuture syncFuture) | 
| private void | FSHLog.SafePointZigZagLatch. checkIfSyncFailed(SyncFuture syncFuture) | 
| (package private) void | RingBufferTruck. load(SyncFuture syncFuture)Load the truck with a  SyncFuture. | 
| (package private) void | FSHLog.SyncRunner. offer(long sequence,
     SyncFuture[] syncFutures,
     int syncFutureCount) | 
| private int | FSHLog.SyncRunner. releaseSyncFuture(SyncFuture syncFuture,
                 long currentSequence,
                 Throwable t)Release the passed  syncFuture | 
| (package private) SyncFuture | FSHLog.SafePointZigZagLatch. waitSafePoint(SyncFuture syncFuture)For Thread A to call when it is ready to wait on the 'safe point' to be attained. | 
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.