Top Fields Constructors Methods
io.netty.channel.kqueue

public Class KQueueServerChannelConfig

extends KQueueChannelConfig
implements ServerSocketChannelConfig
Class Inheritance
All Implemented Interfaces
io.netty.channel.socket.ServerSocketChannelConfig, io.netty.channel.ChannelConfig
Known Direct Subclasses
io.netty.channel.kqueue.KQueueServerSocketChannelConfig
Annotations
@UnstableApi
Imports
io.netty.buffer.ByteBufAllocator, io.netty.channel.ChannelException, .ChannelOption, .MessageSizeEstimator, .RecvByteBufAllocator, .ServerChannelRecvByteBufAllocator, .WriteBufferWaterMark, io.netty.channel.socket.ServerSocketChannelConfig, io.netty.util.NetUtil, io.netty.util.internal.UnstableApi, java.io.IOException, java.util.Map

Field Summary

Modifier and TypeField and Description
private volatile int
private volatile boolean

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Modifier and TypeMethod and Description
public int
getBacklog()

Implements io.netty.channel.socket.ServerSocketChannelConfig.getBacklog.

Gets the backlog value to specify when the channel binds to a local address.
public <T> T
public Map<ChannelOption<?>, Object>
public int
public boolean
public boolean
isTcpFastOpen()

Returns true if TCP FastOpen is enabled.

public KQueueServerChannelConfig
public KQueueServerChannelConfig
setAutoRead(boolean autoRead)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setAutoRead.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setAutoRead, io.netty.channel.ChannelConfig.setAutoRead.

Sets if ChannelHandlerContext#read() will be invoked automatically so that a user application doesn't need to call it at all.
public KQueueServerChannelConfig
setBacklog(int backlog)

Implements io.netty.channel.socket.ServerSocketChannelConfig.setBacklog.

Sets the backlog value to specify when the channel binds to a local address.
public KQueueServerChannelConfig
setConnectTimeoutMillis(int
the connect timeout in milliseconds. 0 to disable.
connectTimeoutMillis
)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setConnectTimeoutMillis.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setConnectTimeoutMillis, io.netty.channel.ChannelConfig.setConnectTimeoutMillis.

Sets the connect timeout of the channel in milliseconds.
public KQueueServerChannelConfig
public KQueueServerChannelConfig
public <T> boolean
setOption(ChannelOption<T> option, T value)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setOption.

Implements io.netty.channel.ChannelConfig.setOption.

Sets a configuration property with the specified name and value.
public KQueueServerChannelConfig
setPerformancePreferences(int connectionTime, int latency, int bandwidth)

Implements io.netty.channel.socket.ServerSocketChannelConfig.setPerformancePreferences.

Sets the performance preferences as specified in ServerSocket#setPerformancePreferences(int, int, int).
public KQueueServerChannelConfig
setRcvAllocTransportProvidesGuess(boolean transportProvidesGuess)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setRcvAllocTransportProvidesGuess.

If this is true then the RecvByteBufAllocator.Handle#guess() will be overridden to always attempt to read as many bytes as kqueue says are available.
public KQueueServerChannelConfig
public KQueueServerChannelConfig
public KQueueServerChannelConfig
public KQueueServerChannelConfig
setTcpFastOpen(boolean
true if TCP FastOpen should be enabled for incomming connections.
enableTcpFastOpen
)

Enables TCP FastOpen on the server channel.

public KQueueServerChannelConfig
public KQueueServerChannelConfig
public KQueueServerChannelConfig
public KQueueServerChannelConfig
Inherited from io.netty.channel.kqueue.KQueueChannelConfig:
autoReadClearedgetMaxBytesPerGatheringWritegetRcvAllocTransportProvidesGuesssetMaxBytesPerGatheringWrite

Field Detail

backlogback to summary
private volatile int backlog
enableTcpFastOpenback to summary
private volatile boolean enableTcpFastOpen

Constructor Detail

KQueueServerChannelConfigback to summary
pack-priv KQueueServerChannelConfig(AbstractKQueueChannel channel)

Method Detail

getBacklogback to summary
public int getBacklog()

Implements io.netty.channel.socket.ServerSocketChannelConfig.getBacklog.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.getBacklog.

Gets the backlog value to specify when the channel binds to a local address.

Annotations
@Override
getOptionback to summary
public <T> T getOption(ChannelOption<T> option)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.getOption.

Implements io.netty.channel.ChannelConfig.getOption.

Doc from io.netty.channel.ChannelConfig.getOption.

Return the value of the given ChannelOption

Annotations
@SuppressWarnings:unchecked
@Override
getOptionsback to summary
public Map<ChannelOption<?>, Object> getOptions()

Overrides io.netty.channel.kqueue.KQueueChannelConfig.getOptions.

Implements io.netty.channel.ChannelConfig.getOptions.

Doc from io.netty.channel.ChannelConfig.getOptions.

Return all set ChannelOption's.

Annotations
@Override
getReceiveBufferSizeback to summary
public int getReceiveBufferSize()

Implements io.netty.channel.socket.ServerSocketChannelConfig.getReceiveBufferSize.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.getReceiveBufferSize.

Gets the StandardSocketOptions#SO_RCVBUF option.

Annotations
@Override
isReuseAddressback to summary
public boolean isReuseAddress()

Implements io.netty.channel.socket.ServerSocketChannelConfig.isReuseAddress.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.isReuseAddress.

Gets the StandardSocketOptions#SO_REUSEADDR option.

Annotations
@Override
isTcpFastOpenback to summary
public boolean isTcpFastOpen()

Returns true if TCP FastOpen is enabled.

See Also
RFC 7413 Passive Open
setAllocatorback to summary
public KQueueServerChannelConfig setAllocator(ByteBufAllocator allocator)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setAllocator.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setAllocator, io.netty.channel.ChannelConfig.setAllocator.

Doc from io.netty.channel.ChannelConfig.setAllocator.

Set the ByteBufAllocator which is used for the channel to allocate buffers.

Annotations
@Override
setAutoReadback to summary
public KQueueServerChannelConfig setAutoRead(boolean autoRead)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setAutoRead.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setAutoRead, io.netty.channel.ChannelConfig.setAutoRead.

Doc from io.netty.channel.ChannelConfig.setAutoRead.

Sets if ChannelHandlerContext#read() will be invoked automatically so that a user application doesn't need to call it at all. The default value is true.

Annotations
@Override
setBacklogback to summary
public KQueueServerChannelConfig setBacklog(int backlog)

Implements io.netty.channel.socket.ServerSocketChannelConfig.setBacklog.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.setBacklog.

Sets the backlog value to specify when the channel binds to a local address.

Annotations
@Override
setConnectTimeoutMillisback to summary
public KQueueServerChannelConfig setConnectTimeoutMillis(int connectTimeoutMillis)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setConnectTimeoutMillis.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setConnectTimeoutMillis, io.netty.channel.ChannelConfig.setConnectTimeoutMillis.

Doc from io.netty.channel.ChannelConfig.setConnectTimeoutMillis.

Sets the connect timeout of the channel in milliseconds. If the Channel does not support connect operation, this property is not used at all, and therefore will be ignored.

Parameters
connectTimeoutMillis:int

the connect timeout in milliseconds. 0 to disable.

Annotations
@Override
setMaxMessagesPerReadback to summary
public KQueueServerChannelConfig setMaxMessagesPerRead(int maxMessagesPerRead)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setMaxMessagesPerRead.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setMaxMessagesPerRead, io.netty.channel.ChannelConfig.setMaxMessagesPerRead.

Doc from io.netty.channel.DefaultChannelConfig.setMaxMessagesPerRead.

Deprecated

Annotations
@Override
@Deprecated
setMessageSizeEstimatorback to summary
public KQueueServerChannelConfig setMessageSizeEstimator(MessageSizeEstimator estimator)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setMessageSizeEstimator.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setMessageSizeEstimator, io.netty.channel.ChannelConfig.setMessageSizeEstimator.

Doc from io.netty.channel.ChannelConfig.setMessageSizeEstimator.

Set the MessageSizeEstimator which is used for the channel to detect the size of a message.

Annotations
@Override
setOptionback to summary
public <T> boolean setOption(ChannelOption<T> option, T value)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setOption.

Implements io.netty.channel.ChannelConfig.setOption.

Doc from io.netty.channel.ChannelConfig.setOption.

Sets a configuration property with the specified name and value. To override this method properly, you must call the super class:

public boolean setOption(ChannelOption<T> option, T value) {
    if (super.setOption(option, value)) {
        return true;
    }

    if (option.equals(additionalOption)) {
        ....
        return true;
    }

    return false;
}
Returns:boolean

true if and only if the property has been set

Annotations
@Override
setPerformancePreferencesback to summary
public KQueueServerChannelConfig setPerformancePreferences(int connectionTime, int latency, int bandwidth)

Implements io.netty.channel.socket.ServerSocketChannelConfig.setPerformancePreferences.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.setPerformancePreferences.

Sets the performance preferences as specified in ServerSocket#setPerformancePreferences(int, int, int).

Annotations
@Override
setRcvAllocTransportProvidesGuessback to summary
public KQueueServerChannelConfig setRcvAllocTransportProvidesGuess(boolean transportProvidesGuess)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setRcvAllocTransportProvidesGuess.

Doc from io.netty.channel.kqueue.KQueueChannelConfig.setRcvAllocTransportProvidesGuess.

If this is true then the RecvByteBufAllocator.Handle#guess() will be overridden to always attempt to read as many bytes as kqueue says are available.

Annotations
@Override
setReceiveBufferSizeback to summary
public KQueueServerChannelConfig setReceiveBufferSize(int receiveBufferSize)

Implements io.netty.channel.socket.ServerSocketChannelConfig.setReceiveBufferSize.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.setReceiveBufferSize.

Gets the StandardSocketOptions#SO_SNDBUF option.

Annotations
@Override
setRecvByteBufAllocatorback to summary
public KQueueServerChannelConfig setRecvByteBufAllocator(RecvByteBufAllocator allocator)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setRecvByteBufAllocator.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setRecvByteBufAllocator, io.netty.channel.ChannelConfig.setRecvByteBufAllocator.

Doc from io.netty.channel.ChannelConfig.setRecvByteBufAllocator.

Set the RecvByteBufAllocator which is used for the channel to allocate receive buffers.

Annotations
@Override
setReuseAddressback to summary
public KQueueServerChannelConfig setReuseAddress(boolean reuseAddress)

Implements io.netty.channel.socket.ServerSocketChannelConfig.setReuseAddress.

Doc from io.netty.channel.socket.ServerSocketChannelConfig.setReuseAddress.

Sets the StandardSocketOptions#SO_REUSEADDR option.

Annotations
@Override
setTcpFastOpenback to summary
public KQueueServerChannelConfig setTcpFastOpen(boolean enableTcpFastOpen)

Enables TCP FastOpen on the server channel. If the underlying os doesn't support TCP_FASTOPEN setting this has no effect. This has to be set before doing listen on the socket otherwise this takes no effect.

Parameters
enableTcpFastOpen:boolean

true if TCP FastOpen should be enabled for incomming connections.

See Also
RFC 7413 Passive Open
setWriteBufferHighWaterMarkback to summary
public KQueueServerChannelConfig setWriteBufferHighWaterMark(int writeBufferHighWaterMark)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setWriteBufferHighWaterMark.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setWriteBufferHighWaterMark, io.netty.channel.ChannelConfig.setWriteBufferHighWaterMark.

Doc from io.netty.channel.ChannelConfig.setWriteBufferHighWaterMark.

Deprecated

Sets the high water mark of the write buffer. If the number of bytes queued in the write buffer exceeds this value, Channel#isWritable() will start to return false.

Annotations
@Override
@Deprecated
setWriteBufferLowWaterMarkback to summary
public KQueueServerChannelConfig setWriteBufferLowWaterMark(int writeBufferLowWaterMark)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setWriteBufferLowWaterMark.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setWriteBufferLowWaterMark, io.netty.channel.ChannelConfig.setWriteBufferLowWaterMark.

Doc from io.netty.channel.ChannelConfig.setWriteBufferLowWaterMark.

Deprecated

Sets the low water mark of the write buffer. Once the number of bytes queued in the write buffer exceeded the high water mark and then dropped down below this value, Channel#isWritable() will start to return true again.

Annotations
@Override
@Deprecated
setWriteBufferWaterMarkback to summary
public KQueueServerChannelConfig setWriteBufferWaterMark(WriteBufferWaterMark writeBufferWaterMark)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setWriteBufferWaterMark.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setWriteBufferWaterMark, io.netty.channel.ChannelConfig.setWriteBufferWaterMark.

Doc from io.netty.channel.ChannelConfig.setWriteBufferWaterMark.

Set the WriteBufferWaterMark which is used for setting the high and low water mark of the write buffer.

Annotations
@Override
setWriteSpinCountback to summary
public KQueueServerChannelConfig setWriteSpinCount(int writeSpinCount)

Overrides io.netty.channel.kqueue.KQueueChannelConfig.setWriteSpinCount.

Implements io.netty.channel.socket.ServerSocketChannelConfig.setWriteSpinCount, io.netty.channel.ChannelConfig.setWriteSpinCount.

Doc from io.netty.channel.ChannelConfig.setWriteSpinCount.

Sets the maximum loop count for a write operation until WritableByteChannel#write(ByteBuffer) returns a non-zero value. It is similar to what a spin lock is used for in concurrency programming. It improves memory utilization and write throughput depending on the platform that JVM runs on. The default value is 16.

Annotations
@Override