Package 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 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 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 Description ClientConnection(NetworkSide side)
-
Method Summary
Modifier and Type Method 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>
voidhandlePacket(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 Details
-
LOGGER
-
MARKER_NETWORK
-
MARKER_NETWORK_PACKETS
-
ATTR_KEY_PROTOCOL
-
CLIENT_IO_GROUP
-
CLIENT_IO_GROUP_EPOLL
-
CLIENT_IO_GROUP_LOCAL
-
side
-
packetQueue
-
channel
private io.netty.channel.Channel channel -
address
-
packetListener
-
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 Details
-
ClientConnection
-
-
Method Details
-
channelActive
public void channelActive(io.netty.channel.ChannelHandlerContext channelHandlerContext) throws Exception- Specified by:
channelActive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelActive
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
Exception
-
setState
-
channelInactive
public void channelInactive(io.netty.channel.ChannelHandlerContext channelHandlerContext) throws Exception- Specified by:
channelInactive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelInactive
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
Exception
-
exceptionCaught
public void exceptionCaught(io.netty.channel.ChannelHandlerContext channelHandlerContext, Throwable throwable)- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelHandler
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
exceptionCaught
in classio.netty.channel.ChannelInboundHandlerAdapter
-
channelRead0
protected void channelRead0(io.netty.channel.ChannelHandlerContext channelHandlerContext, Packet<?> packet)- Specified by:
channelRead0
in classio.netty.channel.SimpleChannelInboundHandler<Packet<?>>
-
handlePacket
private static <T extends PacketListener> void handlePacket(Packet<T> packet, PacketListener listener) -
setPacketListener
-
send
-
send
-
sendImmediately
-
sendQueuedPackets
private void sendQueuedPackets() -
tick
public void tick() -
updateStats
protected void updateStats() -
getAddress
-
disconnect
-
isLocal
public boolean isLocal() -
connect
@Environment(CLIENT) public static ClientConnection connect(InetAddress address, int port, boolean shouldUseNativeTransport) -
connectLocal
-
setupEncryption
-
isEncrypted
@Environment(CLIENT) public boolean isEncrypted() -
isOpen
public boolean isOpen() -
hasChannel
public boolean hasChannel() -
getPacketListener
-
getDisconnectReason
-
disableAutoRead
public void disableAutoRead() -
setCompressionThreshold
public void setCompressionThreshold(int compressionThreshold) -
handleDisconnection
public void handleDisconnection() -
getAveragePacketsReceived
public float getAveragePacketsReceived() -
getAveragePacketsSent
@Environment(CLIENT) public float getAveragePacketsSent()
-