Package org.apache.hadoop.ipc

Class ProtobufRpcEngine2.Server

java.lang.Object

org.apache.hadoop.ipc.Server

org.apache.hadoop.ipc.RPC.Server

org.apache.hadoop.ipc.ProtobufRpcEngine2.Server

Direct Known Subclasses:

ProtobufRpcEngine.Server

Enclosing class:

ProtobufRpcEngine2

public static class ProtobufRpcEngine2.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	Description
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, AlignmentContext alignmentContext)	Construct an RPC server.

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.ipc.RPC.RpcInvoker	getServerRpcInvoker(RPC.RpcKind rpcKind)
static ProtobufRpcEngineCallback2	registerForDeferredResponse2()

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

addProtocol, call

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

addAuxiliaryListener, addSuppressedLoggingExceptions, addTerseExceptions, bind, bind, call, get, getAuxiliaryListenerAddresses, getAuxiliaryPortEstablishedQOP, getCallId, getCallQueueLen, getCallRetryCount, getClientId, getCurCall, getListenerAddress, getLogSlowRPCThresholdTime, getMaxIdleTime, getMaxQueueSize, getNumDroppedConnections, getNumInProcessHandler, getNumOpenConnections, getNumOpenConnectionsPerUser, getNumReaders, getPort, getPriorityLevel, getProtocol, getPurgeIntervalNanos, getRemoteAddress, getRemoteIp, getRemotePort, getRemoteUser, getRpcDetailedMetrics, getRpcInvoker, getRpcMetrics, getRpcRequestWrapper, getServerName, getServiceAuthorizationManager, getTotalRequests, getTotalRequestsPerSecond, isClientBackoffEnabled, isLogSlowRPC, isRpcInvocation, isServerFailOverEnabled, isServerFailOverEnabledByQueue, join, queueCall, refreshCallQueue, refreshServiceAcl, refreshServiceAclWithLoadedConfiguration, registerProtocolEngine, setAlignmentContext, setClientBackoffEnabled, setLogSlowRPC, setLogSlowRPCThresholdTime, setSocketSendBufSize, setTracer, start, stop

Methods inherited from class java.lang.Object

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

Constructor Details

Server

public 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,
 AlignmentContext alignmentContext)
       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

numReaders - number of read threads

queueSizePerHandler - the size of the queue contained in each Handler

verbose - whether each call should be logged

secretManager - the server-side secret manager for each token type

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

alignmentContext - provides server state info on client responses

Throws:

IOException - raised on errors performing I/O.

Method Details

registerForDeferredResponse2

@Unstable
public static ProtobufRpcEngineCallback2 registerForDeferredResponse2()

getServerRpcInvoker

protected org.apache.hadoop.ipc.RPC.RpcInvoker getServerRpcInvoker(RPC.RpcKind rpcKind)

Overrides:

getServerRpcInvoker in class Server