io.aeron.protocol

Class NakFlyweight

java.lang.Object

org.agrona.concurrent.UnsafeBuffer

io.aeron.protocol.HeaderFlyweight

io.aeron.protocol.NakFlyweight

All Implemented Interfaces:

java.lang.Comparable<org.agrona.DirectBuffer>, org.agrona.concurrent.AtomicBuffer, org.agrona.DirectBuffer, org.agrona.MutableDirectBuffer

public class NakFlyweight
extends HeaderFlyweight

Flyweight for a NAK Message Frame.

Data Recovery wiki page.

Field Summary

Fields

Modifier and Type	Field and Description
static int	HEADER_LENGTH

Fields inherited from class io.aeron.protocol.HeaderFlyweight

CURRENT_VERSION, FLAGS_FIELD_OFFSET, FRAME_LENGTH_FIELD_OFFSET, HDR_TYPE_DATA, HDR_TYPE_ERR, HDR_TYPE_EXT, HDR_TYPE_NAK, HDR_TYPE_PAD, HDR_TYPE_RTTM, HDR_TYPE_SETUP, HDR_TYPE_SM, MIN_HEADER_LENGTH, TYPE_FIELD_OFFSET, VERSION_FIELD_OFFSET

Fields inherited from class org.agrona.concurrent.UnsafeBuffer

ALIGNMENT, DISABLE_BOUNDS_CHECKS_PROP_NAME, SHOULD_BOUNDS_CHECK

Constructor Summary

Constructors

Constructor and Description
NakFlyweight()
NakFlyweight(java.nio.ByteBuffer buffer)
NakFlyweight(org.agrona.concurrent.UnsafeBuffer buffer)

Method Summary

Modifier and Type	Method and Description
int	length() The length field
NakFlyweight	length(int length) set length field
int	sessionId() return session id field
NakFlyweight	sessionId(int sessionId) set session id field
int	streamId() return stream id field
NakFlyweight	streamId(int streamId) set stream id field
int	termId() return term id field
NakFlyweight	termId(int termId) set term id field
int	termOffset() return term offset field
NakFlyweight	termOffset(int termOffset) set term offset field
java.lang.String	toString()

Methods inherited from class io.aeron.protocol.HeaderFlyweight

flags, flags, frameLength, frameLength, headerType, headerType, version, version

Methods inherited from class org.agrona.concurrent.UnsafeBuffer

addIntOrdered, addLongOrdered, addressOffset, boundsCheck, byteArray, byteBuffer, capacity, checkLimit, compareAndSetInt, compareAndSetLong, compareTo, equals, getAndAddInt, getAndAddLong, getAndSetInt, getAndSetLong, getByte, getBytes, getBytes, getBytes, getBytes, getBytes, getByteVolatile, getChar, getChar, getCharVolatile, getDouble, getDouble, getFloat, getFloat, getInt, getInt, getIntVolatile, getLong, getLong, getLongVolatile, getShort, getShort, getShortVolatile, getStringAscii, getStringAscii, getStringAscii, getStringUtf8, getStringUtf8, getStringUtf8, getStringWithoutLengthAscii, getStringWithoutLengthUtf8, hashCode, isExpandable, parseIntAscii, parseLongAscii, parseNaturalIntAscii, parseNaturalLongAscii, putByte, putBytes, putBytes, putBytes, putBytes, putBytes, putByteVolatile, putChar, putChar, putCharVolatile, putDouble, putDouble, putFloat, putFloat, putInt, putInt, putIntAscii, putIntOrdered, putIntVolatile, putLong, putLong, putLongAscii, putLongOrdered, putLongVolatile, putNaturalIntAscii, putNaturalIntAsciiFromEnd, putNaturalLongAscii, putNaturalPaddedIntAscii, putShort, putShort, putShortVolatile, putStringAscii, putStringAscii, putStringUtf8, putStringUtf8, putStringUtf8, putStringUtf8, putStringWithoutLengthAscii, putStringWithoutLengthAscii, putStringWithoutLengthUtf8, setMemory, verifyAlignment, wrap, wrap, wrap, wrap, wrap, wrap, wrap, wrapAdjustment

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

HEADER_LENGTH

public static final int HEADER_LENGTH

See Also:

Constant Field Values

Constructor Detail

NakFlyweight

public NakFlyweight()

NakFlyweight

public NakFlyweight(java.nio.ByteBuffer buffer)

NakFlyweight

public NakFlyweight(org.agrona.concurrent.UnsafeBuffer buffer)

Method Detail

sessionId

public int sessionId()

return session id field

Returns:

session id field

sessionId

public NakFlyweight sessionId(int sessionId)

set session id field

Parameters:

sessionId - field value

Returns:

flyweight

streamId

public int streamId()

return stream id field

Returns:

stream id field

streamId

public NakFlyweight streamId(int streamId)

set stream id field

Parameters:

streamId - field value

Returns:

flyweight

termId

public int termId()

return term id field

Returns:

term id field

termId

public NakFlyweight termId(int termId)

set term id field

Parameters:

termId - field value

Returns:

flyweight

termOffset

public int termOffset()

return term offset field

Returns:

term offset field

termOffset

public NakFlyweight termOffset(int termOffset)

set term offset field

Parameters:

termOffset - field value

Returns:

flyweight

length

public int length()

The length field

Returns:

length field

length

public NakFlyweight length(int length)

set length field

Parameters:

length - field value

Returns:

flyweight

toString

public java.lang.String toString()

Overrides:

toString in class org.agrona.concurrent.UnsafeBuffer