io.aeron.driver.buffer

Interface RawLog

public interface RawLog

Represents the collection of term and associated state buffers for the image between a publisher and subscriber image for the replicated log.

Method Summary

Modifier and Type	Method and Description
void	close() Close the resource regardless of if free() has succeeded or not.
java.lang.String	fileName() Get the fully qualified file name for the log file.
boolean	free() Free the mapped buffers and delete the file.
boolean	isInactive() Has the free() method been called.
org.agrona.concurrent.UnsafeBuffer	metaData() The meta data storage for the overall log.
java.nio.ByteBuffer[]	sliceTerms() Slice the underlying buffer to provide an array of term buffers in order.
org.agrona.concurrent.UnsafeBuffer[]	termBuffers() An array of term buffer partitions.
int	termLength() The length of each term in bytes.

Method Detail

termLength

int termLength()

The length of each term in bytes.

Returns:

the length of each term in bytes.

termBuffers

org.agrona.concurrent.UnsafeBuffer[] termBuffers()

An array of term buffer partitions.

Returns:

an array of the term buffer partitions.

metaData

org.agrona.concurrent.UnsafeBuffer metaData()

The meta data storage for the overall log.

Returns:

the meta data storage for the overall log.

sliceTerms

java.nio.ByteBuffer[] sliceTerms()

Slice the underlying buffer to provide an array of term buffers in order.

Returns:

slices of the underlying buffer to provide an array of term buffers in order.

fileName

java.lang.String fileName()

Get the fully qualified file name for the log file.

Returns:

the fully qualified file name for the log file.

free

boolean free()

Free the mapped buffers and delete the file.

Returns:

true if successful or false if it should be reattempted.

isInactive

boolean isInactive()

Has the free() method been called.

Returns:

true if an attempt to free is in progress or completed.

close

void close()

Close the resource regardless of if free() has succeeded or not.