public final class WrappingXnioSocketChannel
extends io.netty.channel.AbstractChannel
AbstractXnioSocketChannel implementation which allows you to wrap a pre-created XNIO channel.| Constructor and Description |
|---|
WrappingXnioSocketChannel(org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection> parent,
org.xnio.StreamConnection channel)
Create a new
WrappingXnioSocketChannel which was created via the given AcceptingChannel and uses
the given StreamConnection under the covers. |
WrappingXnioSocketChannel(org.xnio.StreamConnection channel)
Create a
WrappingXnioSocketChannel which uses the given StreamConnection under the covers. |
| Modifier and Type | Method and Description |
|---|---|
io.netty.channel.socket.SocketChannelConfig |
config() |
protected org.xnio.StreamConnection |
connection()
Returns the underlying
StreamConnection or null if not created yet. |
protected void |
doBeginRead() |
protected void |
doBind(SocketAddress localAddress) |
protected void |
doClose() |
protected void |
doDisconnect() |
protected void |
doWrite(io.netty.channel.ChannelOutboundBuffer in) |
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 |
isInputShutdown() |
boolean |
isOpen() |
boolean |
isOutputShutdown() |
boolean |
isShutdown() |
InetSocketAddress |
localAddress() |
protected SocketAddress |
localAddress0() |
io.netty.channel.ChannelMetadata |
metadata() |
protected org.xnio.netty.transport.WrappingXnioSocketChannel.XnioUnsafe |
newUnsafe() |
io.netty.channel.socket.ServerSocketChannel |
parent() |
InetSocketAddress |
remoteAddress() |
protected SocketAddress |
remoteAddress0() |
protected <T> void |
setOption0(org.xnio.Option<T> option,
T value)
Set the given
Option to the given value. |
io.netty.channel.ChannelFuture |
shutdown() |
io.netty.channel.ChannelFuture |
shutdown(io.netty.channel.ChannelPromise channelPromise) |
io.netty.channel.ChannelFuture |
shutdownInput() |
io.netty.channel.ChannelFuture |
shutdownInput(io.netty.channel.ChannelPromise channelPromise) |
io.netty.channel.ChannelFuture |
shutdownOutput() |
io.netty.channel.ChannelFuture |
shutdownOutput(io.netty.channel.ChannelPromise future) |
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, equals, eventLoop, filterOutboundMessage, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushclone, finalize, getClass, notify, notifyAll, wait, wait, waitalloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isRegistered, isWritable, pipeline, read, unsafebind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlushcompareTopublic WrappingXnioSocketChannel(org.xnio.channels.AcceptingChannel<org.xnio.StreamConnection> parent,
org.xnio.StreamConnection channel)
WrappingXnioSocketChannel which was created via the given AcceptingChannel and uses
the given StreamConnection under the covers.public WrappingXnioSocketChannel(org.xnio.StreamConnection channel)
WrappingXnioSocketChannel which uses the given StreamConnection under the covers.public org.xnio.XnioIoThread ioThread()
protected org.xnio.netty.transport.WrappingXnioSocketChannel.XnioUnsafe newUnsafe()
protected void doBind(SocketAddress localAddress) throws Exception
doBind in class io.netty.channel.AbstractChannelExceptionprotected <T> void setOption0(org.xnio.Option<T> option,
T value)
throws IOException
Option to the given value.IOExceptionprotected <T> T getOption0(org.xnio.Option<T> option)
throws IOException
Option.IOExceptionprotected org.xnio.StreamConnection connection()
StreamConnection or null if not created yet.public io.netty.channel.ChannelFuture shutdownInput()
shutdownInput in interface io.netty.channel.socket.DuplexChannelpublic io.netty.channel.ChannelFuture shutdownInput(io.netty.channel.ChannelPromise channelPromise)
shutdownInput in interface io.netty.channel.socket.DuplexChannelpublic io.netty.channel.socket.ServerSocketChannel parent()
parent in interface io.netty.channel.Channelparent in interface io.netty.channel.socket.SocketChannelparent in class io.netty.channel.AbstractChannelpublic InetSocketAddress remoteAddress()
remoteAddress in interface io.netty.channel.ChannelremoteAddress in interface io.netty.channel.socket.SocketChannelremoteAddress in class io.netty.channel.AbstractChannelpublic InetSocketAddress localAddress()
localAddress in interface io.netty.channel.ChannellocalAddress in interface io.netty.channel.socket.SocketChannellocalAddress in class io.netty.channel.AbstractChannelprotected boolean isCompatible(io.netty.channel.EventLoop loop)
isCompatible in class io.netty.channel.AbstractChannelprotected void doDisconnect()
throws Exception
doDisconnect in class io.netty.channel.AbstractChannelExceptionprotected void doWrite(io.netty.channel.ChannelOutboundBuffer in)
throws Exception
doWrite in class io.netty.channel.AbstractChannelExceptionpublic io.netty.channel.socket.SocketChannelConfig config()
config in interface io.netty.channel.Channelconfig in interface io.netty.channel.socket.SocketChannelpublic io.netty.channel.ChannelFuture shutdownOutput()
shutdownOutput in interface io.netty.channel.socket.DuplexChannelpublic io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise future)
shutdownOutput in interface io.netty.channel.socket.DuplexChannelpublic boolean isOpen()
isOpen in interface io.netty.channel.Channelpublic boolean isActive()
isActive in interface io.netty.channel.Channelpublic io.netty.channel.ChannelMetadata metadata()
metadata in interface io.netty.channel.Channelprotected SocketAddress localAddress0()
localAddress0 in class io.netty.channel.AbstractChannelprotected SocketAddress remoteAddress0()
remoteAddress0 in class io.netty.channel.AbstractChannelpublic boolean isInputShutdown()
isInputShutdown in interface io.netty.channel.socket.DuplexChannelpublic boolean isOutputShutdown()
isOutputShutdown in interface io.netty.channel.socket.DuplexChannelprotected void doBeginRead()
throws Exception
doBeginRead in class io.netty.channel.AbstractChannelExceptionprotected void doClose()
throws Exception
doClose in class io.netty.channel.AbstractChannelExceptionpublic boolean isShutdown()
isShutdown in interface io.netty.channel.socket.DuplexChannelpublic io.netty.channel.ChannelFuture shutdown()
shutdown in interface io.netty.channel.socket.DuplexChannelpublic io.netty.channel.ChannelFuture shutdown(io.netty.channel.ChannelPromise channelPromise)
shutdown in interface io.netty.channel.socket.DuplexChannelCopyright © 2013–2021 JBoss, a division of Red Hat. All rights reserved.