org.apache.hadoop.hbase.regionserver.wal

Class RingBufferTruck

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck

@InterfaceAudience.Private
final class RingBufferTruck
extends Object

A 'truck' to carry a payload across the ring buffer from Handler to WAL. Has EITHER a FSWALEntry for making an append OR it has a SyncFuture to represent a 'sync' invocation. Truck instances are reused by the disruptor when it gets around to it so their payload references must be discarded on consumption to release them to GC.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RingBufferTruck.Type

Field Summary

Fields

Modifier and Type	Field and Description
private FSWALEntry	entry
private SyncFuture	sync Either this syncFuture is set or entry is set, but not both.
private RingBufferTruck.Type	type

Constructor Summary

Constructors

Constructor and Description
RingBufferTruck()

Method Summary

Modifier and Type	Method and Description
(package private) void	load(FSWALEntry entry) Load the truck with a FSWALEntry.
(package private) void	load(SyncFuture syncFuture) Load the truck with a SyncFuture.
(package private) RingBufferTruck.Type	type()
(package private) FSWALEntry	unloadAppend() Unload the truck of its FSWALEntry payload.
(package private) SyncFuture	unloadSync() Unload the truck of its SyncFuture payload.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

type

private RingBufferTruck.Type type

sync

private SyncFuture sync

Either this syncFuture is set or entry is set, but not both.

entry

private FSWALEntry entry

Constructor Detail

RingBufferTruck

RingBufferTruck()

Method Detail

load

void load(FSWALEntry entry)

Load the truck with a FSWALEntry.

load

void load(SyncFuture syncFuture)

Load the truck with a SyncFuture.

type

RingBufferTruck.Type type()

Returns:

the type of this truck's payload.

unloadAppend

FSWALEntry unloadAppend()

Unload the truck of its FSWALEntry payload. The internal reference is released.

unloadSync

SyncFuture unloadSync()

Unload the truck of its SyncFuture payload. The internal reference is released.