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

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

Fields

Modifier and Type

Field

Description

private final io.netty.util.AttributeKey<ConnectionProtocol.CodecData<?>>

codecKey

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

LOGGER

private static final int

MAX_PACKET_SIZE

private static final int

MAX_PART_SIZE

private static final List<byte[]>

receivedBuffers

private static final byte

STATE_FIRST

private static final byte

STATE_LAST
Constructor Summary

Constructors

Constructor

Description

GenericPacketSplitter(io.netty.util.AttributeKey<ConnectionProtocol.CodecData<?>> codecKey)

GenericPacketSplitter(Connection connection)
Method Summary

Modifier and Type

Method

Description

private static Packet<?>

createPacket(PacketFlow flow, byte[] payload)

static int

determineMaxPayloadSize(ConnectionProtocol protocol, PacketFlow flow)

protected void

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

private static io.netty.util.AttributeKey<ConnectionProtocol.CodecData<?>>

getProtocolKey(PacketFlow flow)

static GenericPacketSplitter.RemoteCompatibility

getRemoteCompatibility(Connection manager)

boolean

isNecessary(Connection manager)

static boolean

isRemoteCompatible(Connection manager)

private static void

receivedPacket(SplitPacketPayload payload, IPayloadContext context)

private static void

register(RegisterPayloadHandlerEvent 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
- MAX_PACKET_SIZE
  
  private static final int MAX_PACKET_SIZE
  See Also:
  
  Constant Field Values
- MAX_PART_SIZE
  
  private static final int MAX_PART_SIZE
- 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
- codecKey
  
  private final io.netty.util.AttributeKey<ConnectionProtocol.CodecData<?>> codecKey
- receivedBuffers
  
  private static final List<byte[]> receivedBuffers
Constructor Details
- GenericPacketSplitter
  
  public GenericPacketSplitter(Connection connection)
- GenericPacketSplitter
  
  public GenericPacketSplitter(io.netty.util.AttributeKey<ConnectionProtocol.CodecData<?>> codecKey)
Method Details
- register
  
  private static void register(RegisterPayloadHandlerEvent event)
- 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 static 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(ConnectionProtocol protocol, PacketFlow flow)
- getProtocolKey
  
  private static io.netty.util.AttributeKey<ConnectionProtocol.CodecData<?>> getProtocolKey(PacketFlow flow)

Class GenericPacketSplitter

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

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

Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

Methods inherited from class java.lang.Object

Methods inherited from interface io.netty.channel.ChannelHandler

Field Details

LOGGER

MAX_PACKET_SIZE

MAX_PART_SIZE

STATE_FIRST

STATE_LAST

codecKey

receivedBuffers

Constructor Details

GenericPacketSplitter

GenericPacketSplitter

Method Details

register

encode

receivedPacket

createPacket

isNecessary

getRemoteCompatibility

isRemoteCompatible

determineMaxPayloadSize

getProtocolKey