RouterAsyncRpcClient

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total856 of 8560%36 of 360%53532002003535
getRemoteResults(RemoteMethod, long, RouterRpcFairnessPolicyController, List, List)570%20%22171711
lambda$invokeMethod$2(Method, boolean, List, Object[], ThreadLocalContext, String, UserGroupInformation, Class, Object)550%20%229911
invokeMethod(UserGroupInformation, List, boolean, Class, Method, Object[])530%40%33111111
lambda$invokeSequential$12(RemoteLocationContext, List, Method, String, Object, Exception)530%20%22111111
invokeMethodAsync(UserGroupInformation, List, boolean, Class, Method, Object[])450%20%229911
invokeSequential(RemoteMethod, List, Class, Object)450%n/a11101011
lambda$invokeSequential$14(RouterRpcClient.ExecutionStatus, List, Object[], List, Object)440%80%55101011
invokeSingle(String, RemoteMethod)410%n/a119911
lambda$invokeMethodAsync$7(RouterRpcClient.ExecutionStatus, ConnectionContext[], UserGroupInformation, Class, Method, Object[], Map, boolean, AsyncForEachRun, FederationNamenodeContext)410%40%33101011
invokeSingle(RemoteLocationContext, RemoteMethod)360%n/a119911
lambda$invokeSequential$13(Method, RemoteMethod, UserGroupInformation, Class, Object, RouterRpcClient.ExecutionStatus, Object[], List, AsyncForEachRun, RemoteLocationContext)360%n/a117711
lambda$invokeMethodAsync$4(ConnectionContext[], UserGroupInformation, String, String, Class, FederationNamenodeContext, RouterRpcClient.ExecutionStatus, Method, Object[], AsyncForEachRun)360%n/a116611
invoke(FederationNamenodeContext, Boolean, int, Method, Object, Object[])340%n/a11111111
lambda$invokeSequential$10(Class, Object, RemoteLocationContext, AsyncForEachRun, RouterRpcClient.ExecutionStatus, Object[], Object)330%60%44101011
lambda$invokeSequential$11(RemoteMethod, RemoteLocationContext, UserGroupInformation, List, boolean, Method, Class, Object, AsyncForEachRun, RouterRpcClient.ExecutionStatus, Object[])250%n/a115511
lambda$getRemoteResults$16(RemoteMethod, Method, List, CompletableFuture[], Void, Throwable)230%n/a115511
lambda$invokeSingle$18(RemoteMethod, RemoteLocationContext, UserGroupInformation, List, boolean, Method)200%n/a115511
RouterAsyncRpcClient(Configuration, Router, ActiveNamenodeResolver, RouterRpcMonitor, RouterStateIdContext)170%n/a115511
invokeAll(Collection, RemoteMethod)150%n/a113311
invokeConcurrent(Collection, RemoteMethod, boolean, boolean, long, Class)150%n/a113311
lambda$invokeMethodAsync$3(RouterRpcClient.ExecutionStatus, Method, FederationNamenodeContext, String, NameNodeProxiesClient.ProxyAndInfo, AsyncForEachRun, Object)140%n/a114411
lambda$invokeMethodAsync$5(Map, FederationNamenodeContext, RouterRpcClient.ExecutionStatus, boolean, Object, IOException)130%n/a113311
invokeSequential(List, RemoteMethod, Class, Object)120%n/a113311
releasePermit(String, UserGroupInformation, Method, RouterRpcFairnessPolicyController)120%20%225511
lambda$invokeMethodAsync$8(RouterRpcClient.ExecutionStatus, List, Method, Map, Object[], Object)120%20%223311
invokeSingle(RemoteLocationContext, RemoteMethod, Class)110%n/a113311
lambda$invoke$9(FederationNamenodeContext, Boolean, int, Method, Object, Object[], Object, Throwable)110%n/a112211
lambda$invokeMethodAsync$6(ConnectionContext[], Object)100%20%223311
lambda$invokeSingle$17(RemoteLocationContext, Object)90%n/a112211
lambda$invokeMethod$1(String, UserGroupInformation, Method, RouterRpcFairnessPolicyController, Object)80%n/a112211
lambda$invokeAll$0(Map)60%n/a111111
lambda$invokeSingle$19(RemoteLocationContext, Object, IOException)50%n/a111111
lambda$invokeConcurrent$15(boolean, List)40%n/a111111
static {...}40%n/a112211
initConcurrentCallExecutorService(Configuration)10%n/a111111