net.minecraft.network.Connection

net.minecraft.network

public class Connection

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

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

Field summary

Modifier and Type

Field

private static final float

	g
	AVERAGE_PACKETS_SMOOTHING
	field_33280
	CURRENT_PACKET_COUNTER_WEIGHT
	f_178299_

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

	h
	LOGGER
	field_11642
	LOGGER
	f_129465_

public static final org.apache.logging.log4j.Marker

	a
	ROOT_MARKER
	field_11641
	NETWORK_MARKER
	f_129459_

public static final org.apache.logging.log4j.Marker

	b
	PACKET_MARKER
	field_11639
	NETWORK_PACKETS_MARKER
	f_129460_

public static final io.netty.util.AttributeKey<ConnectionProtocol>

	c
	ATTRIBUTE_PROTOCOL
	field_11648
	PROTOCOL_ATTRIBUTE_KEY
	f_129461_

public static final LazyLoadedValue<io.netty.channel.nio.NioEventLoopGroup>

	d
	NETWORK_WORKER_GROUP
	field_11650
	CLIENT_IO_GROUP
	f_129462_

public static final LazyLoadedValue<io.netty.channel.epoll.EpollEventLoopGroup>

	e
	NETWORK_EPOLL_WORKER_GROUP
	field_11657
	EPOLL_CLIENT_IO_GROUP
	f_129463_

public static final LazyLoadedValue<io.netty.channel.DefaultEventLoopGroup>

	f
	LOCAL_WORKER_GROUP
	field_11649
	LOCAL_CLIENT_IO_GROUP
	f_129464_

private final PacketFlow

	i
	receiving
	field_11643
	side
	f_129466_

private final Queue<Connection$PacketHolder>

	j
	queue
	field_11644
	packetQueue
	f_129467_

private io.netty.channel.Channel

	k
	channel
	field_11651
	channel
	f_129468_

private SocketAddress

	l
	address
	field_11645
	address
	f_129469_

private PacketListener

	m
	packetListener
	field_11652
	packetListener
	f_129470_

private Component

	n
	disconnectedReason
	field_11660
	disconnectReason
	f_129471_

private boolean

	o
	encrypted
	field_11647
	encrypted
	f_129472_

private boolean

	p
	disconnectionHandled
	field_11646
	disconnected
	f_129473_

private int

	q
	receivedPackets
	field_11658
	packetsReceivedCounter
	f_129474_

private int

	r
	sentPackets
	field_11656
	packetsSentCounter
	f_129475_

private float

	s
	averageReceivedPackets
	field_11654
	averagePacketsReceived
	f_129476_

private float

	t
	averageSentPackets
	field_11653
	averagePacketsSent
	f_129477_

private int

	u
	tickCount
	field_11655
	ticks
	f_129478_

private boolean

	v
	handlingFault
	field_11640
	errored
	f_129479_

Constructor summary

Modifier	Constructor
public	(PacketFlow side)

Method summary

Modifier and Type

Method

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)
	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)
	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)
	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)
	setPacketListener(PacketListener listener)
	m_129505_(C_4986_ arg0)
	setPacketListener(PacketListener arg0)

public void

	a(pk<?> arg0)
	send(Packet<?> arg0)
	method_10743(class_2596<?> 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)
	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)
	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)
	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()
	getState()
	m_178315_()

private void

	q()
	flushQueue()
	method_10751()
	sendQueuedPackets()
	m_129544_()

public void

	a()
	tick()
	method_10754()
	tick()
	m_129483_()

protected void

	b()
	tickSecond()
	method_30615()
	updateStats()
	m_7073_()

public SocketAddress

	c()
	getRemoteAddress()
	method_10755()
	getAddress()
	m_129523_()
	getSocketAddress()

public void

	a(os arg0)
	disconnect(Component arg0)
	method_10747(class_2561 arg0)
	disconnect(Text disconnectReason)
	m_129507_(C_4996_ arg0)
	close(IChatBaseComponent arg0)

public boolean

	d()
	isMemoryConnection()
	method_10756()
	isLocal()
	m_129531_()
	isLocal()

public PacketFlow

	e()
	getReceiving()
	method_36121()
	getSide()
	m_178313_()

public PacketFlow

	f()
	getSending()
	method_36122()
	getOppositeSide()
	m_178314_()

public static Connection

	a(InetSocketAddress arg0, boolean arg1)
	connectToServer(InetSocketAddress arg0, boolean arg1)
	method_10753(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)
	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)
	setupEncryption(Cipher decryptionCipher, Cipher encryptionCipher)
	m_129495_(Cipher p_129497_, Cipher arg1)

public boolean

	g()
	isEncrypted()
	method_10771()
	isEncrypted()
	m_129535_()

public boolean

	h()
	isConnected()
	method_10758()
	isOpen()
	m_129536_()
	isConnected()

public boolean

	i()
	isConnecting()
	method_10772()
	hasChannel()
	m_129537_()

public PacketListener

	j()
	getPacketListener()
	method_10744()
	getPacketListener()
	m_129538_()

public Component

	k()
	getDisconnectedReason()
	method_10748()
	getDisconnectReason()
	m_129539_()

public void

	l()
	setReadOnly()
	method_10757()
	disableAutoRead()
	m_129540_()
	stopReading()

public void

	a(int arg0)
	setupCompression(int arg0)
	method_10760(int arg0)
	setCompressionThreshold(int compressionThreshold)
	m_129484_(int arg0)
	setCompressionLevel(int arg0)

public void

	m()
	handleDisconnection()
	method_10768()
	handleDisconnection()
	m_129541_()
	handleDisconnection()

public float

	n()
	getAverageReceivedPackets()
	method_10762()
	getAveragePacketsReceived()
	m_129542_()

public float

	o()
	getAverageSentPackets()
	method_10745()
	getAveragePacketsSent()
	m_129543_()