| handleInvokeMethodIOException(FederationNamenodeContext, IOException, RouterRpcClient.ExecutionStatus, boolean) |  | 0% | | 0% | 15 | 15 | 45 | 45 | 1 | 1 |
| invokeConcurrent(Collection, RemoteMethod, boolean, long, Class) | | 0% | | 0% | 10 | 10 | 38 | 38 | 1 | 1 |
| invokeSequential(RemoteMethod, List, Class, Object) | | 0% | | 0% | 8 | 8 | 40 | 40 | 1 | 1 |
| RouterRpcClient(Configuration, Router, ActiveNamenodeResolver, RouterRpcMonitor, RouterStateIdContext) | | 0% | | 0% | 6 | 6 | 35 | 35 | 1 | 1 |
| getCleanException(IOException) | | 0% | | 0% | 6 | 6 | 36 | 36 | 1 | 1 |
| invokeMethod(UserGroupInformation, List, boolean, Class, Method, Object[]) | | 0% | | 0% | 9 | 9 | 32 | 32 | 1 | 1 |
| processFutures(RemoteMethod, Method, List, List) | | 0% | | 0% | 4 | 4 | 27 | 27 | 1 | 1 |
| handlerAllNamenodeFail(List, Method, Map, Object[]) | | 0% | | 0% | 5 | 5 | 22 | 22 | 1 | 1 |
| addClientInfoToCallerContext(UserGroupInformation) | | 0% | | 0% | 8 | 8 | 26 | 26 | 1 | 1 |
| getRemoteResults(RemoteMethod, long, RouterRpcFairnessPolicyController, List, List) | | 0% | | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
| processException(IOException, RemoteLocationContext) | | 0% | | 0% | 4 | 4 | 21 | 21 | 1 | 1 |
| invokeSingle(RemoteLocationContext, RemoteMethod) | | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
| postProcessResult(boolean, List) | | 0% | | 0% | 9 | 9 | 18 | 18 | 1 | 1 |
| handlerInvokeException(FederationNamenodeContext, Boolean, int, Method, Object, Throwable, Object[]) | | 0% | | 0% | 7 | 7 | 16 | 16 | 1 | 1 |
| processExceptionMsg(String, String, String) | | 0% | | 0% | 6 | 6 | 9 | 9 | 1 | 1 |
| getConnection(UserGroupInformation, String, String, Class) | | 0% | | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
| invokeSingle(String, RemoteMethod) | | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
| getOrderedNamenodes(String, boolean) | | 0% | | 0% | 7 | 7 | 10 | 10 | 1 | 1 |
| acquirePermit(String, UserGroupInformation, String, RouterRpcFairnessPolicyController) | | 0% | | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
| initConcurrentCallExecutorService(Configuration) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| shouldRetry(IOException, int, String, FederationNamenodeContext, boolean) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| postProcessResult(Method, RouterRpcClient.ExecutionStatus, FederationNamenodeContext, String, NameNodeProxiesClient.ProxyAndInfo) | | 0% | | 0% | 5 | 5 | 9 | 9 | 1 | 1 |
| isClusterUnAvailable(String, FederationNamenodeContext, boolean) | | 0% | | 0% | 6 | 6 | 10 | 10 | 1 | 1 |
| getAsyncCallerPoolJson() | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| getLocationWithBPID(List, String) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| getClientConfiguration(Configuration) | | 0% | | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
| isUnavailableException(IOException) | | 0% | | 0% | 7 | 7 | 7 | 7 | 1 | 1 |
| invoke(FederationNamenodeContext, Boolean, int, Method, Object, Object[]) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| refreshFairnessPolicyController(Configuration) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| isNamespaceStateIdFresh(String) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
| isReadCall(Method) | | 0% | | 0% | 4 | 4 | 5 | 5 | 1 | 1 |
| getNamenodesForBlockPoolId(String) | | 0% | | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
| shutdown() | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| shouldRotateCache(IOException) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| toIOException(Exception) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| getRejectedPermitForNs(String) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| getAcceptedPermitForNs(String) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| invokeAll(Collection, RemoteMethod) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$invokeConcurrent$1(Server.Call, CallerContext, UserGroupInformation, List, boolean, Class, Method, Object[]) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$invokeConcurrent$0(Server.Call, CallerContext, UserGroupInformation, List, boolean, Class, Method, Object[]) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeSingle(ExtendedBlock, RemoteMethod, List, Class) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeSingle(ExtendedBlock, RemoteMethod, Class) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| isExpectedClass(Class, Object) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| isExpectedValue(Object, Object) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| invokeConcurrent(Collection, RemoteMethod, boolean, boolean, long, Class) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getNameserviceForBlockPoolId(String) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| releasePermit(String, UserGroupInformation, RemoteMethod, RouterRpcFairnessPolicyController) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| isObserverReadEligible(String, Method) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| isNamespaceObserverReadEligible(String) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| invokeSingle(RemoteLocationContext, RemoteMethod, Class) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| getCurrentFairnessPolicyControllerClassName() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| invokeSingleBlockPool(String, RemoteMethod) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeConcurrent(Collection, RemoteMethod, boolean, boolean) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeConcurrent(Collection, RemoteMethod, boolean, boolean, Class) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| invokeSequential(List, RemoteMethod, Class, Object) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeConcurrent(Collection, RemoteMethod, Class) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| incrRejectedPermitForNs(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| incrAcceptedPermitForNs(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeSingle(String, RemoteMethod, Class) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| invokeSequential(List, RemoteMethod) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| invokeConcurrent(Collection, RemoteMethod) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getTimeOfLastCallToActive(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| transferThreadLocalContext(Server.Call, CallerContext) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$getTimeOfLastCallToActive$4(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumConnections() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumActiveConnections() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumIdleConnections() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumActiveConnectionsRecently() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumConnectionPools() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNumCreatingConnections() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getJSON() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getRejectedPermitsPerNsJSON() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getAcceptedPermitsPerNsJSON() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$incrAcceptedPermitForNs$3(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$incrRejectedPermitForNs$2(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getNamenodeResolver() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getExecutorService() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getRouterRpcFairnessPolicyController() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |