| Package | Description |
|---|---|
| org.apache.hadoop.hbase.regionserver.wal |
| Modifier and Type | Field and Description |
|---|---|
private SyncFuture |
RingBufferTruck.syncFuture
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> |
FSHLog.cachedSyncFutures
Map of
SyncFutures owned by Thread objects. |
private BlockingQueue<SyncFuture> |
FSHLog.SyncRunner.syncFutures |
| Modifier and Type | Method and Description |
|---|---|
private SyncFuture |
FSHLog.getSyncFuture(long sequence,
org.apache.htrace.Span span) |
private SyncFuture |
FSHLog.publishSyncOnRingBuffer(long sequence) |
private SyncFuture |
FSHLog.publishSyncOnRingBuffer(long sequence,
org.apache.htrace.Span span) |
private SyncFuture |
FSHLog.publishSyncOnRingBuffer(org.apache.htrace.Span span) |
(package private) SyncFuture |
SyncFuture.reset(long sequence)
Call this method to clear old usage and get it ready for new deploy.
|
(package private) SyncFuture |
SyncFuture.reset(long sequence,
org.apache.htrace.Span span)
Call this method to clear old usage and get it ready for new deploy.
|
(package private) SyncFuture |
RingBufferTruck.unloadSyncFuturePayload()
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 org.apache.htrace.Span |
FSHLog.blockOnSync(SyncFuture syncFuture) |
private void |
FSHLog.SafePointZigZagLatch.checkIfSyncFailed(SyncFuture syncFuture) |
(package private) void |
RingBufferTruck.loadPayload(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.