net.minecraft.network

Class NetworkManager

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

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

net.minecraft.network.NetworkManager

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	NetworkManager.InboundHandlerTuplePacketListener

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 io.netty.channel.Channel	channel
static LazyLoadBase<io.netty.channel.epoll.EpollEventLoopGroup>	CLIENT_EPOLL_EVENTLOOP
static LazyLoadBase<io.netty.channel.local.LocalEventLoopGroup>	CLIENT_LOCAL_EVENTLOOP
static LazyLoadBase<io.netty.channel.nio.NioEventLoopGroup>	CLIENT_NIO_EVENTLOOP
private EnumPacketDirection	direction
private boolean	disconnected
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.InboundHandlerTuplePacketListener>	outboundPacketsQueue
private INetHandler	packetListener
static io.netty.util.AttributeKey<EnumConnectionState>	PROTOCOL_ATTRIBUTE_KEY
private java.util.concurrent.locks.ReentrantReadWriteLock	readWriteLock
private java.net.SocketAddress	socketAddress
private ITextComponent	terminationReason

Constructor Summary

Constructors

Constructor and Description
NetworkManager(EnumPacketDirection 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_, Packet<?> p_channelRead0_2_)
void	checkDisconnected()
void	closeChannel(ITextComponent message)
static NetworkManager	createNetworkManagerAndConnect(java.net.InetAddress address, int serverPort, boolean useNativeTransport)
void	disableAutoRead()
private void	dispatchPacket(Packet<?> 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()
EnumPacketDirection	getDirection()
ITextComponent	getExitMessage()
INetHandler	getNetHandler()
java.net.SocketAddress	getRemoteAddress()
boolean	hasNoChannel()
boolean	isChannelOpen()
boolean	isEncrypted()
boolean	isLocalChannel()
void	processReceivedPackets()
static NetworkManager	provideLocalClient(java.net.SocketAddress address)
void	sendPacket(Packet<?> packetIn)
void	sendPacket(Packet<?> packetIn, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>> listener, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>>... listeners)
void	setCompressionThreshold(int threshold)
void	setConnectionState(EnumConnectionState newState)
void	setNetHandler(INetHandler handler)

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<EnumConnectionState> 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.local.LocalEventLoopGroup> CLIENT_LOCAL_EVENTLOOP

direction

private final EnumPacketDirection direction

outboundPacketsQueue

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

readWriteLock

private final java.util.concurrent.locks.ReentrantReadWriteLock readWriteLock

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

Constructor Detail

NetworkManager

public NetworkManager(EnumPacketDirection packetDirection)

Method Detail

getDirection

public EnumPacketDirection getDirection()

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(EnumConnectionState 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_)
                     throws java.lang.Exception

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

Throws:

java.lang.Exception

channelRead0

protected void channelRead0(io.netty.channel.ChannelHandlerContext p_channelRead0_1_,
                            Packet<?> p_channelRead0_2_)
                     throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception

setNetHandler

public void setNetHandler(INetHandler handler)

sendPacket

public void sendPacket(Packet<?> packetIn)

sendPacket

public void sendPacket(Packet<?> packetIn,
                       io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>> listener,
                       io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super java.lang.Void>>... listeners)

dispatchPacket

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

flushOutboundQueue

private void flushOutboundQueue()

processReceivedPackets

public void processReceivedPackets()

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

public ITextComponent getExitMessage()

disableAutoRead

public void disableAutoRead()

setCompressionThreshold

public void setCompressionThreshold(int threshold)

checkDisconnected

public void checkDisconnected()

channel

public io.netty.channel.Channel channel()