Top Inners Fields Constructors Methods
io.netty.channel.kqueue

public final Class KQueueSocketChannel

extends AbstractKQueueStreamChannel
implements SocketChannel
Class Inheritance
All Implemented Interfaces
io.netty.channel.socket.SocketChannel, io.netty.channel.socket.DuplexChannel, io.netty.channel.Channel, java.lang.Comparable, io.netty.channel.ChannelOutboundInvoker, io.netty.util.AttributeMap
Annotations
@UnstableApi
Imports
io.netty.buffer.ByteBuf, io.netty.channel.Channel, .ChannelOutboundBuffer, io.netty.channel.socket.InternetProtocolFamily, .ServerSocketChannel, .SocketChannel, io.netty.channel.unix.IovArray, io.netty.util.concurrent.GlobalEventExecutor, io.netty.util.internal.UnstableApi, java.net.InetSocketAddress, .SocketAddress, java.util.concurrent.Executor

Nested and Inner Type Summary

Modifier and TypeClass and Description
private class
KQueueSocketChannel.KQueueSocketChannelUnsafe

Field Summary

Modifier and TypeField and Description
private final KQueueSocketChannelConfig
config

Constructor Summary

AccessConstructor and Description
public
KQueueSocketChannel()

public
KQueueSocketChannel(InternetProtocolFamily protocol)

public
KQueueSocketChannel(int fd)

pack-priv
KQueueSocketChannel(Channel parent, BsdSocket fd, InetSocketAddress remoteAddress)

Method Summary

Modifier and TypeMethod and Description
public KQueueSocketChannelConfig
config()

Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.config.

Implements io.netty.channel.socket.SocketChannel.config, io.netty.channel.Channel.config.

Returns the configuration of this channel.
protected boolean
doConnect0(SocketAddress remoteAddress, SocketAddress localAddress)

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doConnect0.

public InetSocketAddress
localAddress()

Overrides io.netty.channel.AbstractChannel.localAddress.

Implements io.netty.channel.socket.SocketChannel.localAddress, io.netty.channel.Channel.localAddress.

Returns the local address where this channel is bound to.
protected AbstractKQueueChannel.AbstractKQueueUnsafe
newUnsafe()

Overrides io.netty.channel.kqueue.AbstractKQueueStreamChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel
public ServerSocketChannel
parent()

Overrides io.netty.channel.AbstractChannel.parent.

Implements io.netty.channel.socket.SocketChannel.parent, io.netty.channel.Channel.parent.

Returns the parent of this channel.
public InetSocketAddress
remoteAddress()

Overrides io.netty.channel.AbstractChannel.remoteAddress.

Implements io.netty.channel.socket.SocketChannel.remoteAddress, io.netty.channel.Channel.remoteAddress.

Returns the remote address where this channel is connected to.
Inherited from io.netty.channel.kqueue.AbstractKQueueStreamChannel:
doShutdownOutputdoWritedoWriteSinglefilterOutboundMessageisInputShutdownisOutputShutdownisShutdownmetadatashutdownshutdownshutdownInputshutdownInputshutdownOutputshutdownOutput

Field Detail

configback to summary
private final KQueueSocketChannelConfig config

Constructor Detail

KQueueSocketChannelback to summary
public KQueueSocketChannel()
KQueueSocketChannelback to summary
public KQueueSocketChannel(InternetProtocolFamily protocol)
KQueueSocketChannelback to summary
public KQueueSocketChannel(int fd)
KQueueSocketChannelback to summary
pack-priv KQueueSocketChannel(Channel parent, BsdSocket fd, InetSocketAddress remoteAddress)

Method Detail

configback to summary
public KQueueSocketChannelConfig config()

Implements abstract io.netty.channel.kqueue.AbstractKQueueChannel.config.

Implements io.netty.channel.socket.SocketChannel.config, io.netty.channel.Channel.config.

Doc from io.netty.channel.Channel.config.

Returns the configuration of this channel.

Annotations
@Override
doConnect0back to summary
protected boolean doConnect0(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception

Overrides io.netty.channel.kqueue.AbstractKQueueChannel.doConnect0.

Annotations
@Override
localAddressback to summary
public InetSocketAddress localAddress()

Overrides io.netty.channel.AbstractChannel.localAddress.

Implements io.netty.channel.socket.SocketChannel.localAddress, io.netty.channel.Channel.localAddress.

Doc from io.netty.channel.Channel.localAddress.

Returns the local address where this channel is bound to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Returns:InetSocketAddress

the local address of this channel. null if this channel is not bound.

Annotations
@Override
newUnsafeback to summary
protected AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()

Overrides io.netty.channel.kqueue.AbstractKQueueStreamChannel.newUnsafe.

Doc from io.netty.channel.AbstractChannel.newUnsafe.

Create a new AbstractUnsafe instance which will be used for the life-time of the Channel

Annotations
@Override
parentback to summary
public ServerSocketChannel parent()

Overrides io.netty.channel.AbstractChannel.parent.

Implements io.netty.channel.socket.SocketChannel.parent, io.netty.channel.Channel.parent.

Doc from io.netty.channel.Channel.parent.

Returns the parent of this channel.

Returns:ServerSocketChannel

the parent channel. null if this channel does not have a parent channel.

Annotations
@Override
remoteAddressback to summary
public InetSocketAddress remoteAddress()

Overrides io.netty.channel.AbstractChannel.remoteAddress.

Implements io.netty.channel.socket.SocketChannel.remoteAddress, io.netty.channel.Channel.remoteAddress.

Doc from io.netty.channel.Channel.remoteAddress.

Returns the remote address where this channel is connected to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Returns:InetSocketAddress

the remote address of this channel. null if this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g. DatagramChannel, use DatagramPacket#recipient() to determine the origination of the received message as this method will return null.

Annotations
@Override
io.netty.channel.kqueue back to summary

private final Class KQueueSocketChannel.KQueueSocketChannelUnsafe

extends KQueueStreamUnsafe
Class Inheritance

Constructor Summary

AccessConstructor and Description
private
KQueueSocketChannelUnsafe()

Method Summary

Modifier and TypeMethod and Description
protected Executor
prepareToClose()

Overrides io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe.prepareToClose.

Prepares to close the Channel.
Inherited from io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe:
readReady

Constructor Detail

KQueueSocketChannelUnsafeback to summary
private KQueueSocketChannelUnsafe()

Method Detail

prepareToCloseback to summary
protected Executor prepareToClose()

Overrides io.netty.channel.kqueue.AbstractKQueueStreamChannel.KQueueStreamUnsafe.prepareToClose.

Doc from io.netty.channel.AbstractChannel.AbstractUnsafe.prepareToClose.

Prepares to close the Channel. If this method returns an Executor, the caller must call the Executor#execute(Runnable) method with a task that calls doClose() on the returned Executor. If this method returns null, doClose() must be called from the caller thread. (i.e. EventLoop)

Annotations
@Override