public abstract static class RPC.Server extends Server
Server.AuthProtocol, Server.Call, Server.Connection
AUDITLOG, LOG, rpcDetailedMetrics, rpcMetrics
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) |
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.
|
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
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
IOException
public RPC.Server addProtocol(RPC.RpcKind rpcKind, Class<?> protocolClass, Object protocolImpl)
protocolClass
- - the protocol classprotocolImpl
- - the impl of the protocol that will be calledCopyright © 2013 Apache Software Foundation. All rights reserved.