public final class EpollDomainSocketChannel extends AbstractEpollStreamChannel implements DomainSocketChannel
AbstractEpollStreamChannel.SpliceInTaskAbstractChannel.AbstractUnsafeChannel.Unsafe| Modifier and Type | Field and Description |
|---|---|
protected boolean |
active |
protected int |
flags |
| Constructor and Description |
|---|
EpollDomainSocketChannel() |
EpollDomainSocketChannel(Channel parent, io.netty.channel.epoll.LinuxSocket fd) |
EpollDomainSocketChannel(int fd) |
EpollDomainSocketChannel(int fd, boolean active) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
checkResolvable(java.net.InetSocketAddress addr) |
EpollDomainSocketChannelConfig |
config()
返回此频道的配置。
|
protected void |
doBeginRead()
安排读取操作。
|
protected void |
doBind(java.net.SocketAddress localAddress)
将 Channel绑定到SocketAddress
|
protected boolean |
doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
连接到远程对等
|
protected void |
doDeregister()
|
protected void |
doDisconnect()
将此 Channel从其远程对等方断开
|
protected int |
doReadBytes(ByteBuf byteBuf)
将字节读入给定的 ByteBuf并返回金额。
|
protected void |
doRegister()
|
protected int |
doWriteBytes(ChannelOutboundBuffer in, ByteBuf buf) |
protected int |
doWriteSingle(ChannelOutboundBuffer in)
尝试编写单个对象。
|
FileDescriptor |
fd()
返回 Channel使用的FileDescriptor 。
|
protected java.lang.Object |
filterOutboundMessage(java.lang.Object msg)
当新消息添加到此 AbstractChannel的ChannelOutboundBuffer中时调用 ,以便Channel实现将消息转换为另一个消息。
|
boolean |
isActive()
如果 Channel处于活动状态并已连接,则返回true 。
|
protected boolean |
isCompatible(EventLoop loop)
如果给定 EventLoop与此实例兼容,则返回true 。
|
boolean |
isOpen()
如果 Channel已打开并且稍后可能会激活,则返回true
|
DomainSocketAddress |
localAddress()
返回此通道绑定的本地地址。
|
protected DomainSocketAddress |
localAddress0()
返回本地绑定的
SocketAddress 。
|
protected ByteBuf |
newDirectBuffer(ByteBuf buf)
返回指定 ByteBuf的堆外副本,并释放原始副本。
|
protected ByteBuf |
newDirectBuffer(java.lang.Object holder, ByteBuf buf)
返回指定 ByteBuf的堆外副本,并释放指定的持有者。
|
protected io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe |
newUnsafe()
创建一个新的 AbstractChannel.AbstractUnsafe实例,该实例将用于Channel的生命周期
|
PeerCredentials |
peerCredentials()
返回对等
SO_PEERCRED的unix凭据(uid,gid,pid)
|
DomainSocketAddress |
remoteAddress()
返回此通道连接到的远程地址。
|
protected DomainSocketAddress |
remoteAddress0()
返回 SocketAddress其中Channel被连接到。
|
doClose, doShutdownOutput, doWrite, isInputShutdown, isOutputShutdown, isShutdown, metadata, shutdown, shutdown, shutdownInput, shutdownInput, shutdownOutput, shutdownOutput, spliceTo, spliceTo, spliceTo, spliceToalloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, equals, eventLoop, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, unsafe, voidPromise, write, write, writeAndFlush, writeAndFlushattr, hasAttrclone, finalize, getClass, notify, notifyAll, wait, wait, waitfdisInputShutdown, isOutputShutdown, isShutdown, shutdown, shutdown, shutdownInput, shutdownInput, shutdownOutput, shutdownOutputalloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, metadata, parent, pipeline, read, unsafeattr, hasAttrbind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlushpublic EpollDomainSocketChannel()
public EpollDomainSocketChannel(int fd)
public EpollDomainSocketChannel(Channel parent, io.netty.channel.epoll.LinuxSocket fd)
public EpollDomainSocketChannel(int fd,
boolean active) protected io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe newUnsafe()
AbstractChannel
AbstractChannel.AbstractUnsafe实例,该实例将用于Channel的生命周期
protected DomainSocketAddress localAddress0()
AbstractChannel
SocketAddress 。
protected DomainSocketAddress remoteAddress0()
AbstractChannel
SocketAddress其中Channel被连接到。
protected void doBind(java.net.SocketAddress localAddress)
throws java.lang.Exception
AbstractChannel
Channel绑定到SocketAddress
java.lang.Exception
public EpollDomainSocketChannelConfig config()
Channel复制的描述
config接口
Channel
config接口
DomainSocketChannel
protected boolean doConnect(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
throws java.lang.Exception
java.lang.Exception
public DomainSocketAddress remoteAddress()
Channel复制的描述
SocketAddress被假定为更具体的类型,如InetSocketAddress以检索详细信息。
remoteAddress接口
Channel
remoteAddress接口
DomainSocketChannel
remoteAddress在课堂
AbstractChannel
null如果此通道未连接。
如果此通道未连接,但它可以接收来自任意远程地址的消息(例如DatagramChannel ,请使用DefaultAddressedEnvelope.recipient()来确定收到消息的来源,因为此方法将返回null 。
public DomainSocketAddress localAddress()
Channel复制的描述
SocketAddress应该被下调为更具体的类型,例如InetSocketAddress以检索详细信息。
localAddress接口
Channel
localAddress接口
DomainSocketChannel
localAddress在课堂
AbstractChannel
null如果此通道未绑定。
protected int doWriteSingle(ChannelOutboundBuffer in) throws java.lang.Exception
AbstractEpollStreamChannel
doWriteSingle在课堂
AbstractEpollStreamChannel
in - 包含要写入对象的集合。
ChannelConfig.getWriteSpinCount() 。
典型的用例如下:
ByteBuf (或其他空的内容),这是合适的 ChannelUtils.WRITE_STATUS_SNDBUF_FULL - 如果尝试向操作系统写入数据,但未接受任何数据 java.lang.Exception - 如果发生I / O错误。
protected java.lang.Object filterOutboundMessage(java.lang.Object msg)
AbstractChannel
AbstractChannel的ChannelOutboundBuffer时调用 ,以便Channel实现将消息转换为另一个消息。
(例如堆缓冲区 - >直接缓冲区)
@UnstableApi public PeerCredentials peerCredentials() throws java.io.IOException
java.io.IOException
public final FileDescriptor fd()
UnixChannel
Channel使用的FileDescriptor 。
fd在界面
UnixChannel
protected void doDisconnect()
throws java.lang.Exception
AbstractChannel
Channel从其远程对等方断开
doDisconnect在班级
AbstractChannel
java.lang.Exception
protected boolean isCompatible(EventLoop loop)
AbstractChannel
EventLoop与此实例兼容,则返回true 。
isCompatible在课堂上
AbstractChannel
protected void doDeregister()
throws java.lang.Exception
AbstractChannel
doDeregister在课堂
AbstractChannel
java.lang.Exception
protected final void doBeginRead()
throws java.lang.Exception
AbstractChannel
doBeginRead在课堂
AbstractChannel
java.lang.Exception
protected void doRegister()
throws java.lang.Exception
AbstractChannel
doRegister在课堂
AbstractChannel
java.lang.Exception
protected static void checkResolvable(java.net.InetSocketAddress addr)
protected final int doReadBytes(ByteBuf byteBuf) throws java.lang.Exception
ByteBuf并返回金额。
java.lang.Exception
protected final int doWriteBytes(ChannelOutboundBuffer in, ByteBuf buf) throws java.lang.Exception
java.lang.Exception
Copyright © 2008–2018 The Netty Project. All rights reserved.