akka.remote.artery

Class RollingEventLogSection

java.lang.Object

akka.remote.artery.RollingEventLogSection

public class RollingEventLogSection
extends java.lang.Object

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
RollingEventLogSection(java.nio.channels.FileChannel fileChannel, long offset, long entryCount, long logBufferSize, int recordSize)

Method Summary

Modifier and Type	Method and Description
void	clear(int logId)
void	close()
static int	CommitEntrySize()
static int	Committed()
static int	Dirty()
static int	Empty()
static long	HeadPointerOffset()
static int	Live()
static long	LogOffset()
static long	LogStateOffset()
void	markLive(int logId)
void	markSnapshot(int logId)
static long	RecordsOffset()
static int	Snapshot()
void	write(int logId, java.nio.ByteBuffer recordBuffer)

Methods inherited from class java.lang.Object

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

Constructor Detail

RollingEventLogSection

public RollingEventLogSection(java.nio.channels.FileChannel fileChannel,
                              long offset,
                              long entryCount,
                              long logBufferSize,
                              int recordSize)

Method Detail

HeadPointerOffset

public static long HeadPointerOffset()

LogStateOffset

public static long LogStateOffset()

RecordsOffset

public static long RecordsOffset()

LogOffset

public static long LogOffset()

Empty

public static int Empty()

Live

public static int Live()

Snapshot

public static int Snapshot()

Committed

public static int Committed()

Dirty

public static int Dirty()

CommitEntrySize

public static int CommitEntrySize()

clear

public void clear(int logId)

write

public void write(int logId,
                  java.nio.ByteBuffer recordBuffer)

markSnapshot

public void markSnapshot(int logId)

markLive

public void markLive(int logId)

close

public void close()