Package io.netty.channel.kqueue
Class AbstractKQueueServerChannel
- java.lang.Object
-
- io.netty.util.DefaultAttributeMap
-
- io.netty.channel.AbstractChannel
-
- io.netty.channel.kqueue.AbstractKQueueChannel
-
- io.netty.channel.kqueue.AbstractKQueueServerChannel
-
- All Implemented Interfaces:
Channel
,ChannelOutboundInvoker
,ServerChannel
,UnixChannel
,AttributeMap
,java.lang.Comparable<Channel>
- Direct Known Subclasses:
KQueueServerDomainSocketChannel
,KQueueServerSocketChannel
@UnstableApi public abstract class AbstractKQueueServerChannel extends AbstractKQueueChannel implements ServerChannel
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) class
AbstractKQueueServerChannel.KQueueServerSocketUnsafe
-
Nested classes/interfaces inherited from class io.netty.channel.kqueue.AbstractKQueueChannel
AbstractKQueueChannel.AbstractKQueueUnsafe
-
Nested classes/interfaces inherited from class io.netty.channel.AbstractChannel
AbstractChannel.AbstractUnsafe
-
Nested classes/interfaces inherited from interface io.netty.channel.Channel
Channel.Unsafe
-
-
Field Summary
Fields Modifier and Type Field Description private static ChannelMetadata
METADATA
-
Fields inherited from class io.netty.channel.kqueue.AbstractKQueueChannel
active, inputClosedSeenErrorOnRead, readReadyRunnablePending, socket
-
-
Constructor Summary
Constructors Constructor Description AbstractKQueueServerChannel(BsdSocket fd)
AbstractKQueueServerChannel(BsdSocket fd, boolean active)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected boolean
doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress)
Connect to the remote peerprotected void
doWrite(ChannelOutboundBuffer in)
Flush the content of the given buffer to the remote peer.protected java.lang.Object
filterOutboundMessage(java.lang.Object msg)
Invoked when a new message is added to aChannelOutboundBuffer
of thisAbstractChannel
, so that theChannel
implementation converts the message to another.protected boolean
isCompatible(EventLoop loop)
Returntrue
if the givenEventLoop
is compatible with this instance.ChannelMetadata
metadata()
(package private) abstract Channel
newChildChannel(int fd, byte[] remote, int offset, int len)
protected AbstractKQueueChannel.AbstractKQueueUnsafe
newUnsafe()
Create a newAbstractChannel.AbstractUnsafe
instance which will be used for the life-time of theChannel
protected java.net.InetSocketAddress
remoteAddress0()
Return theSocketAddress
which theChannel
is connected to.-
Methods inherited from class io.netty.channel.kqueue.AbstractKQueueChannel
checkResolvable, clearReadFilter, config, doBeginRead, doBind, doClose, doConnect0, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isOpen, isSoErrorZero, localAddress0, newDirectBuffer, newDirectBuffer, readFilter, resetCachedAddresses, shouldBreakReadReady, unregisterFilters, writeFilter
-
Methods inherited from class io.netty.channel.AbstractChannel
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, localAddress, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, remoteAddress, toString, unsafe, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlush
-
Methods inherited from class io.netty.util.DefaultAttributeMap
attr, hasAttr
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface io.netty.util.AttributeMap
attr, hasAttr
-
Methods inherited from interface io.netty.channel.Channel
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, config, eventLoop, flush, id, isActive, isOpen, isRegistered, isWritable, localAddress, parent, pipeline, read, remoteAddress, unsafe
-
Methods inherited from interface io.netty.channel.ChannelOutboundInvoker
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush
-
-
-
-
Field Detail
-
METADATA
private static final ChannelMetadata METADATA
-
-
Method Detail
-
metadata
public ChannelMetadata metadata()
Description copied from interface:Channel
- Specified by:
metadata
in interfaceChannel
- Overrides:
metadata
in classAbstractKQueueChannel
-
isCompatible
protected boolean isCompatible(EventLoop loop)
Description copied from class:AbstractChannel
Returntrue
if the givenEventLoop
is compatible with this instance.- Overrides:
isCompatible
in classAbstractKQueueChannel
-
remoteAddress0
protected java.net.InetSocketAddress remoteAddress0()
Description copied from class:AbstractChannel
Return theSocketAddress
which theChannel
is connected to.- Overrides:
remoteAddress0
in classAbstractKQueueChannel
-
newUnsafe
protected AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()
Description copied from class:AbstractChannel
Create a newAbstractChannel.AbstractUnsafe
instance which will be used for the life-time of theChannel
- Specified by:
newUnsafe
in classAbstractKQueueChannel
-
doWrite
protected void doWrite(ChannelOutboundBuffer in) throws java.lang.Exception
Description copied from class:AbstractChannel
Flush the content of the given buffer to the remote peer.- Specified by:
doWrite
in classAbstractChannel
- Throws:
java.lang.Exception
-
filterOutboundMessage
protected java.lang.Object filterOutboundMessage(java.lang.Object msg) throws java.lang.Exception
Description copied from class:AbstractChannel
Invoked when a new message is added to aChannelOutboundBuffer
of thisAbstractChannel
, so that theChannel
implementation converts the message to another. (e.g. heap buffer -> direct buffer)- Overrides:
filterOutboundMessage
in classAbstractChannel
- Throws:
java.lang.Exception
-
newChildChannel
abstract Channel newChildChannel(int fd, byte[] remote, int offset, int len) throws java.lang.Exception
- Throws:
java.lang.Exception
-
doConnect
protected boolean doConnect(java.net.SocketAddress remoteAddress, java.net.SocketAddress localAddress) throws java.lang.Exception
Description copied from class:AbstractKQueueChannel
Connect to the remote peer- Overrides:
doConnect
in classAbstractKQueueChannel
- Throws:
java.lang.Exception
-
-