akka.remote.artery

Class FlightRecorder

java.lang.Object

java.util.concurrent.atomic.AtomicReference<FlightRecorderStatus>

akka.remote.artery.FlightRecorder

All Implemented Interfaces:

java.io.Serializable

public class FlightRecorder
extends java.util.concurrent.atomic.AtomicReference<FlightRecorderStatus>

INTERNAL API

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FlightRecorder(java.nio.channels.FileChannel fileChannel)

Method Summary

Modifier and Type	Method and Description
static V	accumulateAndGet(V x$1, java.util.function.BinaryOperator<V> x$2)
static int	AlertLogSize()
static int	AlertRecordSize()
static int	AlertSectionOffset()
static int	AlertSectionSize()
static int	AlertWindow()
static int	Alignment()
void	close()
static boolean	compareAndSet(V x$1, V x$2)
EventSink	createEventSink()
static java.nio.file.Path	createFlightRecorderFile(java.lang.String destination, java.nio.file.FileSystem fs)
java.nio.channels.FileChannel	fileChannel()
static V	get()
static V	getAndAccumulate(V x$1, java.util.function.BinaryOperator<V> x$2)
static V	getAndSet(V x$1)
static V	getAndUpdate(java.util.function.UnaryOperator<V> x$1)
static int	GlobalSectionSize()
static int	HiFreqBatchSize()
static int	HiFreqEntryCountFieldOffset()
static int	HiFreqLogSize()
static int	HiFreqRecordSize()
static int	HiFreqSectionOffset()
static int	HiFreqSectionSize()
static int	HiFreqWindow()
static void	lazySet(V x$1)
static int	LoFreqLogSize()
static int	LoFreqRecordSize()
static int	LoFreqSectionOffset()
static int	LoFreqSectionSize()
static int	LoFreqWindow()
static int	LogHeaderSize()
static int	MagicString()
static java.nio.channels.FileChannel	prepareFileForFlightRecorder(java.nio.file.Path path)
static void	set(V x$1)
void	snapshot()
static int	SnapshotCount()
static int	SnapshotMask()
static int	StartTimeStampOffset()
static java.lang.String	toString()
static int	TotalSize()
static V	updateAndGet(java.util.function.UnaryOperator<V> x$1)
static boolean	weakCompareAndSet(V x$1, V x$2)

Methods inherited from class java.util.concurrent.atomic.AtomicReference

accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Constructor Detail

FlightRecorder

public FlightRecorder(java.nio.channels.FileChannel fileChannel)

Method Detail

createFlightRecorderFile

public static java.nio.file.Path createFlightRecorderFile(java.lang.String destination,
                                                          java.nio.file.FileSystem fs)

Parameters:

destination - (undocumented)

fs - (undocumented)

Returns:

A created file where the flight recorder file can be written. There are three options, depending on destination: 1. Empty: a file will be generated in the temporary directory of the OS 2. A relative or absolute path ending with ".afr": this file will be used 3. A relative or absolute path: this directory will be used, the file will get a random file name

prepareFileForFlightRecorder

public static java.nio.channels.FileChannel prepareFileForFlightRecorder(java.nio.file.Path path)

Alignment

public static int Alignment()

MagicString

public static int MagicString()

GlobalSectionSize

public static int GlobalSectionSize()

StartTimeStampOffset

public static int StartTimeStampOffset()

LogHeaderSize

public static int LogHeaderSize()

SnapshotCount

public static int SnapshotCount()

SnapshotMask

public static int SnapshotMask()

AlertRecordSize

public static int AlertRecordSize()

LoFreqRecordSize

public static int LoFreqRecordSize()

HiFreqBatchSize

public static int HiFreqBatchSize()

HiFreqRecordSize

public static int HiFreqRecordSize()

AlertWindow

public static int AlertWindow()

LoFreqWindow

public static int LoFreqWindow()

HiFreqWindow

public static int HiFreqWindow()

AlertLogSize

public static int AlertLogSize()

LoFreqLogSize

public static int LoFreqLogSize()

HiFreqLogSize

public static int HiFreqLogSize()

AlertSectionSize

public static int AlertSectionSize()

LoFreqSectionSize

public static int LoFreqSectionSize()

HiFreqSectionSize

public static int HiFreqSectionSize()

AlertSectionOffset

public static int AlertSectionOffset()

LoFreqSectionOffset

public static int LoFreqSectionOffset()

HiFreqSectionOffset

public static int HiFreqSectionOffset()

TotalSize

public static int TotalSize()

HiFreqEntryCountFieldOffset

public static int HiFreqEntryCountFieldOffset()

get

public static final V get()

set

public static final void set(V x$1)

lazySet

public static final void lazySet(V x$1)

compareAndSet

public static final boolean compareAndSet(V x$1,
                                          V x$2)

weakCompareAndSet

public static final boolean weakCompareAndSet(V x$1,
                                              V x$2)

getAndSet

public static final V getAndSet(V x$1)

getAndUpdate

public static final V getAndUpdate(java.util.function.UnaryOperator<V> x$1)

updateAndGet

public static final V updateAndGet(java.util.function.UnaryOperator<V> x$1)

getAndAccumulate

public static final V getAndAccumulate(V x$1,
                                       java.util.function.BinaryOperator<V> x$2)

accumulateAndGet

public static final V accumulateAndGet(V x$1,
                                       java.util.function.BinaryOperator<V> x$2)

toString

public static java.lang.String toString()

fileChannel

public java.nio.channels.FileChannel fileChannel()

snapshot

public void snapshot()

close

public void close()

createEventSink

public EventSink createEventSink()