net.minecraft.network.Connection

net.minecraft.network

public class Connection

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

	ek
	net.minecraft.unmapped.C_05587068
	net.minecraft.network.Connection

Field summary

Modifier and Type

Field

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

	g
	f_69220876
	LOGGER

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

	a
	f_49053781
	MARKER_NETWORK

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

	b
	f_98171336
	MARKER_NETWORK_PACKETS

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

	c
	f_56494702
	PROTOCOL

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

	d
	f_87458716
	NETWORK_GROUP

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

	e
	f_17860218
	EPOLL_NETWORK_GROUP

public static final LazySupplier<io.netty.channel.local.LocalEventLoopGroup>

	f
	f_81753641
	LOCAL_NETWORK_GROUP

private final PacketFlow

	h
	f_54741588
	flow

private final Queue<Connection$QueuedPacket>

	i
	f_52113552
	sendQueue

private final ReentrantReadWriteLock

	j
	f_25564011
	lock

private io.netty.channel.Channel

	k
	f_32499547
	channel

private SocketAddress

	l
	f_25714849
	address

private PacketHandler

	m
	f_73554042
	listener

private Text

	n
	f_12389608
	disconnectReason

private boolean

	o
	f_51676404
	encrypted

private boolean

	p
	f_07278245
	disconnected

Constructor summary

Modifier	Constructor
public	(PacketFlow flow)

Method summary

Modifier and Type

Method

public void

channelActive(io.netty.channel.ChannelHandlerContext arg0)

public void

	a(el arg0)
	m_26191327(C_98834311 arg0)
	setProtocol(NetworkProtocol protocol)

public void

channelInactive(io.netty.channel.ChannelHandlerContext arg0)

public void

exceptionCaught(io.netty.channel.ChannelHandlerContext arg0, Throwable arg1)

protected void

	a(io.netty.channel.ChannelHandlerContext arg0, ff<?> arg1)
	channelRead0(io.netty.channel.ChannelHandlerContext arg0, C_03562565<?> arg1)
	channelRead0(io.netty.channel.ChannelHandlerContext ctx, Packet<?> packet)

public void

	a(ep arg0)
	m_28862542(C_10918870 arg0)
	setListener(PacketHandler listener)

public void

	a(ff<?> arg0)
	m_48086380(C_03562565<?> arg0)
	send(Packet<?> packet)

public void

	a(ff<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... arg2)
	m_00234283(C_03562565<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> arg1, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... arg2)
	send(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>... listeners)

private void

	a(ff<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>[] arg1)
	m_67742570(C_03562565<?> arg0, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>[] arg1)
	doSend(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>>[] listeners)

private void

	m()
	m_70509198()
	flushQueue()

public void

	a()
	m_81049378()
	tick()

public SocketAddress

	b()
	m_13069039()
	getAddress()

public void

	a(eu arg0)
	m_13595665(C_95231345 arg0)
	disconnect(Text reason)

public boolean

	c()
	m_66517083()
	isLocal()

public void

	a(SecretKey arg0)
	m_93804007(SecretKey arg0)
	setupEncryption(SecretKey key)

public boolean

	g()
	m_89401393()
	isConnected()

public boolean

	h()
	m_70300325()
	isConnecting()

public PacketHandler

	i()
	m_00769931()
	getListener()

public Text

	j()
	m_57447328()
	getDisconnectReason()

public void

	k()
	m_18674441()
	disableAutoRead()

public void

	a(int arg0)
	m_63287756(int arg0)
	setCompressionThreshold(int threshold)

public void

	l()
	m_64465424()
	handleDisconnection()

public static Connection

	a(InetAddress arg0, int arg1, boolean arg2)
	m_20835321(InetAddress arg0, int arg1, boolean arg2)
	connect(InetAddress address, int port, boolean epoll)

public static Connection

	a(SocketAddress arg0)
	m_64314410(SocketAddress arg0)
	connectLocal(SocketAddress address)

public boolean

	f()
	m_82295725()
	isEncrypted()