net.minecraft.network

public class ClientConnection

extends io.netty.channel.SimpleChannelInboundHandler<Packet<?>>

net.minecraft.network.Connection
net.minecraft.class_2535
net.minecraft.network.ClientConnection

Field summary

Modifier and TypeField
private static final float
AVERAGE_PACKETS_SMOOTHING
field_33280
CURRENT_PACKET_COUNTER_WEIGHT
private static final org.slf4j.Logger
LOGGER
field_11642
LOGGER
public static final org.slf4j.Marker
ROOT_MARKER
field_11641
NETWORK_MARKER
public static final org.slf4j.Marker
PACKET_MARKER
field_11639
NETWORK_PACKETS_MARKER
public static final org.slf4j.Marker
PACKET_RECEIVED_MARKER
field_36379
PACKET_RECEIVED_MARKER
public static final org.slf4j.Marker
PACKET_SENT_MARKER
field_36380
PACKET_SENT_MARKER
private static final NetworkState<ServerHandshakePacketListener>
INITIAL_PROTOCOL
field_48514
C2S_HANDSHAKE_STATE
private final NetworkSide
receiving
field_11643
side
private volatile boolean
sendLoginDisconnect
field_48515
duringLogin
private final Queue<Consumer<ClientConnection>>
pendingActions
field_45668
queuedTasks
private io.netty.channel.Channel
channel
field_11651
channel
private SocketAddress
address
field_11645
address
private volatile PacketListener
disconnectListener
field_45669
prePlayStateListener
private volatile PacketListener
packetListener
field_11652
packetListener
private DisconnectionInfo
disconnectionDetails
field_52180
disconnectionInfo
private boolean
disconnectionHandled
field_11646
disconnected
private int
receivedPackets
field_11658
packetsReceivedCounter
private int
sentPackets
field_11656
packetsSentCounter
private float
averageReceivedPackets
field_11654
averagePacketsReceived
private float
averageSentPackets
field_11653
averagePacketsSent
private int
tickCount
field_11655
ticks
private boolean
handlingFault
field_11640
errored
private volatile DisconnectionInfo
delayedDisconnect
field_44972
pendingDisconnectionInfo
private PacketSizeLogger
bandwidthDebugMonitor
field_45955
packetSizeLogger
private UUID
intendedProfileId
field_1_6374
uuid

Constructor summary

ModifierConstructor
public (NetworkSide side)

Method summary

Modifier and TypeMethod
public void
channelActive(io.netty.channel.ChannelHandlerContext ctx)
channelActive(io.netty.channel.ChannelHandlerContext arg0)
channelActive(io.netty.channel.ChannelHandlerContext context)
public void
channelInactive(io.netty.channel.ChannelHandlerContext ctx)
channelInactive(io.netty.channel.ChannelHandlerContext arg0)
channelInactive(io.netty.channel.ChannelHandlerContext context)
public void
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
exceptionCaught(io.netty.channel.ChannelHandlerContext arg0, Throwable arg1)
exceptionCaught(io.netty.channel.ChannelHandlerContext context, Throwable ex)
protected void
channelRead0(io.netty.channel.ChannelHandlerContext ctx, Packet<?> packet)
method_10770(io.netty.channel.ChannelHandlerContext arg0, class_2596<?> arg1)
channelRead0(io.netty.channel.ChannelHandlerContext arg0, Packet<?> arg1)
private static <T extends PacketListener> void
genericsFtw(Packet<T> packet, PacketListener listener)
method_10759(class_2596<T> arg0, class_2547 arg1)
handlePacket(Packet<T> packet, PacketListener listener)
private void
validateListener(ProtocolInfo<?> protocol, PacketListener packetListener)
method_56332(class_9127<?> arg0, class_2547 arg1)
setPacketListener(NetworkState<?> state, PacketListener listener)
private static void
syncAfterConfigurationChange(io.netty.channel.ChannelFuture future)
method_59851(io.netty.channel.ChannelFuture arg0)
syncUninterruptibly(io.netty.channel.ChannelFuture future)
public <T extends PacketListener> void
setupInboundProtocol(ProtocolInfo<T> protocol, T packetListener)
method_56330(class_9127<T> arg0, T arg1)
transitionInbound(NetworkState<T> state, T packetListener)
public void
setupOutboundProtocol(ProtocolInfo<?> protocol)
method_56329(class_9127<?> arg0)
transitionOutbound(NetworkState<?> newState)
public void
setListenerForServerboundHandshake(PacketListener packetListener)
method_52912(class_2547 arg0)
setInitialPacketListener(PacketListener packetListener)
public void
initiateServerboundStatusConnection(String hostName, int port, ClientStatusPacketListener listener)
method_52903(String arg0, int arg1, class_2921 arg2)
connect(String address, int port, ClientQueryPacketListener listener)
public void
initiateServerboundPlayConnection(String hostName, int port, ClientLoginPacketListener listener)
method_52902(String arg0, int arg1, class_2896 arg2)
connect(String address, int port, ClientLoginPacketListener listener)
public <S extends ServerPacketListener, C extends ClientPacketListener> void
initiateServerboundPlayConnection(String hostName, int port, ProtocolInfo<S> outbound, ProtocolInfo<C> inbound, C listener, boolean transfer)
method_56326(String arg0, int arg1, class_9127<S> arg2, class_9127<C> arg3, C arg4, boolean arg5)
connect(String address, int port, NetworkState<S> outboundState, NetworkState<C> inboundState, C prePlayStateListener, boolean transfer)
private <S extends ServerPacketListener, C extends ClientPacketListener> void
initiateServerboundConnection(String hostName, int port, ProtocolInfo<S> outbound, ProtocolInfo<C> inbound, C listener, ClientIntent intent)
method_52904(String arg0, int arg1, class_9127<S> arg2, class_9127<C> arg3, C arg4, class_8592 arg5)
connect(String address, int port, NetworkState<S> outboundState, NetworkState<C> inboundState, C prePlayStateListener, ConnectionIntent intent)
public void
send(Packet<?> packet)
method_10743(class_2596<?> arg0)
send(Packet<?> packet)
public void
send(Packet<?> packet, io.netty.channel.ChannelFutureListener listener)
method_10752(class_2596<?> arg0, io.netty.channel.ChannelFutureListener arg1)
send(Packet<?> packet, io.netty.channel.ChannelFutureListener listener)
public void
send(Packet<?> packet, io.netty.channel.ChannelFutureListener listener, boolean flush)
method_52906(class_2596<?> arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2)
send(Packet<?> packet, io.netty.channel.ChannelFutureListener listener, boolean flush)
public void
runOnceConnected(Consumer<Connection> action)
method_52905(Consumer<class_2535> arg0)
submit(Consumer<ClientConnection> task)
private void
sendPacket(Packet<?> packet, io.netty.channel.ChannelFutureListener listener, boolean flush)
method_10764(class_2596<?> arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2)
sendImmediately(Packet<?> packet, io.netty.channel.ChannelFutureListener listener, boolean flush)
private void
doSendPacket(Packet<?> packet, io.netty.channel.ChannelFutureListener listener, boolean flush)
method_36942(class_2596<?> arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2)
sendInternal(Packet<?> packet, io.netty.channel.ChannelFutureListener listener, boolean flush)
public void
flushChannel()
method_52915()
flush()
private void
flush()
method_52918()
flushInternal()
private void
flushQueue()
method_10751()
handleQueuedTasks()
public void
tick()
method_10754()
tick()
protected void
tickSecond()
method_30615()
updateStats()
public SocketAddress
getRemoteAddress()
method_10755()
getAddress()
public String
getLoggableAddress(boolean logIPs)
method_52909(boolean arg0)
getAddressAsString(boolean logIps)
public void
disconnect(Component reason)
method_10747(class_2561 arg0)
disconnect(Text disconnectReason)
public void
disconnect(DisconnectionDetails details)
method_60924(class_9812 arg0)
disconnect(DisconnectionInfo disconnectionInfo)
public boolean
isMemoryConnection()
method_10756()
isLocal()
public NetworkSide
getReceiving()
method_36121()
getSide()
public NetworkSide
getSending()
method_36122()
getOppositeSide()
public static ClientConnection
connectToServer(InetSocketAddress address, EventLoopGroupHolder eventLoopGroupHolder, LocalSampleLogger bandwidthLogger)
method_10753(InetSocketAddress arg0, class_12239 arg1, class_9191 arg2)
connect(InetSocketAddress address, NetworkingBackend backend, MultiValueDebugSampleLogImpl packetSizeLog)
public static io.netty.channel.ChannelFuture
connect(InetSocketAddress address, EventLoopGroupHolder eventLoopGroupHolder, Connection connection)
method_52271(InetSocketAddress arg0, class_12239 arg1, class_2535 arg2)
connect(InetSocketAddress address, NetworkingBackend backend, ClientConnection connection)
private static String
outboundHandlerName(boolean configureOutbound)
method_56333(boolean arg0)
getOutboundHandlerName(boolean sendingSide)
private static String
inboundHandlerName(boolean configureInbound)
method_56334(boolean arg0)
getInboundHandlerName(boolean receivingSide)
public void
configurePacketHandler(io.netty.channel.ChannelPipeline pipeline)
method_53859(io.netty.channel.ChannelPipeline arg0)
addFlowControlHandler(io.netty.channel.ChannelPipeline pipeline)
public static void
configureSerialization(io.netty.channel.ChannelPipeline pipeline, PacketFlow inboundDirection, boolean local, BandwidthDebugMonitor monitor)
method_48311(io.netty.channel.ChannelPipeline arg0, class_2598 arg1, boolean arg2, class_8762 arg3)
addHandlers(io.netty.channel.ChannelPipeline pipeline, NetworkSide side, boolean local, PacketSizeLogger packetSizeLogger)
private static io.netty.channel.ChannelOutboundHandler
createFrameEncoder(boolean local)
method_59853(boolean arg0)
getPrepender(boolean local)
private static io.netty.channel.ChannelInboundHandler
createFrameDecoder(BandwidthDebugMonitor monitor, boolean local)
method_59852(class_8762 arg0, boolean arg1)
getSplitter(PacketSizeLogger packetSizeLogger, boolean local)
public static void
configureInMemoryPipeline(io.netty.channel.ChannelPipeline pipeline, PacketFlow packetFlow)
method_52911(io.netty.channel.ChannelPipeline arg0, class_2598 arg1)
addLocalValidator(io.netty.channel.ChannelPipeline pipeline, NetworkSide side)
public static ClientConnection
connectToLocalServer(SocketAddress address)
method_10769(SocketAddress arg0)
connectLocal(SocketAddress address)
public static ClientConnection
fromChannel(io.netty.channel.Channel channel, PacketFlow flow, LocalSampleLogger bandwidthLogger)
method_1_5478(io.netty.channel.Channel arg0, class_2598 arg1, class_9191 arg2)
create(io.netty.channel.Channel channel, NetworkSide side, MultiValueDebugSampleLogImpl log)
public void
setEncryptionKey(Cipher decryptCipher, Cipher encryptCipher)
method_10746(Cipher arg0, Cipher arg1)
setupEncryption(Cipher decryptionCipher, Cipher encryptionCipher)
public boolean
isConnected()
method_10758()
isOpen()
public boolean
isConnecting()
method_10772()
isChannelAbsent()
public PacketListener
getPacketListener()
method_10744()
getPacketListener()
public DisconnectionInfo
getDisconnectionDetails()
method_60926()
getDisconnectionInfo()
public void
setReadOnly()
method_10757()
tryDisableAutoRead()
public void
setupCompression(int threshold, boolean validateDecompressed)
method_10760(int arg0, boolean arg1)
setCompressionThreshold(int compressionThreshold, boolean rejectsBadPackets)
public void
handleDisconnection()
method_10768()
handleDisconnection()
public float
getAverageReceivedPackets()
method_10762()
getAveragePacketsReceived()
public float
getAverageSentPackets()
method_10745()
getAveragePacketsSent()
public void
setBandwidthLogger(LocalSampleLogger bandwidthLogger)
method_53505(class_9191 arg0)
resetPacketSizeLog(MultiValueDebugSampleLogImpl log)
public void
setIntendedProfileId(UUID profileId)
method_1_5481(UUID arg0)
setUuid(UUID uuid)
public UUID
getIntendedProfileId()
method_1_5479()
getUuid()
protected void
channelRead0(io.netty.channel.ChannelHandlerContext ctx, Object packet)
channelRead0(io.netty.channel.ChannelHandlerContext arg0, Object arg1)
channelRead0(io.netty.channel.ChannelHandlerContext context, Object packet)
private static DisconnectionInfo
lambda$handleDisconnection$0()
method_52919()
method_52919()
private void
lambda$flush$0()
method_52920()
method_52920()
private void
lambda$sendPacket$0(Packet arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2)
method_52917(class_2596 arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2)
method_52917(Packet arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2)
private static void
lambda$send$0(Packet arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2, Connection arg3)
method_52907(class_2596 arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2, class_2535 arg3)
method_52907(Packet arg0, io.netty.channel.ChannelFutureListener arg1, boolean arg2, ClientConnection connection)
private void
lambda$initiateServerboundConnection$0(ProtocolInfo arg0, ClientboundPacketListener arg1, String arg2, int arg3, ClientIntent arg4, ProtocolInfo arg5, Connection arg6)
method_52900(class_9127 arg0, class_8697 arg1, String arg2, int arg3, class_8592 arg4, class_9127 arg5, class_2535 arg6)
method_52900(NetworkState arg0, ClientPacketListener arg1, String arg2, int arg3, ConnectionIntent arg4, NetworkState arg5, ClientConnection connection)
private void
lambda$setupOutboundProtocol$1(boolean arg0, io.netty.channel.ChannelHandlerContext arg1)
method_56331(boolean arg0, io.netty.channel.ChannelHandlerContext arg1)
method_56331(boolean arg0, io.netty.channel.ChannelHandlerContext context)
private static void
lambda$setupOutboundProtocol$0(PacketBundleUnpacker arg0, io.netty.channel.ChannelHandlerContext arg1)
method_56328(class_8036 arg0, io.netty.channel.ChannelHandlerContext arg1)
method_56328(PacketUnbundler arg0, io.netty.channel.ChannelHandlerContext context)
private static void
lambda$setupInboundProtocol$0(PacketBundlePacker arg0, io.netty.channel.ChannelHandlerContext arg1)
method_56327(class_8035 arg0, io.netty.channel.ChannelHandlerContext arg1)
method_56327(PacketBundler arg0, io.netty.channel.ChannelHandlerContext context)
private void
lambda$exceptionCaught$0(DisconnectionDetails arg0)
method_60925(class_9812 arg0)
method_60925(DisconnectionInfo arg0)
private static void
lambda$static$2(org.slf4j.Marker arg0)
method_40062(org.slf4j.Marker arg0)
method_40062(org.slf4j.Marker marker)
private static void
lambda$static$1(org.slf4j.Marker arg0)
method_40063(org.slf4j.Marker arg0)
method_40063(org.slf4j.Marker marker)
private static void
lambda$static$0(org.slf4j.Marker arg0)
method_40064(org.slf4j.Marker arg0)
method_40064(org.slf4j.Marker marker)