org.apache.giraph.comm.netty

Class NettyServer

java.lang.Object

org.apache.giraph.comm.netty.NettyServer

public class NettyServer
extends Object

This server uses Netty and will implement all Giraph communication

Field Summary

Fields

Modifier and Type	Field and Description
static io.netty.util.AttributeKey<SaslNettyServer>	CHANNEL_SASL_NETTY_SERVERS Used to authenticate with netty clients
static int	MAXIMUM_THREAD_POOL_SIZE_DEFAULT Default maximum thread pool size

Constructor Summary

Constructors

Constructor and Description
NettyServer(ImmutableClassesGiraphConfiguration conf, RequestServerHandler.Factory requestServerHandlerFactory, TaskInfo myTaskInfo, org.apache.hadoop.util.Progressable progressable, SaslServerHandler.Factory saslServerHandlerFactory, Thread.UncaughtExceptionHandler exceptionHandler) Constructor for creating the server
NettyServer(ImmutableClassesGiraphConfiguration conf, RequestServerHandler.Factory requestServerHandlerFactory, TaskInfo myTaskInfo, org.apache.hadoop.util.Progressable progressable, Thread.UncaughtExceptionHandler exceptionHandler) Constructor for creating the server

Method Summary

Modifier and Type	Method and Description
InboundByteCounter	getInByteCounter() Returns a handle on the in-bound byte counter.
String	getLocalHostOrIp()
InetSocketAddress	getMyAddress()
void	setFlowControl(FlowControl flowControl) Inform the server about the flow control policy used in sending requests
void	start() Start the server with the appropriate port
void	stop() Stop the server.

Methods inherited from class java.lang.Object

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

Field Detail

MAXIMUM_THREAD_POOL_SIZE_DEFAULT

public static final int MAXIMUM_THREAD_POOL_SIZE_DEFAULT

Default maximum thread pool size

See Also:

Constant Field Values

CHANNEL_SASL_NETTY_SERVERS

public static final io.netty.util.AttributeKey<SaslNettyServer> CHANNEL_SASL_NETTY_SERVERS

Used to authenticate with netty clients

Constructor Detail

NettyServer

public NettyServer(ImmutableClassesGiraphConfiguration conf,
                   RequestServerHandler.Factory requestServerHandlerFactory,
                   TaskInfo myTaskInfo,
                   org.apache.hadoop.util.Progressable progressable,
                   Thread.UncaughtExceptionHandler exceptionHandler)

Constructor for creating the server

Parameters:

conf - Configuration to use

requestServerHandlerFactory - Factory for request handlers

myTaskInfo - Current task info

progressable - Progressable for reporting progress

exceptionHandler - handle uncaught exceptions

NettyServer

public NettyServer(ImmutableClassesGiraphConfiguration conf,
                   RequestServerHandler.Factory requestServerHandlerFactory,
                   TaskInfo myTaskInfo,
                   org.apache.hadoop.util.Progressable progressable,
                   SaslServerHandler.Factory saslServerHandlerFactory,
                   Thread.UncaughtExceptionHandler exceptionHandler)

Constructor for creating the server

Parameters:

conf - Configuration to use

requestServerHandlerFactory - Factory for request handlers

myTaskInfo - Current task info

progressable - Progressable for reporting progress

saslServerHandlerFactory - Factory for SASL handlers

exceptionHandler - handle uncaught exceptions

Method Detail

getInByteCounter

public InboundByteCounter getInByteCounter()

Returns a handle on the in-bound byte counter.

Returns:

The InboundByteCounter object for this server.

start

public void start()

Start the server with the appropriate port

stop

public void stop()

Stop the server.

getMyAddress

public InetSocketAddress getMyAddress()

getLocalHostOrIp

public String getLocalHostOrIp()

setFlowControl

public void setFlowControl(FlowControl flowControl)

Inform the server about the flow control policy used in sending requests

Parameters:

flowControl - reference to the flow control used