edu.snu.coral.runtime.common

Class NativeChannelImplementationSelector

java.lang.Object

edu.snu.coral.runtime.common.NativeChannelImplementationSelector

All Implemented Interfaces:

NettyChannelImplementationSelector

public final class NativeChannelImplementationSelector
extends Object
implements NettyChannelImplementationSelector

A NettyChannelImplementationSelector implementation that prefers native transport if possible. Uses Epoll if possible (on Linux).

Method Summary

Modifier and Type	Method and Description
Class<? extends io.netty.channel.Channel>	getChannelClass()
Class<? extends io.netty.channel.ServerChannel>	getServerChannelClass()
io.netty.channel.EventLoopGroup	newEventLoopGroup(int numThreads, ThreadFactory threadFactory) Creates a new EventLoopGroup.

Methods inherited from class java.lang.Object

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

Method Detail

newEventLoopGroup

public io.netty.channel.EventLoopGroup newEventLoopGroup(int numThreads,
                                                         ThreadFactory threadFactory)

Description copied from interface: NettyChannelImplementationSelector

Creates a new EventLoopGroup.

Specified by:

newEventLoopGroup in interface NettyChannelImplementationSelector

Parameters:

numThreads - the number of threads

threadFactory - the ThreadFactory

Returns:

a new EventLoopGroup

getServerChannelClass

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

Specified by:

getServerChannelClass in interface NettyChannelImplementationSelector

Returns:

class for server channel

getChannelClass

public Class<? extends io.netty.channel.Channel> getChannelClass()

Specified by:

getChannelClass in interface NettyChannelImplementationSelector

Returns:

class for channel