Package io.netty.channel.kqueue

Class AbstractKQueueStreamChannel

java.lang.Object

io.netty.util.DefaultAttributeMap

io.netty.channel.AbstractChannel

io.netty.channel.kqueue.AbstractKQueueChannel

io.netty.channel.kqueue.AbstractKQueueStreamChannel

All Implemented Interfaces:

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

Direct Known Subclasses:

KQueueDomainSocketChannel, KQueueSocketChannel

public abstract class AbstractKQueueStreamChannel
extends AbstractKQueueChannel
implements DuplexChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private final class	AbstractKQueueStreamChannel.KQueueSocketWritableByteChannel
(package private) class	AbstractKQueueStreamChannel.KQueueStreamUnsafe

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 WritableByteChannel	byteChannel
private static final String	EXPECTED_TYPES
private final Runnable	flushTask
private static final InternalLogger	logger
private static final ChannelMetadata	METADATA

Fields inherited from class io.netty.channel.kqueue.AbstractKQueueChannel

active, inputClosedSeenErrorOnRead, readReadyRunnablePending, registration, socket

Constructor Summary

Constructors

Constructor	Description
AbstractKQueueStreamChannel(Channel parent, BsdSocket fd, boolean active)
AbstractKQueueStreamChannel(Channel parent, BsdSocket fd, SocketAddress remote)
AbstractKQueueStreamChannel(BsdSocket fd)

Method Summary

Modifier and Type	Method	Description
private void	adjustMaxBytesPerGatheringWrite(long attempted, long written, long oldMaxBytesPerGatheringWrite)
protected final void	doShutdownOutput()	Called when conditions justify shutting down the output portion of the channel.
protected void	doWrite(ChannelOutboundBuffer in)	Flush the content of the given buffer to the remote peer.
private int	doWriteMultiple(ChannelOutboundBuffer in)	Attempt to write multiple ByteBuf objects.
protected int	doWriteSingle(ChannelOutboundBuffer in)	Attempt to write a single object.
protected Object	filterOutboundMessage(Object msg)	Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another.
boolean	isInputShutdown()	Returns true if and only if the remote peer shut down its output so that no more data is received from this channel.
boolean	isOutputShutdown()
boolean	isShutdown()	Determine if both the input and output of this channel have been shutdown.
ChannelMetadata	metadata()	Return the ChannelMetadata of the Channel which describe the nature of the Channel.
protected AbstractKQueueChannel.AbstractKQueueUnsafe	newUnsafe()	Create a new AbstractChannel.AbstractUnsafe instance which will be used for the life-time of the Channel
ChannelFuture	shutdown()	Will shutdown the input and output sides of this channel.
ChannelFuture	shutdown(ChannelPromise promise)	Will shutdown the input and output sides of this channel.
private static void	shutdownDone(ChannelFuture shutdownOutputFuture, ChannelFuture shutdownInputFuture, ChannelPromise promise)
ChannelFuture	shutdownInput()
ChannelFuture	shutdownInput(ChannelPromise promise)	Will shutdown the input and notify ChannelPromise.
private void	shutdownInput0(ChannelPromise promise)
ChannelFuture	shutdownOutput()
ChannelFuture	shutdownOutput(ChannelPromise promise)	Will shutdown the output and notify ChannelPromise.
private void	shutdownOutputDone(ChannelFuture shutdownOutputFuture, ChannelPromise promise)
private int	writeBytes(ChannelOutboundBuffer in, ByteBuf buf)	Write bytes form the given ByteBuf to the underlying Channel.
private int	writeBytesMultiple(ChannelOutboundBuffer in, IovArray array)	Write multiple bytes via IovArray.
private int	writeBytesMultiple(ChannelOutboundBuffer in, ByteBuffer[] nioBuffers, int nioBufferCnt, long expectedWrittenBytes, long maxBytesPerGatheringWrite)	Write multiple bytes via ByteBuffer array.
private int	writeDefaultFileRegion(ChannelOutboundBuffer in, DefaultFileRegion region)	Write a DefaultFileRegion
private int	writeFileRegion(ChannelOutboundBuffer in, FileRegion region)	Write a FileRegion

Methods inherited from class io.netty.channel.kqueue.AbstractKQueueChannel

checkResolvable, clearReadFilter, config, doBeginRead, doBind, doClose, doConnect, doConnect0, doDeregister, doDisconnect, doReadBytes, doRegister, doWriteBytes, fd, isActive, isCompatible, isOpen, isSoErrorZero, localAddress0, newDirectBuffer, newDirectBuffer, readFilter, remoteAddress0, 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, 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

Methods inherited from interface java.lang.Comparable

compareTo

Field Details

logger

private static final InternalLogger logger

METADATA

private static final ChannelMetadata METADATA

EXPECTED_TYPES

private static final String EXPECTED_TYPES

byteChannel

private WritableByteChannel byteChannel

flushTask

private final Runnable flushTask

Constructor Details

AbstractKQueueStreamChannel

AbstractKQueueStreamChannel(Channel parent,
 BsdSocket fd,
 boolean active)

AbstractKQueueStreamChannel

AbstractKQueueStreamChannel(Channel parent,
 BsdSocket fd,
 SocketAddress remote)

AbstractKQueueStreamChannel

AbstractKQueueStreamChannel(BsdSocket fd)

Method Details

newUnsafe

protected AbstractKQueueChannel.AbstractKQueueUnsafe newUnsafe()

Description copied from class: AbstractChannel

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

Specified by:

newUnsafe in class AbstractKQueueChannel

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

writeBytes

private int writeBytes(ChannelOutboundBuffer in,
 ByteBuf buf)
                throws Exception

Write bytes form the given ByteBuf to the underlying Channel.

Parameters:

in - the collection which contains objects to write.

buf - the ByteBuf from which the bytes should be written

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

Throws:

Exception

adjustMaxBytesPerGatheringWrite

private void adjustMaxBytesPerGatheringWrite(long attempted,
 long written,
 long oldMaxBytesPerGatheringWrite)

writeBytesMultiple

private int writeBytesMultiple(ChannelOutboundBuffer in,
 IovArray array)
                        throws IOException

Write multiple bytes via IovArray.

Parameters:

in - the collection which contains objects to write.

array - The array which contains the content to write.

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

Throws:

IOException - If an I/O exception occurs during write.

writeBytesMultiple

private int writeBytesMultiple(ChannelOutboundBuffer in,
 ByteBuffer[] nioBuffers,
 int nioBufferCnt,
 long expectedWrittenBytes,
 long maxBytesPerGatheringWrite)
                        throws IOException

Write multiple bytes via ByteBuffer array.

Parameters:

in - the collection which contains objects to write.

nioBuffers - The buffers to write.

nioBufferCnt - The number of buffers to write.

expectedWrittenBytes - The number of bytes we expect to write.

maxBytesPerGatheringWrite - The maximum number of bytes we should attempt to write.

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

Throws:

IOException - If an I/O exception occurs during write.

writeDefaultFileRegion

private int writeDefaultFileRegion(ChannelOutboundBuffer in,
 DefaultFileRegion region)
                            throws Exception

Write a DefaultFileRegion

Parameters:

in - the collection which contains objects to write.

region - the DefaultFileRegion from which the bytes should be written

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

Throws:

Exception

writeFileRegion

private int writeFileRegion(ChannelOutboundBuffer in,
 FileRegion region)
                     throws Exception

Write a FileRegion

Parameters:

in - the collection which contains objects to write.

region - the FileRegion from which the bytes should be written

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

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

doWriteSingle

protected int doWriteSingle(ChannelOutboundBuffer in)
                     throws Exception

Attempt to write a single object.

Parameters:

in - the collection which contains objects to write.

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

Throws:

Exception - If an I/O error occurs.

doWriteMultiple

private int doWriteMultiple(ChannelOutboundBuffer in)
                     throws Exception

Attempt to write multiple ByteBuf objects.

Parameters:

in - the collection which contains objects to write.

Returns:

The value that should be decremented from the write quantum which starts at ChannelConfig.getWriteSpinCount(). The typical use cases are as follows:

• 0 - if no write was attempted. This is appropriate if an empty ByteBuf (or other empty content) is encountered
• 1 - if a single call to write data was made to the OS
• ChannelUtils.WRITE_STATUS_SNDBUF_FULL - if an attempt to write data was made to the OS, but no data was accepted

Throws:

Exception - If an I/O error occurs.

filterOutboundMessage

protected Object filterOutboundMessage(Object msg)

Description copied from class: AbstractChannel

Invoked when a new message is added to a ChannelOutboundBuffer of this AbstractChannel, so that the Channel implementation converts the message to another. (e.g. heap buffer -> direct buffer)

Overrides:

filterOutboundMessage in class AbstractChannel

doShutdownOutput

@UnstableApi
protected final void doShutdownOutput()
                               throws Exception

Description copied from class: AbstractChannel

Called when conditions justify shutting down the output portion of the channel. This may happen if a write operation throws an exception.

Overrides:

doShutdownOutput in class AbstractChannel

Throws:

Exception

isOutputShutdown

public boolean isOutputShutdown()

Specified by:

isOutputShutdown in interface DuplexChannel

See Also:

• Socket.isOutputShutdown()

isInputShutdown

public boolean isInputShutdown()

Description copied from interface: DuplexChannel

Returns true if and only if the remote peer shut down its output so that no more data is received from this channel. Note that the semantic of this method is different from that of Socket.shutdownInput() and Socket.isInputShutdown().

Specified by:

isInputShutdown in interface DuplexChannel

isShutdown

public boolean isShutdown()

Description copied from interface: DuplexChannel

Determine if both the input and output of this channel have been shutdown.

Specified by:

isShutdown in interface DuplexChannel

shutdownOutput

public ChannelFuture shutdownOutput()

Specified by:

shutdownOutput in interface DuplexChannel

See Also:

• Socket.shutdownOutput()

shutdownOutput

public ChannelFuture shutdownOutput(ChannelPromise promise)

Description copied from interface: DuplexChannel

Will shutdown the output and notify ChannelPromise.

Specified by:

shutdownOutput in interface DuplexChannel

See Also:

• Socket.shutdownOutput()

shutdownInput

public ChannelFuture shutdownInput()

Specified by:

shutdownInput in interface DuplexChannel

See Also:

• Socket.shutdownInput()

shutdownInput

public ChannelFuture shutdownInput(ChannelPromise promise)

Description copied from interface: DuplexChannel

Will shutdown the input and notify ChannelPromise.

Specified by:

shutdownInput in interface DuplexChannel

See Also:

• Socket.shutdownInput()

shutdownInput0

private void shutdownInput0(ChannelPromise promise)

shutdown

public ChannelFuture shutdown()

Description copied from interface: DuplexChannel

Will shutdown the input and output sides of this channel.

Specified by:

shutdown in interface DuplexChannel

Returns:

will be completed when both shutdown operations complete.

shutdown

public ChannelFuture shutdown(ChannelPromise promise)

Description copied from interface: DuplexChannel

Will shutdown the input and output sides of this channel.

Specified by:

shutdown in interface DuplexChannel

Parameters:

promise - will be completed when both shutdown operations complete.

Returns:

will be completed when both shutdown operations complete.

shutdownOutputDone

private void shutdownOutputDone(ChannelFuture shutdownOutputFuture,
 ChannelPromise promise)

shutdownDone

private static void shutdownDone(ChannelFuture shutdownOutputFuture,
 ChannelFuture shutdownInputFuture,
 ChannelPromise promise)