Package 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.ProtobufRpcEngine2.Server

org.apache.hadoop.ipc.ProtobufRpcEngine.Server

Enclosing class:

ProtobufRpcEngine

public static class ProtobufRpcEngine.Server
extends ProtobufRpcEngine2.Server

Server implementation is always ProtobufRpcEngine2 based implementation, supports backward compatibility for protobuf 2.5 based implementations, which uses non-shaded protobuf classes.

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
static ProtobufRpcEngineCallback	registerForDeferredResponse()

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

getServerRpcInvoker, 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

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)

alignmentContext - provides server state info on client responses

secretManager - input secretManager.

queueSizePerHandler - input queueSizePerHandler.

numReaders - input numReaders.

Throws:

IOException - raised on errors performing I/O.

Method Details

registerForDeferredResponse

@Unstable
public static ProtobufRpcEngineCallback registerForDeferredResponse()