RouterRpcClient

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,739 of 2,7390%296 of 2960%2172176326326969
invokeMethod(UserGroupInformation, List, boolean, Class, Method, Object[])4630%600%313110110111
invokeConcurrent(Collection, RemoteMethod, boolean, long, Class)4630%280%1515969611
RouterRpcClient(Configuration, Router, ActiveNamenodeResolver, RouterRpcMonitor, RouterStateIdContext)1820%120%77424211
invokeSequential(RemoteMethod, List, Class, Object)1790%140%88404011
getCleanException(IOException)1410%100%66363611
addClientInfoToCallerContext(UserGroupInformation)1060%140%88262611
invoke(String, FederationNamenodeContext, Boolean, int, Method, Object, Object[])770%120%77212111
processException(IOException, RemoteLocationContext)730%60%44212111
invokeConcurrent(Collection, RemoteMethod, boolean, boolean, long, Class)730%160%99191911
getConnection(UserGroupInformation, String, String, Class)650%60%44151511
processExceptionMsg(String, String, String)630%100%669911
invokeSingle(String, RemoteMethod)560%n/a11111111
acquirePermit(String, UserGroupInformation, RemoteMethod, RouterRpcFairnessPolicyController)530%80%55141411
getOrderedNamenodes(String, boolean)530%120%77101011
shouldRetry(IOException, int, String, FederationNamenodeContext, boolean)350%40%33101011
isClusterUnAvailable(String, FederationNamenodeContext, boolean)350%100%66101011
getLocationWithBPID(List, String)340%40%337711
getClientConfiguration(Configuration)320%40%338811
getAsyncCallerPoolJson()310%n/a115511
getNamenodesForBlockPoolId(String)300%40%336611
isUnavailableException(IOException)270%120%777711
refreshFairnessPolicyController(Configuration)260%40%33101011
isNamespaceStateIdFresh(String)230%40%334411
isReadCall(Method)220%60%445511
shutdown()200%60%447711
shouldRotateCache(IOException)200%40%337711
toIOException(Exception)180%40%335511
getRejectedPermitForNs(String)150%20%222211
getAcceptedPermitForNs(String)150%20%222211
invokeAll(Collection, RemoteMethod)130%n/a113311
lambda$invokeConcurrent$1(Server.Call, CallerContext, UserGroupInformation, List, boolean, Class, Method, Object[])130%n/a112211
lambda$invokeConcurrent$0(Server.Call, CallerContext, UserGroupInformation, List, boolean, Class, Method, Object[])130%n/a112211
invokeSingle(ExtendedBlock, RemoteMethod, List, Class)120%n/a112211
invokeSingle(ExtendedBlock, RemoteMethod, Class)120%n/a113311
isExpectedClass(Class, Object)120%40%335511
isExpectedValue(Object, Object)120%40%335511
getNameserviceForBlockPoolId(String)120%n/a114411
releasePermit(String, UserGroupInformation, RemoteMethod, RouterRpcFairnessPolicyController)120%20%225511
isObserverReadEligible(String, Method)110%40%331111
isNamespaceObserverReadEligible(String)110%20%221111
invokeSingle(RemoteLocationContext, RemoteMethod, Class)100%n/a113311
getCurrentFairnessPolicyControllerClassName()100%20%223311
invokeSingleBlockPool(String, RemoteMethod)90%n/a112211
invokeConcurrent(Collection, RemoteMethod, boolean, boolean)90%n/a112211
invokeConcurrent(Collection, RemoteMethod, boolean, boolean, Class)90%n/a111111
invokeSequential(List, RemoteMethod, Class, Object)80%n/a112211
invokeConcurrent(Collection, RemoteMethod, Class)80%n/a111111
incrRejectedPermitForNs(String)80%n/a112211
incrAcceptedPermitForNs(String)80%n/a112211
invokeSingle(String, RemoteMethod, Class)70%n/a112211
invokeSequential(List, RemoteMethod)70%n/a111111
invokeConcurrent(Collection, RemoteMethod)70%n/a112211
getTimeOfLastCallToActive(String)70%n/a112211
static {...}70%n/a114411
transferThreadLocalContext(Server.Call, CallerContext)60%n/a113311
lambda$getTimeOfLastCallToActive$4(String)60%n/a111111
getNumConnections()40%n/a111111
getNumActiveConnections()40%n/a111111
getNumIdleConnections()40%n/a111111
getNumActiveConnectionsRecently()40%n/a111111
getNumConnectionPools()40%n/a111111
getNumCreatingConnections()40%n/a111111
getJSON()40%n/a111111
getRejectedPermitsPerNsJSON()40%n/a111111
getAcceptedPermitsPerNsJSON()40%n/a111111
lambda$incrAcceptedPermitForNs$3(String)40%n/a111111
lambda$incrRejectedPermitForNs$2(String)40%n/a111111
getNamenodeResolver()0%n/a111111
getRouterRpcFairnessPolicyController()0%n/a111111