Top Fields Constructors Methods

io.rsocket.core

pack-priv Class ReassemblyUtils

Class Inheritance

extends Object

java.lang.Object
io.rsocket.core.ReassemblyUtils

Static Imports

io.rsocket.core.FragmentationUtils.MIN_MTU_SIZE, .StateUtils.isReassembling, .StateUtils.isTerminated, .StateUtils.markReassembled, .StateUtils.markReassembling, io.rsocket.frame.FrameLengthCodec.FRAME_LENGTH_MASK

Field Summary

Modifier and Type	Field and Description
pack-priv static final String	ILLEGAL_REASSEMBLED_PAYLOAD_SIZE

Constructor Summary

Access	Constructor and Description
pack-priv	ReassemblyUtils()

Method Summary

Modifier and Type	Method and Description
pack-priv static CompositeByteBuf	addFollowingFrame(CompositeByteBuf frames, ByteBuf followingFrame, boolean hasFollows, int maxInboundPayloadSize)
pack-priv static int	assertInboundPayloadSize(int inboundPayloadSize)
private static int	decodeLength(final ByteBuf byteBuf)
private static void	encodeLength(final ByteBuf byteBuf, final int length)
pack-priv static <T extends RequesterFrameHandler> void	handleNextSupport(AtomicLongFieldUpdater<T> updater, T instance, Subscription subscription, CoreSubscriber<? super Payload> inboundSubscriber, PayloadDecoder payloadDecoder, ByteBufAllocator allocator, int maxInboundPayloadSize, ByteBuf frame, boolean hasFollows, boolean isLastPayload)
pack-priv static void	release(RequesterFrameHandler framesHolder, long state)
pack-priv static void	synchronizedRelease(RequesterFrameHandler framesHolder, long state)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

ILLEGAL_REASSEMBLED_PAYLOAD_SIZE	back to summary
pack-priv static final String ILLEGAL_REASSEMBLED_PAYLOAD_SIZE

Constructor Detail

ReassemblyUtils	back to summary
pack-priv ReassemblyUtils()

Method Detail

addFollowingFrame	back to summary
pack-priv static CompositeByteBuf addFollowingFrame(CompositeByteBuf frames, ByteBuf followingFrame, boolean hasFollows, int maxInboundPayloadSize)

assertInboundPayloadSize	back to summary
pack-priv static int assertInboundPayloadSize(int inboundPayloadSize)

decodeLength	back to summary
private static int decodeLength(final ByteBuf byteBuf)

encodeLength	back to summary
private static void encodeLength(final ByteBuf byteBuf, final int length)

handleNextSupport	back to summary
pack-priv static <T extends RequesterFrameHandler> void handleNextSupport(AtomicLongFieldUpdater<T> updater, T instance, Subscription subscription, CoreSubscriber<? super Payload> inboundSubscriber, PayloadDecoder payloadDecoder, ByteBufAllocator allocator, int maxInboundPayloadSize, ByteBuf frame, boolean hasFollows, boolean isLastPayload)

release	back to summary
pack-priv static void release(RequesterFrameHandler framesHolder, long state) Annotations @SuppressWarnings:ConstantConditions

synchronizedRelease	back to summary
pack-priv static void synchronizedRelease(RequesterFrameHandler framesHolder, long state) Annotations @SuppressWarnings:ConstantConditions, SynchronizationOnLocalVariableOrMethodParameter