org.apache.hadoop.ipc

Class RPC.Server

java.lang.Object

org.apache.hadoop.ipc.Server

org.apache.hadoop.ipc.RPC.Server

Direct Known Subclasses:

ProtobufRpcEngine.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 and Description
protected	RPC.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

Methods

Modifier and Type	Method and 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

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

RPC.Server

protected RPC.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 Detail

addProtocol

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

Add a protocol to the existing server.

Parameters:

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

Throws:

Exception