readAndProcess() |  | 0% |  | 0% | 17 | 17 | 52 | 52 | 1 | 1 |
processRpcRequest(RpcHeaderProtos.RpcRequestHeaderProto, RpcWritable.Buffer) |  | 0% |  | 0% | 13 | 13 | 65 | 65 | 1 | 1 |
saslProcess(RpcHeaderProtos.RpcSaslProto) |  | 0% |  | 0% | 12 | 12 | 49 | 49 | 1 | 1 |
Server.Connection(Server, SocketChannel, long, int, boolean) |  | 0% |  | 0% | 3 | 3 | 32 | 32 | 1 | 1 |
processSaslMessage(RpcHeaderProtos.RpcSaslProto) |  | 0% |  | 0% | 12 | 12 | 29 | 29 | 1 | 1 |
processOneRpc(ByteBuffer) |  | 0% |  | 0% | 4 | 4 | 25 | 25 | 1 | 1 |
unwrapPacketAndProcessRpcs(byte[]) |  | 0% |  | 0% | 9 | 9 | 25 | 25 | 1 | 1 |
setupBadVersionResponse(int) |  | 0% |  | 0% | 4 | 4 | 22 | 22 | 1 | 1 |
processConnectionContext(RpcWritable.Buffer) |  | 0% |  | 0% | 8 | 8 | 21 | 21 | 1 | 1 |
processRpcOutOfBandRequest(RpcHeaderProtos.RpcRequestHeaderProto, RpcWritable.Buffer) |  | 0% |  | 0% | 7 | 7 | 13 | 13 | 1 | 1 |
authorizeConnection() |  | 0% |  | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
buildSaslNegotiateResponse() |  | 0% |  | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
initializeAuthContext(int) |  | 0% |  | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
close() |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
saslReadAndProcess(RpcWritable.Buffer) |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
checkDataLength(int) |  | 0% |  | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
checkRpcHeaders(RpcHeaderProtos.RpcRequestHeaderProto) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
processSaslToken(RpcHeaderProtos.RpcSaslProto) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getAuthorizedUgi(String) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
getTrueCause(IOException) |  | 0% |  | 0% | 6 | 6 | 12 | 12 | 1 | 1 |
buildSaslResponse(RpcHeaderProtos.RpcSaslProto.SaslState, byte[]) |  | 0% |  | 0% | 4 | 4 | 8 | 8 | 1 | 1 |
doSaslReply(Message) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
createSaslServer(SaslRpcServer.AuthMethod) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
doSaslReply(Exception) |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
setupHttpRequestOnIpcPortResponse() |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
getMessage(Message, RpcWritable.Buffer) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
disposeSasl() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
isIdle() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
toString() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
switchToSimple() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
sendResponse(Server.RpcCall) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setShouldClose() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
decRpcCount() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
incRpcCount() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setLastContact(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getConf() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setServiceClass(int) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
shouldClose() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHostAddress() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getIngressPort() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getRemotePort() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getHostInetAddress() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEstablishedQOP() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isOnAuxiliaryPort() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getLastContact() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getServer() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getServiceClass() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |