@UnstableApi
public final class KQueueDomainDatagramChannel
extends io.netty.channel.AbstractChannel
implements io.netty.channel.unix.DomainDatagramChannel
Modifier and Type | Field and Description |
---|---|
protected boolean |
active |
Constructor and Description |
---|
KQueueDomainDatagramChannel() |
KQueueDomainDatagramChannel(int fd) |
Modifier and Type | Method and Description |
---|---|
protected static void |
checkResolvable(InetSocketAddress addr) |
KQueueDomainDatagramChannelConfig |
config() |
protected void |
doBeginRead() |
protected void |
doBind(SocketAddress localAddress) |
protected void |
doClose() |
protected boolean |
doConnect(SocketAddress remoteAddress,
SocketAddress localAddress)
Connect to the remote peer
|
protected boolean |
doConnect0(SocketAddress remoteAddress,
SocketAddress localAddress) |
protected void |
doDeregister() |
protected void |
doDisconnect() |
protected int |
doReadBytes(io.netty.buffer.ByteBuf byteBuf)
Read bytes into the given
ByteBuf and return the amount. |
protected void |
doRegister() |
protected void |
doWrite(io.netty.channel.ChannelOutboundBuffer in) |
protected int |
doWriteBytes(io.netty.channel.ChannelOutboundBuffer in,
io.netty.buffer.ByteBuf buf) |
protected boolean |
doWriteMessage(Object msg) |
io.netty.channel.unix.FileDescriptor |
fd() |
protected Object |
filterOutboundMessage(Object msg) |
boolean |
isActive() |
protected boolean |
isCompatible(io.netty.channel.EventLoop loop) |
boolean |
isConnected() |
boolean |
isOpen() |
io.netty.channel.unix.DomainSocketAddress |
localAddress() |
protected io.netty.channel.unix.DomainSocketAddress |
localAddress0() |
io.netty.channel.ChannelMetadata |
metadata() |
protected io.netty.buffer.ByteBuf |
newDirectBuffer(io.netty.buffer.ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the original one. |
protected io.netty.buffer.ByteBuf |
newDirectBuffer(Object holder,
io.netty.buffer.ByteBuf buf)
Returns an off-heap copy of the specified
ByteBuf , and releases the specified holder. |
protected io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe |
newUnsafe() |
io.netty.channel.unix.PeerCredentials |
peerCredentials()
Returns the unix credentials (uid, gid, pid) of the peer
SO_PEERCRED
|
io.netty.channel.unix.DomainSocketAddress |
remoteAddress() |
protected io.netty.channel.unix.DomainSocketAddress |
remoteAddress0() |
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isOpen, isRegistered, isWritable, metadata, parent, pipeline, read, unsafe
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
compareTo
public KQueueDomainDatagramChannel()
public KQueueDomainDatagramChannel(int fd)
public KQueueDomainDatagramChannelConfig config()
config
in interface io.netty.channel.Channel
config
in interface io.netty.channel.unix.DomainDatagramChannel
protected void doBind(SocketAddress localAddress) throws Exception
Exception
protected boolean doConnect(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
Exception
protected Object filterOutboundMessage(Object msg)
filterOutboundMessage
in class io.netty.channel.AbstractChannel
public boolean isActive()
isActive
in interface io.netty.channel.Channel
public boolean isConnected()
isConnected
in interface io.netty.channel.unix.DomainDatagramChannel
public io.netty.channel.unix.DomainSocketAddress localAddress()
localAddress
in interface io.netty.channel.Channel
localAddress
in interface io.netty.channel.unix.DomainDatagramChannel
localAddress
in class io.netty.channel.AbstractChannel
protected io.netty.channel.unix.DomainSocketAddress localAddress0()
protected io.netty.channel.kqueue.AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()
public io.netty.channel.unix.PeerCredentials peerCredentials() throws IOException
IOException
public io.netty.channel.unix.DomainSocketAddress remoteAddress()
remoteAddress
in interface io.netty.channel.Channel
remoteAddress
in interface io.netty.channel.unix.DomainDatagramChannel
remoteAddress
in class io.netty.channel.AbstractChannel
protected io.netty.channel.unix.DomainSocketAddress remoteAddress0()
public io.netty.channel.ChannelMetadata metadata()
metadata
in interface io.netty.channel.Channel
protected void doWrite(io.netty.channel.ChannelOutboundBuffer in) throws Exception
doWrite
in class io.netty.channel.AbstractChannel
Exception
public final io.netty.channel.unix.FileDescriptor fd()
fd
in interface io.netty.channel.unix.UnixChannel
protected boolean isCompatible(io.netty.channel.EventLoop loop)
isCompatible
in class io.netty.channel.AbstractChannel
public boolean isOpen()
isOpen
in interface io.netty.channel.Channel
protected void doDeregister() throws Exception
doDeregister
in class io.netty.channel.AbstractChannel
Exception
protected final void doBeginRead() throws Exception
doBeginRead
in class io.netty.channel.AbstractChannel
Exception
protected void doRegister() throws Exception
doRegister
in class io.netty.channel.AbstractChannel
Exception
protected final io.netty.buffer.ByteBuf newDirectBuffer(io.netty.buffer.ByteBuf buf)
ByteBuf
, and releases the original one.protected final io.netty.buffer.ByteBuf newDirectBuffer(Object holder, io.netty.buffer.ByteBuf buf)
ByteBuf
, and releases the specified holder.
The caller must ensure that the holder releases the original ByteBuf
when the holder is released by
this method.protected static void checkResolvable(InetSocketAddress addr)
protected final int doReadBytes(io.netty.buffer.ByteBuf byteBuf) throws Exception
ByteBuf
and return the amount.Exception
protected final int doWriteBytes(io.netty.channel.ChannelOutboundBuffer in, io.netty.buffer.ByteBuf buf) throws Exception
Exception
protected boolean doConnect0(SocketAddress remoteAddress, SocketAddress localAddress) throws Exception
Exception
Copyright © 2008–2021 The Netty Project. All rights reserved.