org.apache.giraph.comm.netty

Class NettyMasterServer

java.lang.Object

org.apache.giraph.comm.netty.NettyMasterServer

All Implemented Interfaces:

MasterServer

public class NettyMasterServer
extends Object
implements MasterServer

Netty implementation of MasterServer

Constructor Summary

Constructors

Constructor and Description
NettyMasterServer(ImmutableClassesGiraphConfiguration conf, CentralizedServiceMaster<?,?,?> service, org.apache.hadoop.util.Progressable progressable, Thread.UncaughtExceptionHandler exceptionHandler) Constructor

Method Summary

Modifier and Type	Method and Description
void	close() Shuts down.
String	getLocalHostOrIp() Get server host or IP
InetSocketAddress	getMyAddress() Get server address
void	setFlowControl(FlowControl flowControl) Inform the server about the flow control policy used in sending requests

Methods inherited from class java.lang.Object

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

Constructor Detail

NettyMasterServer

public NettyMasterServer(ImmutableClassesGiraphConfiguration conf,
                         CentralizedServiceMaster<?,?,?> service,
                         org.apache.hadoop.util.Progressable progressable,
                         Thread.UncaughtExceptionHandler exceptionHandler)

Constructor

Parameters:

conf - Hadoop configuration

service - Centralized service

progressable - Progressable for reporting progress

exceptionHandler - to handle uncaught exceptions

Method Detail

getMyAddress

public InetSocketAddress getMyAddress()

Description copied from interface: MasterServer

Get server address

Specified by:

getMyAddress in interface MasterServer

Returns:

Address used by this server

getLocalHostOrIp

public String getLocalHostOrIp()

Description copied from interface: MasterServer

Get server host or IP

Specified by:

getLocalHostOrIp in interface MasterServer

Returns:

Server host or IP

close

public void close()

Description copied from interface: MasterServer

Shuts down.

Specified by:

close in interface MasterServer

setFlowControl

public void setFlowControl(FlowControl flowControl)

Description copied from interface: MasterServer

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

Specified by:

setFlowControl in interface MasterServer

Parameters:

flowControl - reference to flow control policy