org.cloudburstmc.netty.channel.raknet

Class RakServerChannel

java.lang.Object

org.cloudburstmc.netty.channel.proxy.ProxyChannel<io.netty.channel.socket.DatagramChannel>

org.cloudburstmc.netty.channel.raknet.RakServerChannel

All Implemented Interfaces:

io.netty.channel.Channel, io.netty.channel.ChannelOutboundInvoker, io.netty.channel.ServerChannel, io.netty.util.AttributeMap, java.lang.Comparable<io.netty.channel.Channel>

public class RakServerChannel
extends ProxyChannel<io.netty.channel.socket.DatagramChannel>
implements io.netty.channel.ServerChannel

Nested Class Summary

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

io.netty.channel.Channel.Unsafe

Field Summary

Fields inherited from class org.cloudburstmc.netty.channel.proxy.ProxyChannel

channel, pipeline

Constructor Summary

Constructors

Constructor and Description
RakServerChannel(io.netty.channel.socket.DatagramChannel channel)
RakServerChannel(io.netty.channel.socket.DatagramChannel channel, java.util.function.Consumer<RakChannel> childConsumer)

Method Summary

Modifier and Type	Method and Description
RakServerChannelConfig	config()
RakChildChannel	createChildChannel(java.net.InetSocketAddress address, long clientGuid, int protocolVersion, int mtu) Create new child channel assigned to remote address.
RakChildChannel	getChildChannel(java.net.SocketAddress address)
void	onCloseTriggered(io.netty.channel.ChannelPromise promise)
boolean	tryBlockAddress(java.net.InetAddress address, long time, java.util.concurrent.TimeUnit unit)

Methods inherited from class org.cloudburstmc.netty.channel.proxy.ProxyChannel

alloc, attr, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, correctPromise, deregister, deregister, disconnect, disconnect, eventLoop, flush, hasAttr, id, internalPipeline, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, newChannelPipeline, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush

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.Channel

alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, metadata, parent, pipeline, read, remoteAddress, unsafe

Methods inherited from interface io.netty.util.AttributeMap

attr, hasAttr

Methods inherited from interface io.netty.channel.ChannelOutboundInvoker

bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from interface java.lang.Comparable

compareTo

Constructor Detail

RakServerChannel

public RakServerChannel(io.netty.channel.socket.DatagramChannel channel)

RakServerChannel

public RakServerChannel(io.netty.channel.socket.DatagramChannel channel,
                        java.util.function.Consumer<RakChannel> childConsumer)

Method Detail

createChildChannel

public RakChildChannel createChildChannel(java.net.InetSocketAddress address,
                                          long clientGuid,
                                          int protocolVersion,
                                          int mtu)

Create new child channel assigned to remote address.

Parameters:

address - remote address of new connection.

Returns:

RakChildChannel instance of new channel.

getChildChannel

public RakChildChannel getChildChannel(java.net.SocketAddress address)

onCloseTriggered

public void onCloseTriggered(io.netty.channel.ChannelPromise promise)

Overrides:

onCloseTriggered in class ProxyChannel<io.netty.channel.socket.DatagramChannel>

tryBlockAddress

public boolean tryBlockAddress(java.net.InetAddress address,
                               long time,
                               java.util.concurrent.TimeUnit unit)

config

public RakServerChannelConfig config()

Specified by:

config in interface io.netty.channel.Channel

Overrides:

config in class ProxyChannel<io.netty.channel.socket.DatagramChannel>