Package | Description |
---|---|
org.apache.hadoop.hbase.regionserver.wal |
Modifier and Type | Field and Description |
---|---|
private SyncFuture |
RingBufferTruck.sync
Either 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.cachedSyncFutures
Map of
SyncFuture s 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) |
private SyncFuture |
FSHLog.publishSyncOnRingBuffer() |
protected SyncFuture |
FSHLog.publishSyncOnRingBuffer(long sequence) |
(package private) SyncFuture |
SyncFuture.reset(long txid)
Call this method to clear old usage and get it ready for new deploy.
|
(package private) SyncFuture |
RingBufferTruck.unloadSync()
Unload the truck of its
SyncFuture payload. |
(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–2019 The Apache Software Foundation. All rights reserved.