net.minecraft.network

public class Connection

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

oe
net.minecraft.network.Connection
net.minecraft.class_2535
net.minecraft.unmapped.C_oasmcckk
net.minecraft.network.ClientConnection
net.minecraft.src.C_4961_
net.minecraft.network.NetworkManager

Field summary

Modifier and TypeField
private static final float
g
AVERAGE_PACKETS_SMOOTHING
field_33280
f_yhdjpmsl
CURRENT_PACKET_COUNTER_WEIGHT
f_178299_
private static final org.apache.logging.log4j.Logger
h
LOGGER
field_11642
f_lspmidtv
LOGGER
f_129465_
public static final org.apache.logging.log4j.Marker
a
ROOT_MARKER
field_11641
f_wborsynf
NETWORK_MARKER
f_129459_
public static final org.apache.logging.log4j.Marker
b
PACKET_MARKER
field_11639
f_howpitdi
NETWORK_PACKETS_MARKER
f_129460_
public static final io.netty.util.AttributeKey<ConnectionProtocol>
c
ATTRIBUTE_PROTOCOL
field_11648
f_gecyhplb
PROTOCOL_ATTRIBUTE_KEY
f_129461_
public static final LazyLoadedValue<io.netty.channel.nio.NioEventLoopGroup>
d
NETWORK_WORKER_GROUP
field_11650
f_hudxxxbp
CLIENT_IO_GROUP
f_129462_
public static final LazyLoadedValue<io.netty.channel.epoll.EpollEventLoopGroup>
e
NETWORK_EPOLL_WORKER_GROUP
field_11657
f_pdctspiv
EPOLL_CLIENT_IO_GROUP
f_129463_
public static final LazyLoadedValue<io.netty.channel.DefaultEventLoopGroup>
f
LOCAL_WORKER_GROUP
field_11649
f_ewnrqslo
LOCAL_CLIENT_IO_GROUP
f_129464_
private final PacketFlow
i
receiving
field_11643
f_gaynmpqg
side
f_129466_
private final Queue<Connection$PacketHolder>
j
queue
field_11644
f_bgaglckf
packetQueue
f_129467_
private io.netty.channel.Channel
k
channel
field_11651
f_kawdlrjp
channel
f_129468_
private SocketAddress
l
address
field_11645
f_daxqlowt
address
f_129469_
private PacketListener
m
packetListener
field_11652
f_ucdtbtsq
packetListener
f_129470_
private Component
n
disconnectedReason
field_11660
f_hgoaaoyc
disconnectReason
f_129471_
private boolean
o
encrypted
field_11647
f_eatlkkxl
encrypted
f_129472_
private boolean
p
disconnectionHandled
field_11646
f_wdeykuqe
disconnected
f_129473_
private int
q
receivedPackets
field_11658
f_mamtuefi
packetsReceivedCounter
f_129474_
private int
r
sentPackets
field_11656
f_zrkidnxu
packetsSentCounter
f_129475_
private float
s
averageReceivedPackets
field_11654
f_sjhnumre
averagePacketsReceived
f_129476_
private float
t
averageSentPackets
field_11653
f_jrcdtkyf
averagePacketsSent
f_129477_
private int
u
tickCount
field_11655
f_bcutours
ticks
f_129478_
private boolean
v
handlingFault
field_11640
f_vcukytvt
errored
f_129479_

Constructor summary

ModifierConstructor
public (PacketFlow side)

Method summary

Modifier and TypeMethod
public void
channelActive(io.netty.channel.ChannelHandlerContext arg0)
channelActive(io.netty.channel.ChannelHandlerContext arg0)
channelActive(io.netty.channel.ChannelHandlerContext arg0)
channelActive(io.netty.channel.ChannelHandlerContext context)
channelActive(io.netty.channel.ChannelHandlerContext arg0)
public void
a(of arg0)
setProtocol(ConnectionProtocol arg0)
method_10750(class_2539 arg0)
m_moawflfe(C_kxdobmrm arg0)
setState(NetworkState state)
m_129498_(C_4965_ arg0)
setProtocol(EnumProtocol arg0)
public void
channelInactive(io.netty.channel.ChannelHandlerContext arg0)
channelInactive(io.netty.channel.ChannelHandlerContext arg0)
channelInactive(io.netty.channel.ChannelHandlerContext arg0)
channelInactive(io.netty.channel.ChannelHandlerContext context)
channelInactive(io.netty.channel.ChannelHandlerContext arg0)
public void
exceptionCaught(io.netty.channel.ChannelHandlerContext arg0, Throwable arg1)
exceptionCaught(io.netty.channel.ChannelHandlerContext arg0, Throwable arg1)
exceptionCaught(io.netty.channel.ChannelHandlerContext arg0, Throwable arg1)
exceptionCaught(io.netty.channel.ChannelHandlerContext context, Throwable ex)
exceptionCaught(io.netty.channel.ChannelHandlerContext p_129534_, Throwable arg1)
protected void
a(io.netty.channel.ChannelHandlerContext arg0, pk<?> arg1)
channelRead0(io.netty.channel.ChannelHandlerContext arg0, Packet<?> arg1)
method_10770(io.netty.channel.ChannelHandlerContext arg0, class_2596<?> arg1)
m_zyhzemut(io.netty.channel.ChannelHandlerContext arg0, C_zyjtrjrl<?> arg1)
channelRead0(io.netty.channel.ChannelHandlerContext arg0, Packet<?> arg1)
channelRead0(io.netty.channel.ChannelHandlerContext p_129488_, C_5028_<?> arg1)
private static <T extends PacketListener> void
a(pk<T> arg0, oj arg1)
genericsFtw(Packet<T> arg0, PacketListener arg1)
method_10759(class_2596<T> arg0, class_2547 arg1)
m_rgronykr(C_zyjtrjrl<T> arg0, C_tkgdawqw arg1)
handlePacket(Packet<T> packet, PacketListener listener)
m_129517_(C_5028_<T> p_129518_, C_4986_ p_129519_)
public void
a(oj arg0)
setListener(PacketListener arg0)
method_10763(class_2547 arg0)
m_qqopfmuz(C_tkgdawqw arg0)
setPacketListener(PacketListener listener)
m_129505_(C_4986_ arg0)
setPacketListener(PacketListener arg0)
public void
a(pk<?> arg0)
send(Packet<?> arg0)
method_10743(class_2596<?> arg0)
m_egofcujr(C_zyjtrjrl<?> arg0)
send(Packet<?> packet)
m_129512_(C_5028_<?> arg0)
sendPacket(Packet<?> arg0)
public void
a(pk<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
send(Packet<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
method_10752(class_2596<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
m_fgmkpwtg(C_zyjtrjrl<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
send(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback)
m_129514_(C_5028_<?> p_129516_, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
sendPacket(Packet<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
private void
b(pk<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
sendPacket(Packet<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
method_10764(class_2596<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
m_bgcagbfi(C_zyjtrjrl<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
sendImmediately(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback)
m_129520_(C_5028_<?> p_129522_, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1)
private void
a(pk<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1, of arg2, of arg3)
doSendPacket(Packet<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1, ConnectionProtocol arg2, ConnectionProtocol arg3)
method_36942(class_2596<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1, class_2539 arg2, class_2539 arg3)
m_vyytglie(C_zyjtrjrl<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1, C_kxdobmrm arg2, C_kxdobmrm arg3)
sendInternal(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback, NetworkState arg2, NetworkState arg3)
m_178303_(C_5028_<?> p_178305_, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> p_178306_, C_4965_ p_178307_, C_4965_ arg3)
private ConnectionProtocol
p()
getCurrentProtocol()
method_32306()
m_igiszgub()
getState()
m_178315_()
private void
q()
flushQueue()
method_10751()
m_akpgjfcu()
sendQueuedPackets()
m_129544_()
public void
a()
tick()
method_10754()
m_tulexlec()
tick()
m_129483_()
protected void
b()
tickSecond()
method_30615()
m_eiltuozj()
updateStats()
m_7073_()
public SocketAddress
c()
getRemoteAddress()
method_10755()
m_sigcqeza()
getAddress()
m_129523_()
getSocketAddress()
public void
a(os arg0)
disconnect(Component arg0)
method_10747(class_2561 arg0)
m_kbtplepg(C_rdaqiwdt arg0)
disconnect(Text disconnectReason)
m_129507_(C_4996_ arg0)
close(IChatBaseComponent arg0)
public boolean
d()
isMemoryConnection()
method_10756()
m_wrxqepoa()
isLocal()
m_129531_()
isLocal()
public PacketFlow
e()
getReceiving()
method_36121()
m_ziivfjpb()
getSide()
m_178313_()
public PacketFlow
f()
getSending()
method_36122()
m_kqbvmhdm()
getOppositeSide()
m_178314_()
public static Connection
a(InetSocketAddress arg0, boolean arg1)
connectToServer(InetSocketAddress arg0, boolean arg1)
method_10753(InetSocketAddress arg0, boolean arg1)
m_vkqagjgi(InetSocketAddress arg0, boolean arg1)
connect(InetSocketAddress address, boolean useEpoll)
m_178300_(InetSocketAddress p_178301_, boolean p_178302_)
public static Connection
a(SocketAddress arg0)
connectToLocalServer(SocketAddress arg0)
method_10769(SocketAddress arg0)
m_lyptmghi(SocketAddress arg0)
connectLocal(SocketAddress address)
m_129493_(SocketAddress p_129494_)
public void
a(Cipher arg0, Cipher arg1)
setEncryptionKey(Cipher arg0, Cipher arg1)
method_10746(Cipher arg0, Cipher arg1)
m_ebvsfyfg(Cipher arg0, Cipher arg1)
setupEncryption(Cipher decryptionCipher, Cipher encryptionCipher)
m_129495_(Cipher p_129497_, Cipher arg1)
public boolean
g()
isEncrypted()
method_10771()
m_urabqmij()
isEncrypted()
m_129535_()
public boolean
h()
isConnected()
method_10758()
m_xphjmqxa()
isOpen()
m_129536_()
isConnected()
public boolean
i()
isConnecting()
method_10772()
m_bnpqdudq()
hasChannel()
m_129537_()
public PacketListener
j()
getPacketListener()
method_10744()
m_bhwloxoc()
getPacketListener()
m_129538_()
public Component
k()
getDisconnectedReason()
method_10748()
m_bywquzql()
getDisconnectReason()
m_129539_()
public void
l()
setReadOnly()
method_10757()
m_cxygpyan()
disableAutoRead()
m_129540_()
stopReading()
public void
a(int arg0, boolean arg1)
setupCompression(int arg0, boolean arg1)
method_10760(int arg0, boolean arg1)
m_uyfxzupt(int arg0, boolean arg1)
setCompressionThreshold(int compressionThreshold, boolean rejectsBadPackets)
m_129484_(int p_182682_, boolean arg1)
setCompressionLevel(int arg0, boolean arg1)
public void
m()
handleDisconnection()
method_10768()
m_wlmhzfek()
handleDisconnection()
m_129541_()
handleDisconnection()
public float
n()
getAverageReceivedPackets()
method_10762()
m_jitsmihi()
getAveragePacketsReceived()
m_129542_()
public float
o()
getAverageSentPackets()
method_10745()
m_uhgukhmf()
getAveragePacketsSent()
m_129543_()