Package org.apache.hadoop.ipc

Class RPC.Server

java.lang.Object

org.apache.hadoop.ipc.Server

org.apache.hadoop.ipc.RPC.Server

Direct Known Subclasses:

ProtobufRpcEngine2.Server, WritableRpcEngine.Server

Enclosing class:

RPC

public abstract static class RPC.Server
extends Server

An 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

Modifier	Constructor	Description
protected	Server(String bindAddress, int port, Class<? extends Writable> paramClass, int handlerCount, int numReaders, int queueSizePerHandler, Configuration conf, String serverName, SecretManager<? extends TokenIdentifier> secretManager, String portRangeConfig)

Method Summary

Modifier and Type	Method	Description
RPC.Server	addProtocol(RPC.RpcKind rpcKind, Class<?> protocolClass, Object protocolImpl)	Add a protocol to the existing server.
Writable	call(RPC.RpcKind rpcKind, String protocol, Writable rpcRequest, long receiveTime)	Called for each 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, getServerRpcInvoker, 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

protected Server(String bindAddress,
 int port,
 Class<? extends Writable> paramClass,
 int handlerCount,
 int numReaders,
 int queueSizePerHandler,
 Configuration conf,
 String serverName,
 SecretManager<? extends TokenIdentifier> secretManager,
 String portRangeConfig)
          throws IOException

Throws:

IOException

Method Details

addProtocol

public RPC.Server addProtocol(RPC.RpcKind rpcKind,
 Class<?> protocolClass,
 Object protocolImpl)

Add a protocol to the existing server.

Parameters:

rpcKind - - input rpcKind

protocolClass - - the protocol class

protocolImpl - - the impl of the protocol that will be called

Returns:

the server (for convenience)

call

public Writable call(RPC.RpcKind rpcKind,
 String protocol,
 Writable rpcRequest,
 long receiveTime)
              throws Exception

Description copied from class: Server

Called for each call.

Specified by:

call in class Server

Parameters:

rpcKind - input rpcKind.

protocol - input protocol.

rpcRequest - input param.

receiveTime - input receiveTime.

Returns:

Call.

Throws:

Exception - raised on errors performing I/O.