Class AbstractKQueueDatagramChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.kqueue.AbstractKQueueChannel

io.netty.channel.kqueue.AbstractKQueueDatagramChannel

All Implemented Interfaces:

Channel, ChannelOutboundInvoker, UnixChannel, AttributeMap, Comparable<Channel>

Direct Known Subclasses:

KQueueDatagramChannel, KQueueDomainDatagramChannel

abstract class AbstractKQueueDatagramChannel
extends AbstractKQueueChannel

Nested Class Summary

Nested classes/interfaces inherited from class AbstractKQueueChannel

AbstractKQueueChannel.AbstractKQueueUnsafe

Nested classes/interfaces inherited from class AbstractChannel

AbstractChannel.AbstractUnsafe

Nested classes/interfaces inherited from interface Channel

Channel.Unsafe

Field Summary

Fields

Modifier and Type	Field	Description
private static final ChannelMetadata	METADATA

Fields inherited from class AbstractKQueueChannel

active, inputClosedSeenErrorOnRead, readReadyRunnablePending, registration, socket

Constructor Summary

Constructors

Constructor	Description
AbstractKQueueDatagramChannel(Channel parent, BsdSocket fd, boolean active)

Method Summary

Modifier and Type	Method	Description
protected void	doWrite(ChannelOutboundBuffer in)	Flush the content of the given buffer to the remote peer.
protected abstract boolean	doWriteMessage(Object msg)
ChannelMetadata	metadata()	Return the ChannelMetadata of the Channel which describe the nature of the Channel.

Methods inherited from class AbstractKQueueChannel

checkResolvable, clearReadFilter, config, doBeginRead, doBind, doClose, doConnect, doConnect0, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isCompatible, isOpen, isSoErrorZero, localAddress0, newDirectBuffer, newDirectBuffer, newUnsafe, readFilter, remoteAddress0, resetCachedAddresses, shouldBreakReadReady, unregisterFilters, writeFilter

Methods inherited from class AbstractChannel

alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, eventLoop, filterOutboundMessage, 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 DefaultAttributeMap

attr, hasAttr

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface AttributeMap

attr, hasAttr

Methods inherited from interface Channel

alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isRegistered, isWritable, localAddress, parent, pipeline, read, remoteAddress, unsafe

Methods inherited from interface ChannelOutboundInvoker

bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlush

Methods inherited from interface Comparable

compareTo

Field Details

METADATA

private static final ChannelMetadata METADATA

Constructor Details

AbstractKQueueDatagramChannel

AbstractKQueueDatagramChannel(Channel parent,
 BsdSocket fd,
 boolean active)

Method Details

metadata

public ChannelMetadata metadata()

Description copied from interface: Channel

Return the ChannelMetadata of the Channel which describe the nature of the Channel.

Specified by:

metadata in interface Channel

Overrides:

metadata in class AbstractKQueueChannel

doWriteMessage

protected abstract boolean doWriteMessage(Object msg)
                                   throws Exception

Throws:

Exception

doWrite

protected void doWrite(ChannelOutboundBuffer in)
                throws Exception

Description copied from class: AbstractChannel

Flush the content of the given buffer to the remote peer.

Specified by:

doWrite in class AbstractChannel

Throws:

Exception