io.aeron

Class LogBuffers

java.lang.Object

io.aeron.LogBuffers

All Implemented Interfaces:

java.lang.AutoCloseable, org.agrona.ManagedResource

public class LogBuffers
extends java.lang.Object
implements java.lang.AutoCloseable, org.agrona.ManagedResource

Takes a log file name and maps the file into memory and wraps it with UnsafeBuffers as appropriate.

See Also:

LogBufferDescriptor

Constructor Summary

Constructors

Constructor and Description
LogBuffers(java.lang.String logFileName) Construct the log buffers for a given log file.

Method Summary

Modifier and Type	Method and Description
void	close()
int	decRef()
void	delete()
org.agrona.concurrent.UnsafeBuffer[]	duplicateTermBuffers() Duplicate the underlying ByteBuffers and wrap them for thread local access.
java.nio.channels.FileChannel	fileChannel() The FileChannel for the mapped log.
int	incRef()
org.agrona.concurrent.UnsafeBuffer	metaDataBuffer() Get the buffer which holds the log metadata.
int	termLength() The length of the term buffer in each log partition.
long	timeOfLastStateChange()
void	timeOfLastStateChange(long timeNs)

Methods inherited from class java.lang.Object

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

Constructor Detail

LogBuffers

public LogBuffers(java.lang.String logFileName)

Construct the log buffers for a given log file.

Parameters:

logFileName - to be mapped.

Method Detail

duplicateTermBuffers

public org.agrona.concurrent.UnsafeBuffer[] duplicateTermBuffers()

Duplicate the underlying ByteBuffers and wrap them for thread local access.

Returns:

duplicates of the wrapped underlying ByteBuffers.

metaDataBuffer

public org.agrona.concurrent.UnsafeBuffer metaDataBuffer()

Get the buffer which holds the log metadata.

Returns:

the buffer which holds the log metadata.

fileChannel

public java.nio.channels.FileChannel fileChannel()

The FileChannel for the mapped log.

Returns:

the FileChannel for the mapped log.

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

termLength

public int termLength()

The length of the term buffer in each log partition.

Returns:

length of the term buffer in each log partition.

incRef

public int incRef()

decRef

public int decRef()

timeOfLastStateChange

public void timeOfLastStateChange(long timeNs)

Specified by:

timeOfLastStateChange in interface org.agrona.ManagedResource

timeOfLastStateChange

public long timeOfLastStateChange()

Specified by:

timeOfLastStateChange in interface org.agrona.ManagedResource

delete

public void delete()

Specified by:

delete in interface org.agrona.ManagedResource