Server(String, int, Class, int, int, int, Configuration, String, SecretManager, String) |  | 0% |  | 0% | 5 | 5 | 65 | 65 | 1 | 1 |
updateMetrics(Server.Call, long, boolean) |  | 0% |  | 0% | 5 | 5 | 37 | 37 | 1 | 1 |
updateDeferredMetrics(Server.Call, String) |  | 0% |  | 0% | 3 | 3 | 25 | 25 | 1 | 1 |
setupResponse(Server.RpcCall, RpcHeaderProtos.RpcResponseHeaderProto.RpcStatusProto, RpcHeaderProtos.RpcResponseHeaderProto.RpcErrorCodeProto, Writable, String, String) |  | 0% |  | 0% | 4 | 4 | 26 | 26 | 1 | 1 |
logSlowRpcCalls(String, Server.Call, ProcessingDetails) |  | 0% |  | 0% | 4 | 4 | 13 | 13 | 1 | 1 |
setupResponseForProtobuf(RpcHeaderProtos.RpcResponseHeaderProto, Writable) |  | 0% |  | 0% | 4 | 4 | 17 | 17 | 1 | 1 |
stop() |  | 0% |  | 0% | 7 | 7 | 19 | 19 | 1 | 1 |
bind(ServerSocket, InetSocketAddress, int, Configuration, String) |  | 0% |  | 0% | 8 | 8 | 21 | 21 | 1 | 1 |
buildNegotiateResponse(List) |  | 0% |  | 0% | 6 | 6 | 15 | 15 | 1 | 1 |
start() |  | 0% |  | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
wrapWithSasl(Server.RpcCall) |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
channelIO(ReadableByteChannel, WritableByteChannel, ByteBuffer) |  | 0% |  | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
getSchedulerClass(String, int, Configuration) |  | 0% |  | 0% | 5 | 5 | 14 | 14 | 1 | 1 |
internalQueueCall(Server.Call, boolean) |  | 0% |  | 0% | 4 | 4 | 14 | 14 | 1 | 1 |
addAuxiliaryListener(int) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
registerProtocolEngine(RPC.RpcKind, Class, RPC.RpcInvoker) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
logException(Logger, Throwable, Server.Call) |  | 0% |  | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
getAuthMethods(SecretManager, Configuration) |  | 0% |  | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
getSchedulerClass(String, Configuration) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
refreshCallQueue(Configuration) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
authorize(UserGroupInformation, String, InetAddress) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
doKerberosRelogin() |  | 0% |  | 0% | 7 | 7 | 13 | 13 | 1 | 1 |
setupResponse(Server.RpcCall, RpcHeaderProtos.RpcResponseHeaderProto, Writable) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
getAuxiliaryListenerAddresses() |  | 0% |  | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
setupResponseForWritable(RpcHeaderProtos.RpcResponseHeaderProto, Writable) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
setupResponseOldVersionFatal(ByteArrayOutputStream, Server.RpcCall, Writable, String, String) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
getQueueClass(String, int, Configuration) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
shutdownMetricsUpdaterExecutor() |  | 0% |  | 0% | 2 | 2 | 10 | 10 | 1 | 1 |
getAuxiliaryPortEstablishedQOP() |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
channelWrite(WritableByteChannel, ByteBuffer) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
channelRead(ReadableByteChannel, ByteBuffer) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
getRpcRequestWrapper(RpcHeaderProtos.RpcKindProto) |  | 0% |  | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
getClientBackoffEnable(String, int, Configuration) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
getProtocolClass(String, Configuration) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
setPurgeIntervalNanos(int) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
Server(String, int, Class, int, Configuration) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
Server(String, int, Class, int, int, int, Configuration, String, SecretManager) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getNumOpenConnectionsPerUser() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getRpcInvoker(RPC.RpcKind) |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getQueueClass(String, Configuration) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getCallId() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getCallRetryCount() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getRemoteIp() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getRemotePort() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getClientId() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getRemoteUser() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getProtocol() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getPriorityLevel() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
queueCall(Server.Call) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getRemoteAddress() |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
setLogSlowRPCThresholdTime(long) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getClientBackoffEnable(String, Configuration) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getDelimitedLength(Message) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
isRpcInvocation() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
bind(ServerSocket, InetSocketAddress, int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
join() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
call(Writable, long) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setPriorityLevel(UserGroupInformation, int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
refreshServiceAcl(Configuration, PolicyProvider) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
refreshServiceAclWithLoadedConfiguration(Configuration, PolicyProvider) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
closeConnection(Server.Connection) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
addTerseExceptions(Class[]) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
addSuppressedLoggingExceptions(Class[]) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getPriorityLevel(Schedulable) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPriorityLevel(UserGroupInformation) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
internalQueueCall(Server.Call) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setClientBackoffEnabled(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setAlignmentContext(AlignmentContext) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
get() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumInProcessHandler() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTotalRequests() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setLogSlowRPC(boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getHandlers() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getQueueClassPrefix() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setSocketSendBufSize(int) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setTracer(Tracer) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getListenerAddress() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumOpenConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumDroppedConnections() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCallQueueLen() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isClientBackoffEnabled() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isServerFailOverEnabled() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isServerFailOverEnabledByQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxIdleTime() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setCallQueue(CallQueueManager) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setRpcRequestClass(Class) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getServerRpcInvoker(RPC.RpcKind) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isLogSlowRPC() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLogSlowRPCThresholdTime() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getTotalRequestsPerSecond() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPurgeIntervalNanos() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRpcMetrics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRpcDetailedMetrics() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getServiceAuthorizationManager() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConf() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPort() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getMaxQueueSize() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNumReaders() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getServerName() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCallQueue() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCurCall() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |