net.minecraft.network

Class ClientConnection

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

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

net.minecraft.network.ClientConnection

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

Direct Known Subclasses:

RateLimitedConnection

public class ClientConnection
extends io.netty.channel.SimpleChannelInboundHandler<Packet<?>>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	ClientConnection.QueuedPacket

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

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
private SocketAddress	address
static io.netty.util.AttributeKey<NetworkState>	ATTR_KEY_PROTOCOL
private float	avgPacketsReceived
private float	avgPacketsSent
private io.netty.channel.Channel	channel
static Lazy<io.netty.channel.nio.NioEventLoopGroup>	CLIENT_IO_GROUP
static Lazy<io.netty.channel.epoll.EpollEventLoopGroup>	CLIENT_IO_GROUP_EPOLL
static Lazy<io.netty.channel.DefaultEventLoopGroup>	CLIENT_IO_GROUP_LOCAL
private boolean	disconnected
private Text	disconnectReason
private boolean	encrypted
private boolean	errored
private static Logger	LOGGER
static Marker	MARKER_NETWORK
static Marker	MARKER_NETWORK_PACKETS
private PacketListener	packetListener
private Queue<ClientConnection.QueuedPacket>	packetQueue
private int	packetsReceivedCounter
private int	packetsSentCounter
private NetworkSide	side
private int	ticks

Constructor Summary

Constructors

Constructor and Description
ClientConnection(NetworkSide side)

Method Summary

Modifier and Type	Method and Description
void	channelActive(io.netty.channel.ChannelHandlerContext channelHandlerContext)
void	channelInactive(io.netty.channel.ChannelHandlerContext channelHandlerContext)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext, Packet<?> packet)
static ClientConnection	connect(InetAddress address, int port, boolean shouldUseNativeTransport)
static ClientConnection	connectLocal(SocketAddress address)
void	disableAutoRead()
void	disconnect(Text disconnectReason)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext, Throwable throwable)
SocketAddress	getAddress()
float	getAveragePacketsReceived()
float	getAveragePacketsSent()
Text	getDisconnectReason()
PacketListener	getPacketListener()
void	handleDisconnection()
private static <T extends PacketListener> void	handlePacket(Packet<T> packet, PacketListener listener)
boolean	hasChannel()
boolean	isEncrypted()
boolean	isLocal()
boolean	isOpen()
void	send(Packet<?> packet)
void	send(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback)
private void	sendImmediately(Packet<?> packet, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback)
private void	sendQueuedPackets()
void	setCompressionThreshold(int compressionThreshold)
void	setPacketListener(PacketListener listener)
void	setState(NetworkState state)
void	setupEncryption(Cipher cipher, Cipher cipher2)
void	tick()
protected void	updateStats()

Methods inherited from class io.netty.channel.SimpleChannelInboundHandler

acceptInboundMessage, channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, 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

handlerAdded, handlerRemoved

Field Detail

LOGGER

private static final Logger LOGGER

MARKER_NETWORK

public static final Marker MARKER_NETWORK

MARKER_NETWORK_PACKETS

public static final Marker MARKER_NETWORK_PACKETS

ATTR_KEY_PROTOCOL

public static final io.netty.util.AttributeKey<NetworkState> ATTR_KEY_PROTOCOL

CLIENT_IO_GROUP

public static final Lazy<io.netty.channel.nio.NioEventLoopGroup> CLIENT_IO_GROUP

CLIENT_IO_GROUP_EPOLL

public static final Lazy<io.netty.channel.epoll.EpollEventLoopGroup> CLIENT_IO_GROUP_EPOLL

CLIENT_IO_GROUP_LOCAL

public static final Lazy<io.netty.channel.DefaultEventLoopGroup> CLIENT_IO_GROUP_LOCAL

side

private final NetworkSide side

packetQueue

private final Queue<ClientConnection.QueuedPacket> packetQueue

channel

private io.netty.channel.Channel channel

address

private SocketAddress address

packetListener

private PacketListener packetListener

disconnectReason

private Text disconnectReason

encrypted

private boolean encrypted

disconnected

private boolean disconnected

packetsReceivedCounter

private int packetsReceivedCounter

packetsSentCounter

private int packetsSentCounter

avgPacketsReceived

private float avgPacketsReceived

avgPacketsSent

private float avgPacketsSent

ticks

private int ticks

errored

private boolean errored

Constructor Detail

ClientConnection

public ClientConnection(NetworkSide side)

Method Detail

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext channelHandlerContext)
                   throws Exception

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

setState

public void setState(NetworkState state)

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext channelHandlerContext)
                     throws Exception

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                            Throwable throwable)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext,
                            Packet<?> packet)

Specified by:

channelRead0 in class io.netty.channel.SimpleChannelInboundHandler<Packet<?>>

handlePacket

private static <T extends PacketListener> void handlePacket(Packet<T> packet,
                                                            PacketListener listener)

setPacketListener

public void setPacketListener(PacketListener listener)

send

public void send(Packet<?> packet)

send

public void send(Packet<?> packet,
                 @Nullable
                 io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback)

sendImmediately

private void sendImmediately(Packet<?> packet,
                             @Nullable
                             io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> callback)

sendQueuedPackets

private void sendQueuedPackets()

tick

public void tick()

updateStats

protected void updateStats()

getAddress

public SocketAddress getAddress()

disconnect

public void disconnect(Text disconnectReason)

isLocal

public boolean isLocal()

connect

@Environment(value=CLIENT)
public static ClientConnection connect(InetAddress address,
                                                                  int port,
                                                                  boolean shouldUseNativeTransport)

connectLocal

@Environment(value=CLIENT)
public static ClientConnection connectLocal(SocketAddress address)

setupEncryption

public void setupEncryption(Cipher cipher,
                            Cipher cipher2)

isEncrypted

@Environment(value=CLIENT)
public boolean isEncrypted()

isOpen

public boolean isOpen()

hasChannel

public boolean hasChannel()

getPacketListener

public PacketListener getPacketListener()

getDisconnectReason

@Nullable
public Text getDisconnectReason()

disableAutoRead

public void disableAutoRead()

setCompressionThreshold

public void setCompressionThreshold(int compressionThreshold)

handleDisconnection

public void handleDisconnection()

getAveragePacketsReceived

public float getAveragePacketsReceived()

getAveragePacketsSent

@Environment(value=CLIENT)
public float getAveragePacketsSent()