org.apache.hadoop.ipc

Class ProtobufRpcEngine.Server

java.lang.Object

org.apache.hadoop.ipc.Server

org.apache.hadoop.ipc.RPC.Server

org.apache.hadoop.ipc.ProtobufRpcEngine.Server

Enclosing class:

ProtobufRpcEngine

public static class ProtobufRpcEngine.Server
extends RPC.Server

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.ipc.Server

Server.AuthProtocol, Server.Call, Server.Connection

Field Summary

Fields inherited from class org.apache.hadoop.ipc.Server

AUDITLOG, LOG, rpcDetailedMetrics, rpcMetrics

Constructor Summary

Constructors

Constructor and Description
ProtobufRpcEngine.Server(Class<?> protocolClass, Object protocolImpl, Configuration conf, String bindAddress, int port, int numHandlers, int numReaders, int queueSizePerHandler, boolean verbose, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig) Construct an RPC server.

Method Summary

Methods inherited from class org.apache.hadoop.ipc.RPC.Server

addProtocol, call

Methods inherited from class org.apache.hadoop.ipc.Server

addTerseExceptions, bind, bind, call, get, getCallId, getCallQueueLen, getCallRetryCount, getClientId, getCurCall, getListenerAddress, getMaxQueueSize, getNumOpenConnections, getNumReaders, getPort, getRemoteAddress, getRemoteIp, getRemoteUser, getRpcDetailedMetrics, getRpcInvoker, getRpcMetrics, getRpcRequestWrapper, getServiceAuthorizationManager, isRpcInvocation, join, refreshServiceAcl, registerProtocolEngine, setSocketSendBufSize, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufRpcEngine.Server

public ProtobufRpcEngine.Server(Class<?> protocolClass,
                        Object protocolImpl,
                        Configuration conf,
                        String bindAddress,
                        int port,
                        int numHandlers,
                        int numReaders,
                        int queueSizePerHandler,
                        boolean verbose,
                        SecretManager<? extends TokenIdentifier> secretManager,
                        String portRangeConfig)
                         throws IOException

Construct an RPC server.

Parameters:

protocolClass - the class of protocol

protocolImpl - the protocolImpl whose methods will be called

conf - the configuration to use

bindAddress - the address to bind on to listen for connection

port - the port to listen for connections on

numHandlers - the number of method handler threads to run

verbose - whether each call should be logged

portRangeConfig - A config parameter that can be used to restrict the range of ports used when port is 0 (an ephemeral port)

Throws:

IOException