public class XnioSocketChannel
extends io.netty.channel.AbstractChannel
SocketChannel
which uses XNIO.Constructor and Description |
---|
XnioSocketChannel() |
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 . |
boolean |
isActive() |
protected boolean |
isCompatible(io.netty.channel.EventLoop loop) |
boolean |
isInputShutdown() |
boolean |
isOpen() |
boolean |
isOutputShutdown() |
InetSocketAddress |
localAddress() |
protected SocketAddress |
localAddress0() |
io.netty.channel.ChannelMetadata |
metadata() |
protected org.xnio.netty.transport.AbstractXnioSocketChannel.AbstractXnioUnsafe |
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 |
shutdownOutput() |
io.netty.channel.ChannelFuture |
shutdownOutput(io.netty.channel.ChannelPromise future) |
alloc, bind, bind, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doDeregister, doRegister, equals, eventLoop, filterOutboundMessage, flush, hashCode, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bind, bind, close, close, closeFuture, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, eventLoop, flush, isRegistered, isWritable, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, pipeline, read, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlush
compareTo
protected org.xnio.netty.transport.AbstractXnioSocketChannel.AbstractXnioUnsafe newUnsafe()
protected <T> void setOption0(org.xnio.Option<T> option, T value) throws IOException
Option
to the given value.IOException
protected <T> T getOption0(org.xnio.Option<T> option) throws IOException
Option
.IOException
protected org.xnio.StreamConnection connection()
StreamConnection
or null
if not created yet.protected void doBind(SocketAddress localAddress) throws Exception
doBind
in class io.netty.channel.AbstractChannel
Exception
public io.netty.channel.socket.ServerSocketChannel parent()
parent
in interface io.netty.channel.Channel
parent
in interface io.netty.channel.socket.SocketChannel
parent
in class io.netty.channel.AbstractChannel
public InetSocketAddress remoteAddress()
remoteAddress
in interface io.netty.channel.Channel
remoteAddress
in interface io.netty.channel.socket.SocketChannel
remoteAddress
in class io.netty.channel.AbstractChannel
public InetSocketAddress localAddress()
localAddress
in interface io.netty.channel.Channel
localAddress
in interface io.netty.channel.socket.SocketChannel
localAddress
in class io.netty.channel.AbstractChannel
protected boolean isCompatible(io.netty.channel.EventLoop loop)
isCompatible
in class io.netty.channel.AbstractChannel
protected void doDisconnect() throws Exception
doDisconnect
in class io.netty.channel.AbstractChannel
Exception
protected void doWrite(io.netty.channel.ChannelOutboundBuffer in) throws Exception
doWrite
in class io.netty.channel.AbstractChannel
Exception
public io.netty.channel.socket.SocketChannelConfig config()
config
in interface io.netty.channel.Channel
config
in interface io.netty.channel.socket.SocketChannel
public io.netty.channel.ChannelFuture shutdownOutput()
shutdownOutput
in interface io.netty.channel.socket.SocketChannel
public io.netty.channel.ChannelFuture shutdownOutput(io.netty.channel.ChannelPromise future)
shutdownOutput
in interface io.netty.channel.socket.SocketChannel
public boolean isOpen()
isOpen
in interface io.netty.channel.Channel
public boolean isActive()
isActive
in interface io.netty.channel.Channel
public io.netty.channel.ChannelMetadata metadata()
metadata
in interface io.netty.channel.Channel
protected SocketAddress localAddress0()
localAddress0
in class io.netty.channel.AbstractChannel
protected SocketAddress remoteAddress0()
remoteAddress0
in class io.netty.channel.AbstractChannel
public boolean isInputShutdown()
isInputShutdown
in interface io.netty.channel.socket.SocketChannel
public boolean isOutputShutdown()
isOutputShutdown
in interface io.netty.channel.socket.SocketChannel
protected void doBeginRead() throws Exception
doBeginRead
in class io.netty.channel.AbstractChannel
Exception
Copyright © 2013–2017 JBoss, a division of Red Hat. All rights reserved.