alluxio.util.network

Class NettyUtils

java.lang.Object

alluxio.util.network.NettyUtils

@ThreadSafe
public final class NettyUtils
extends Object

Utility methods for working with Netty.

Field Summary

Fields

Modifier and Type	Field and Description
static ChannelType	USER_CHANNEL_TYPE
static ChannelType	WORKER_CHANNEL_TYPE

Method Summary

Modifier and Type	Method and Description
static io.netty.channel.EventLoopGroup	createEventLoop(ChannelType type, int numThreads, String threadPrefix, boolean isDaemon) Creates a Netty EventLoopGroup based on ChannelType.
static void	disableAutoRead(io.netty.channel.Channel channel) Disables auto read for a netty channel.
static void	enableAutoRead(io.netty.channel.Channel channel) Enables auto read for a netty channel.
static Class<? extends io.netty.channel.Channel>	getClientChannelClass(boolean isDomainSocket) Returns the correct SocketChannel class for use by the client.
static Class<? extends io.netty.channel.ServerChannel>	getServerChannelClass(boolean isDomainSocket) Returns the correct ServerSocketChannel class for use by the worker.
static boolean	isDomainSocketSupported(WorkerNetAddress workerNetAddress)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

USER_CHANNEL_TYPE

public static final ChannelType USER_CHANNEL_TYPE

WORKER_CHANNEL_TYPE

public static final ChannelType WORKER_CHANNEL_TYPE

Method Detail

createEventLoop

public static io.netty.channel.EventLoopGroup createEventLoop(ChannelType type,
                                                              int numThreads,
                                                              String threadPrefix,
                                                              boolean isDaemon)

Creates a Netty EventLoopGroup based on ChannelType.

Parameters:

type - Selector for which form of low-level IO we should use

numThreads - target number of threads

threadPrefix - name pattern for each thread. should contain '%d' to distinguish between threads.

isDaemon - if true, the ThreadFactory will create daemon threads.

Returns:

EventLoopGroup matching the ChannelType

getServerChannelClass

public static Class<? extends io.netty.channel.ServerChannel> getServerChannelClass(boolean isDomainSocket)

Returns the correct ServerSocketChannel class for use by the worker.

Parameters:

isDomainSocket - whether this is a domain socket server

Returns:

ServerSocketChannel matching the requirements

getClientChannelClass

public static Class<? extends io.netty.channel.Channel> getClientChannelClass(boolean isDomainSocket)

Returns the correct SocketChannel class for use by the client.

Parameters:

isDomainSocket - whether this is to connect to a domain socket server

Returns:

Channel matching the requirements

enableAutoRead

public static void enableAutoRead(io.netty.channel.Channel channel)

Enables auto read for a netty channel.

Parameters:

channel - the netty channel

disableAutoRead

public static void disableAutoRead(io.netty.channel.Channel channel)

Disables auto read for a netty channel.

Parameters:

channel - the netty channel

isDomainSocketSupported

public static boolean isDomainSocketSupported(WorkerNetAddress workerNetAddress)

Parameters:

workerNetAddress - the worker address

Returns:

true if the domain socket is enabled on this client