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/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static LazyLoadBase<io.netty.channel.epoll.EpollEventLoopGroup>	CLIENT_EPOLL_EVENTLOOP
static LazyLoadBase<io.netty.channel.DefaultEventLoopGroup>	CLIENT_LOCAL_EVENTLOOP
static LazyLoadBase<io.netty.channel.nio.NioEventLoopGroup>	CLIENT_NIO_EVENTLOOP
static org.apache.logging.log4j.Marker	NETWORK_MARKER
static org.apache.logging.log4j.Marker	NETWORK_PACKETS_MARKER
static io.netty.util.AttributeKey<ProtocolType>	PROTOCOL_ATTRIBUTE_KEY

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()
void	enableEncryption(javax.crypto.SecretKey key)
void	exceptionCaught(io.netty.channel.ChannelHandlerContext p_exceptionCaught_1_, java.lang.Throwable p_exceptionCaught_2_)
PacketDirection	getDirection()
ITextComponent	getExitMessage()
INetHandler	getNetHandler()
float	getPacketsReceived()
float	getPacketsSent()
java.net.SocketAddress	getRemoteAddress()
void	handleDisconnection()
boolean	hasNoChannel()
boolean	isChannelOpen()
boolean	isEncrypted()
boolean	isLocalChannel()
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

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 LazyLoadBase<io.netty.channel.nio.NioEventLoopGroup> CLIENT_NIO_EVENTLOOP

CLIENT_EPOLL_EVENTLOOP

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

CLIENT_LOCAL_EVENTLOOP

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

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

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_)

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()