org.xnio.netty.transport

Class WrappingXnioServerSocketChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.AbstractServerChannel

org.xnio.netty.transport.WrappingXnioServerSocketChannel

All Implemented Interfaces:

io.netty.channel.Channel, io.netty.channel.ServerChannel, io.netty.channel.socket.ServerSocketChannel, io.netty.util.AttributeMap, Comparable<io.netty.channel.Channel>

public final class WrappingXnioServerSocketChannel
extends io.netty.channel.AbstractServerChannel

AbstractXnioServerSocketChannel implementation which allows to use a AcceptingChannel and wrap it.

Author:

Norman Maurer

Nested Class Summary

Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel

io.netty.channel.AbstractChannel.AbstractUnsafe

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

io.netty.channel.Channel.Unsafe

Constructor Summary

Constructors

Constructor and Description
WrappingXnioServerSocketChannel(org.xnio.channels.AcceptingChannel channel) Create a new instance wrapping the given AcceptingChannel

Method Summary

Modifier and Type	Method and Description
org.xnio.netty.transport.XnioServerSocketChannelConfigImpl	config()
protected void	doBeginRead()
protected void	doBind(SocketAddress localAddress)
protected void	doClose()
protected <T> T	getOption0(org.xnio.Option<T> option) Return the value for the given Option.
org.xnio.XnioIoThread	ioThread()
boolean	isActive()
protected boolean	isCompatible(io.netty.channel.EventLoop loop)
boolean	isOpen()
InetSocketAddress	localAddress()
protected SocketAddress	localAddress0()
InetSocketAddress	remoteAddress()
protected <T> void	setOption0(org.xnio.Option<T> option, T value) Set the given Option to the given value.
protected org.xnio.channels.AcceptingChannel	xnioChannel() Return the underyling AcceptingChannel

Methods inherited from class io.netty.channel.AbstractServerChannel

doDisconnect, doWrite, filterOutboundMessage, metadata, newUnsafe, remoteAddress0

Methods inherited from class io.netty.channel.AbstractChannel

alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, equals, eventLoop, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from class io.netty.util.DefaultAttributeMap

attr

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.netty.channel.Channel

alloc, bind, bind, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isRegistered, isWritable, metadata, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from interface io.netty.util.AttributeMap

attr

Methods inherited from interface java.lang.Comparable

compareTo

Constructor Detail

WrappingXnioServerSocketChannel

public WrappingXnioServerSocketChannel(org.xnio.channels.AcceptingChannel channel)

Create a new instance wrapping the given AcceptingChannel

Method Detail

ioThread

public org.xnio.XnioIoThread ioThread()

setOption0

protected <T> void setOption0(org.xnio.Option<T> option,
                              T value)
                       throws IOException

Set the given Option to the given value.

Throws:

IOException

getOption0

protected <T> T getOption0(org.xnio.Option<T> option)
                    throws IOException

Return the value for the given Option.

Throws:

IOException

doBind

protected void doBind(SocketAddress localAddress)
               throws Exception

Specified by:

doBind in class io.netty.channel.AbstractChannel

Throws:

Exception

xnioChannel

protected org.xnio.channels.AcceptingChannel xnioChannel()

Return the underyling AcceptingChannel

isCompatible

protected boolean isCompatible(io.netty.channel.EventLoop loop)

Specified by:

isCompatible in class io.netty.channel.AbstractChannel

isActive

public boolean isActive()

Specified by:

isActive in interface io.netty.channel.Channel

localAddress

public InetSocketAddress localAddress()

Specified by:

localAddress in interface io.netty.channel.Channel

Specified by:

localAddress in interface io.netty.channel.socket.ServerSocketChannel

Overrides:

localAddress in class io.netty.channel.AbstractChannel

remoteAddress

public InetSocketAddress remoteAddress()

Specified by:

remoteAddress in interface io.netty.channel.Channel

Specified by:

remoteAddress in interface io.netty.channel.socket.ServerSocketChannel

Overrides:

remoteAddress in class io.netty.channel.AbstractServerChannel

config

public org.xnio.netty.transport.XnioServerSocketChannelConfigImpl config()

Specified by:

config in interface io.netty.channel.Channel

Specified by:

config in interface io.netty.channel.socket.ServerSocketChannel

localAddress0

protected SocketAddress localAddress0()

Specified by:

localAddress0 in class io.netty.channel.AbstractChannel

doClose

protected void doClose()
                throws Exception

Specified by:

doClose in class io.netty.channel.AbstractChannel

Throws:

Exception

doBeginRead

protected void doBeginRead()
                    throws Exception

Specified by:

doBeginRead in class io.netty.channel.AbstractChannel

Throws:

Exception

isOpen

public boolean isOpen()

Specified by:

isOpen in interface io.netty.channel.Channel