Package net.neoforged.neoforge.network.filters

Class GenericPacketSplitter

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelOutboundHandlerAdapter

io.netty.handler.codec.MessageToMessageEncoder<Packet<?>>

net.neoforged.neoforge.network.filters.GenericPacketSplitter

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelOutboundHandler, DynamicChannelHandler

@Internal
public class GenericPacketSplitter
extends io.netty.handler.codec.MessageToMessageEncoder<Packet<?>>
implements DynamicChannelHandler

A generic packet splitter that can be used to split packets that are too large to be sent in one go.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	GenericPacketSplitter.RemoteCompatibility
private static final record	GenericPacketSplitter.SizeLimits

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANNEL_HANDLER_NAME
private static final GenericPacketSplitter.SizeLimits	compressedSizeLimits
private static final org.apache.logging.log4j.Logger	LOGGER
private final List<byte[]>	receivedBuffers
private static final byte	STATE_FIRST
private static final byte	STATE_LAST
private static final GenericPacketSplitter.SizeLimits	uncompressedSizeLimits

Constructor Summary

Constructors

Constructor	Description
GenericPacketSplitter()

Method Summary

Modifier and Type	Method	Description
private static Packet<?>	createPacket(PacketFlow flow, byte[] payload)
static int	determineMaxPayloadSize(int maxPacketSize)
protected void	encode(io.netty.channel.ChannelHandlerContext ctx, Packet<?> packet, List<Object> out)
static GenericPacketSplitter.RemoteCompatibility	getRemoteCompatibility(Connection manager)
private static void	handle(SplitPacketPayload payload, IPayloadContext context)
boolean	isNecessary(Connection manager)
static boolean	isRemoteCompatible(Connection manager)
private void	receivedPacket(SplitPacketPayload payload, IPayloadContext context)
private static void	register(RegisterPayloadHandlersEvent event)

Methods inherited from class io.netty.handler.codec.MessageToMessageEncoder

acceptOutboundMessage, write

Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.ChannelHandler

exceptionCaught, handlerAdded, handlerRemoved

Field Details

LOGGER

private static final org.apache.logging.log4j.Logger LOGGER

compressedSizeLimits

private static final GenericPacketSplitter.SizeLimits compressedSizeLimits

uncompressedSizeLimits

private static final GenericPacketSplitter.SizeLimits uncompressedSizeLimits

STATE_FIRST

private static final byte STATE_FIRST

See Also:

• Constant Field Values

STATE_LAST

private static final byte STATE_LAST

See Also:

• Constant Field Values

CHANNEL_HANDLER_NAME

public static final String CHANNEL_HANDLER_NAME

See Also:

• Constant Field Values

receivedBuffers

private final List<byte[]> receivedBuffers

Constructor Details

GenericPacketSplitter

public GenericPacketSplitter()

Method Details

register

private static void register(RegisterPayloadHandlersEvent event)

handle

private static void handle(SplitPacketPayload payload,
 IPayloadContext context)

encode

protected void encode(io.netty.channel.ChannelHandlerContext ctx,
 Packet<?> packet,
 List<Object> out)
               throws Exception

Specified by:

encode in class io.netty.handler.codec.MessageToMessageEncoder<Packet<?>>

Throws:

Exception

receivedPacket

private void receivedPacket(SplitPacketPayload payload,
 IPayloadContext context)

createPacket

private static Packet<?> createPacket(PacketFlow flow,
 byte[] payload)

isNecessary

public boolean isNecessary(Connection manager)

Specified by:

isNecessary in interface DynamicChannelHandler

getRemoteCompatibility

public static GenericPacketSplitter.RemoteCompatibility getRemoteCompatibility(Connection manager)

isRemoteCompatible

public static boolean isRemoteCompatible(Connection manager)

determineMaxPayloadSize

public static int determineMaxPayloadSize(int maxPacketSize)