net.minecraft.network

Class NetworkManager

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

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

net.minecraft.network.NetworkManager

All Implemented Interfaces:

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

public class NetworkManager
extends io.netty.channel.SimpleChannelInboundHandler<IPacket<?>>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	NetworkManager.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 java.util.function.Consumer<NetworkManager>	activationHandler
private io.netty.channel.Channel	channel
static LazyValue<io.netty.channel.epoll.EpollEventLoopGroup>	CLIENT_EPOLL_EVENTLOOP
static LazyValue<io.netty.channel.DefaultEventLoopGroup>	CLIENT_LOCAL_EVENTLOOP
static LazyValue<io.netty.channel.nio.NioEventLoopGroup>	CLIENT_NIO_EVENTLOOP
private PacketDirection	direction
private boolean	disconnected
private int	field_211394_q
private int	field_211395_r
private float	field_211396_s
private float	field_211397_t
private boolean	field_211399_v
private boolean	isEncrypted
private static org.apache.logging.log4j.Logger	LOGGER
static org.apache.logging.log4j.Marker	NETWORK_MARKER
static org.apache.logging.log4j.Marker	NETWORK_PACKETS_MARKER
private java.util.Queue<NetworkManager.QueuedPacket>	outboundPacketsQueue
private INetHandler	packetListener
static io.netty.util.AttributeKey<ProtocolType>	PROTOCOL_ATTRIBUTE_KEY
private java.net.SocketAddress	socketAddress
private ITextComponent	terminationReason
private int	ticks

Constructor Summary

Constructors

Constructor and Description
NetworkManager(PacketDirection packetDirection)

Method Summary

Modifier and Type	Method and Description
io.netty.channel.Channel	channel()
void	channelActive(io.netty.channel.ChannelHandlerContext p_channelActive_1_)
void	channelInactive(io.netty.channel.ChannelHandlerContext p_channelInactive_1_)
protected void	channelRead0(io.netty.channel.ChannelHandlerContext p_channelRead0_1_, IPacket<?> p_channelRead0_2_)
void	closeChannel(ITextComponent message)
static NetworkManager	createNetworkManagerAndConnect(java.net.InetAddress address, int serverPort, boolean useNativeTransport)
void	disableAutoRead()
private void	dispatchPacket(IPacket<?> inPacket, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>> futureListeners)
void	enableEncryption(javax.crypto.SecretKey key)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext p_exceptionCaught_1_, java.lang.Throwable p_exceptionCaught_2_)
private void	flushOutboundQueue()
PacketDirection	getDirection()
ITextComponent	getExitMessage()
INetHandler	getNetHandler()
float	getPacketsReceived()
float	getPacketsSent()
java.net.SocketAddress	getRemoteAddress()
void	handleDisconnection()
boolean	hasNoChannel()
boolean	isChannelOpen()
boolean	isEncrypted()
boolean	isLocalChannel()
private static <T extends INetHandler> void	processPacket(IPacket<T> p_197664_0_, INetHandler p_197664_1_)
static NetworkManager	provideLocalClient(java.net.SocketAddress address)
void	sendPacket(IPacket<?> packetIn)
void	sendPacket(IPacket<?> packetIn, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>> p_201058_2_)
void	setCompressionThreshold(int threshold)
void	setConnectionState(ProtocolType newState)
void	setNetHandler(INetHandler handler)
void	tick()

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 org.apache.logging.log4j.Logger LOGGER

NETWORK_MARKER

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

NETWORK_PACKETS_MARKER

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

PROTOCOL_ATTRIBUTE_KEY

public static final io.netty.util.AttributeKey<ProtocolType> PROTOCOL_ATTRIBUTE_KEY

CLIENT_NIO_EVENTLOOP

public static final LazyValue<io.netty.channel.nio.NioEventLoopGroup> CLIENT_NIO_EVENTLOOP

CLIENT_EPOLL_EVENTLOOP

public static final LazyValue<io.netty.channel.epoll.EpollEventLoopGroup> CLIENT_EPOLL_EVENTLOOP

CLIENT_LOCAL_EVENTLOOP

public static final LazyValue<io.netty.channel.DefaultEventLoopGroup> CLIENT_LOCAL_EVENTLOOP

direction

private final PacketDirection direction

outboundPacketsQueue

private final java.util.Queue<NetworkManager.QueuedPacket> outboundPacketsQueue

channel

private io.netty.channel.Channel channel

socketAddress

private java.net.SocketAddress socketAddress

packetListener

private INetHandler packetListener

terminationReason

private ITextComponent terminationReason

isEncrypted

private boolean isEncrypted

disconnected

private boolean disconnected

field_211394_q

private int field_211394_q

field_211395_r

private int field_211395_r

field_211396_s

private float field_211396_s

field_211397_t

private float field_211397_t

ticks

private int ticks

field_211399_v

private boolean field_211399_v

activationHandler

private java.util.function.Consumer<NetworkManager> activationHandler

Constructor Detail

NetworkManager

public NetworkManager(PacketDirection packetDirection)

Method Detail

channelActive

public void channelActive(io.netty.channel.ChannelHandlerContext p_channelActive_1_)
                   throws java.lang.Exception

Specified by:

channelActive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelActive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

java.lang.Exception

setConnectionState

public void setConnectionState(ProtocolType newState)

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext p_channelInactive_1_)
                     throws java.lang.Exception

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

Throws:

java.lang.Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext p_exceptionCaught_1_,
                            java.lang.Throwable p_exceptionCaught_2_)

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 p_channelRead0_1_,
                            IPacket<?> p_channelRead0_2_)
                     throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception

processPacket

private static <T extends INetHandler> void processPacket(IPacket<T> p_197664_0_,
                                                          INetHandler p_197664_1_)

setNetHandler

public void setNetHandler(INetHandler handler)

sendPacket

public void sendPacket(IPacket<?> packetIn)

sendPacket

public void sendPacket(IPacket<?> packetIn,
                       @Nullable
                       io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>> p_201058_2_)

dispatchPacket

private void dispatchPacket(IPacket<?> inPacket,
                            @Nullable
                            io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>> futureListeners)

flushOutboundQueue

private void flushOutboundQueue()

tick

public void tick()

getRemoteAddress

public java.net.SocketAddress getRemoteAddress()

closeChannel

public void closeChannel(ITextComponent message)

isLocalChannel

public boolean isLocalChannel()

createNetworkManagerAndConnect

public static NetworkManager createNetworkManagerAndConnect(java.net.InetAddress address,
                                                            int serverPort,
                                                            boolean useNativeTransport)

provideLocalClient

public static NetworkManager provideLocalClient(java.net.SocketAddress address)

enableEncryption

public void enableEncryption(javax.crypto.SecretKey key)

isEncrypted

public boolean isEncrypted()

isChannelOpen

public boolean isChannelOpen()

hasNoChannel

public boolean hasNoChannel()

getNetHandler

public INetHandler getNetHandler()

getExitMessage

@Nullable
public ITextComponent getExitMessage()

disableAutoRead

public void disableAutoRead()

setCompressionThreshold

public void setCompressionThreshold(int threshold)

handleDisconnection

public void handleDisconnection()

getPacketsReceived

public float getPacketsReceived()

getPacketsSent

public float getPacketsSent()

channel

public io.netty.channel.Channel channel()

getDirection

public PacketDirection getDirection()