RouterRpcServer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,129 of 3,1290%201 of 2010%316316727727215215
RouterRpcServer(Configuration, Router, ActiveNamenodeResolver, FileSubclusterResolver)4740%100%66949411
getLocationsForPath(String, boolean, boolean)1590%300%1616464611
initAsyncThreadPools(Configuration)1320%120%77292911
initRouterFedRename()990%70%55252511
initNsAsyncHandlerCount()700%100%66121211
updateDnMap(Map, Map)700%80%55141411
getDatanodeStorageReportMap(HdfsConstants.DatanodeReportType, boolean, long)650%20%22121211
invokeOnNs(RemoteMethod, Class, IOException, Set)590%60%44121211
invokeAtAvailableNs(RemoteMethod, Class)570%40%33131311
getDatanodeReport(HdfsConstants.DatanodeReportType, boolean, long)500%n/a119911
getExistingLocation(String, List)470%40%337711
getDatanodeReportAsync(HdfsConstants.DatanodeReportType, boolean, long)460%n/a117711
invokeAtAvailableNsAsync(RemoteMethod, Class)440%20%229911
getDatanodeStorageReportMapAsync(HdfsConstants.DatanodeReportType, boolean, long)430%n/a116611
merge(Map, Class)420%60%447711
getCreateLocation(String, List)380%80%55111111
getSlowDatanodeReport(boolean, long)380%n/a119911
getCreateLocationAsync(String, List)370%60%448811
getExistingLocationAsync(String, List)350%n/a114411
getCachedDatanodeReportImpl(HdfsConstants.DatanodeReportType)350%20%22101011
getSlowDatanodeReportAsync(boolean, long)340%n/a117711
clearStaleNamespacesInRouterStateIdContext()300%20%22111111
lambda$getDatanodeStorageReportMapAsync$17(Map, Map)300%20%227711
checkOperation(NameNode.OperationCategory)290%80%55101011
serviceStop()270%80%55101011
lambda$invokeOnNsAsync$9(RemoteMethod, String, Object, IOException)270%20%224411
lambda$invokeAtAvailableNsAsync$6(Set, String, RemoteMethod, Class, IOException, Object, IOException)270%20%227711
getCachedDatanodeReport(HdfsConstants.DatanodeReportType)260%20%227711
checkSafeMode()240%40%336611
serviceInit(Configuration)230%20%226611
invokeOnNsAsync(RemoteMethod, Class, IOException, Set)220%20%227711
getCreateLocation(String)220%20%225511
isInvokeConcurrent(String)220%40%337711
lambda$invokeOnNsAsync$10(RemoteMethod, Class, AsyncForEachRun, FederationNamespaceInfo)220%n/a115511
checkOperation(NameNode.OperationCategory, boolean)200%40%337711
getMountTable(String)190%20%226611
lambda$getExistingLocationAsync$15(List, Map)190%40%335511
getRemoteUser()160%40%333311
serviceStart()140%20%225511
create(String, FsPermission, String, EnumSetWritable, boolean, short, long, CryptoProtocolVersion[], String, String)140%n/a111111
isSafeMode()130%40%332211
isPathReadOnly(String)130%40%332211
isPathAll(String)130%40%332211
isPathFaultTolerant(String)130%40%332211
lambda$new$0()130%n/a115511
getAdditionalDatanode(String, long, ExtendedBlock, DatanodeInfo[], String[], DatanodeInfo[], int, String)120%n/a111111
toArray(Collection, Class)120%n/a113311
lambda$getSlowDatanodeReportAsync$18(Map, Map)120%n/a113311
lambda$getDatanodeReportAsync$16(Map, Map)120%n/a113311
addBlock(String, String, ExtendedBlock, DatanodeInfo[], long, String[], EnumSet)110%n/a111111
lambda$getCreateLocationAsync$12(String, RemoteLocation, RemoteLocation)110%20%224411
lambda$invokeOnNsAsync$8(String, RemoteMethod, Class, AsyncForEachRun)110%n/a113311
getMethodName()100%n/a113311
getSchedulerJobCount()100%20%223311
lambda$getCreateLocationAsync$13(String, List, RemoteLocation)100%n/a113311
updatePipeline(String, ExtendedBlock, ExtendedBlock, DatanodeID[], String[])90%n/a112211
getSnapshotDiffReportListing(String, String, String, byte[], int)90%n/a111111
getBlocks(DatanodeInfo, long, long, long, StorageType)90%n/a111111
lambda$clearStaleNamespacesInRouterStateIdContext$2(Set, String)90%20%223311
initAsyncHandlerThreadPools4Ns(String, int)80%n/a112211
isEnableRenameAcrossNamespace()80%20%221111
abandonBlock(ExtendedBlock, long, String, String)80%n/a112211
complete(String, String, ExtendedBlock, long)80%n/a111111
fsync(String, long, String, long)80%n/a112211
createSymlink(String, String, FsPermission, boolean)80%n/a112211
setQuota(String, long, long, StorageType)80%n/a112211
lambda$invokeOnNsAsync$7(AsyncForEachRun, Object)80%20%224411
lambda$invokeAtAvailableNsAsync$4(String, RemoteMethod, Class)80%n/a112211
lambda$initAsyncHandlerThreadPools4Ns$1(int, String)80%n/a111111
static {...}80%n/a113311
getBlockLocations(String, long, long)70%n/a111111
append(String, String, EnumSetWritable)70%n/a111111
setOwner(String, String, String)70%n/a112211
rename2(String, String, Options.Rename[])70%n/a112211
truncate(String, long, String)70%n/a111111
mkdirs(String, FsPermission, boolean)70%n/a111111
getListing(String, byte[], boolean)70%n/a111111
setTimes(String, long, long)70%n/a112211
renameSnapshot(String, String, String)70%n/a112211
getSnapshotDiffReport(String, String, String)70%n/a111111
setXAttr(String, XAttr, EnumSet)70%n/a112211
listOpenFiles(long, EnumSet, String)70%n/a111111
errorReport(NamenodeRegistration, int, String)70%n/a112211
refreshFairnessPolicyController()70%n/a111111
recoverLease(String, String)60%n/a111111
setReplication(String, short)60%n/a111111
setStoragePolicy(String, String)60%n/a112211
setPermission(String, FsPermission)60%n/a112211
updateBlockForPipeline(ExtendedBlock, String)60%n/a111111
rename(String, String)60%n/a111111
concat(String, String[])60%n/a112211
delete(String, boolean)60%n/a111111
renewLease(String, List)60%n/a112211
getLocatedFileInfo(String, boolean)60%n/a111111
getDatanodeStorageReportMap(HdfsConstants.DatanodeReportType)60%n/a111111
getDatanodeStorageReportMapAsync(HdfsConstants.DatanodeReportType)60%n/a111111
setSafeMode(HdfsConstants.SafeModeAction, boolean)60%n/a111111
saveNamespace(long, long)60%n/a111111
listCorruptFileBlocks(String, String)60%n/a111111
addCacheDirective(CacheDirectiveInfo, EnumSet)60%n/a111111
modifyCacheDirective(CacheDirectiveInfo, EnumSet)60%n/a112211
listCacheDirectives(long, CacheDirectiveInfo)60%n/a111111
modifyAclEntries(String, List)60%n/a112211
removeAclEntries(String, List)60%n/a112211
setAcl(String, List)60%n/a112211
createEncryptionZone(String, String)60%n/a112211
reencryptEncryptionZone(String, HdfsConstants.ReencryptAction)60%n/a112211
getXAttrs(String, List)60%n/a111111
removeXAttr(String, XAttr)60%n/a112211
checkAccess(String, FsAction)60%n/a112211
createSnapshot(String, String)60%n/a111111
deleteSnapshot(String, String)60%n/a112211
setErasureCodingPolicy(String, String)60%n/a112211
endCheckpoint(NamenodeRegistration, CheckpointSignature)60%n/a112211
getLocationsForPath(String, boolean)60%n/a111111
lambda$invokeOnNsAsync$11(IOException, Object)60%20%223311
getDelegationToken(Text)50%n/a111111
renewDelegationToken(Token)50%n/a111111
cancelDelegationToken(Token)50%n/a112211
getPreferredBlockSize(String)50%n/a111111
getFileInfo(String)50%n/a111111
isFileClosed(String)50%n/a111111
getFileLinkInfo(String)50%n/a111111
getDatanodeReport(HdfsConstants.DatanodeReportType)50%n/a111111
getDatanodeStorageReport(HdfsConstants.DatanodeReportType)50%n/a111111
restoreFailedStorage(String)50%n/a111111
rollingUpgrade(HdfsConstants.RollingUpgradeAction)50%n/a111111
metaSave(String)50%n/a112211
setBalancerBandwidth(long)50%n/a112211
getContentSummary(String)50%n/a111111
getLinkTarget(String)50%n/a111111
allowSnapshot(String)50%n/a112211
disallowSnapshot(String)50%n/a112211
getSnapshotListing(String)50%n/a111111
removeCacheDirective(long)50%n/a112211
addCachePool(CachePoolInfo)50%n/a112211
modifyCachePool(CachePoolInfo)50%n/a112211
removeCachePool(String)50%n/a112211
listCachePools(String)50%n/a111111
removeDefaultAcl(String)50%n/a112211
removeAcl(String)50%n/a112211
getAclStatus(String)50%n/a111111
getEZForPath(String)50%n/a111111
listEncryptionZones(long)50%n/a111111
listReencryptionStatus(long)50%n/a111111
listXAttrs(String)50%n/a111111
getEditsFromTxid(long)50%n/a111111
getQuotaUsage(String)50%n/a111111
reportBadBlocks(LocatedBlock[])50%n/a112211
unsetStoragePolicy(String)50%n/a112211
getStoragePolicy(String)50%n/a111111
addErasureCodingPolicies(ErasureCodingPolicy[])50%n/a111111
removeErasureCodingPolicy(String)50%n/a112211
disableErasureCodingPolicy(String)50%n/a112211
enableErasureCodingPolicy(String)50%n/a112211
getErasureCodingPolicy(String)50%n/a111111
unsetErasureCodingPolicy(String)50%n/a112211
getECTopologyResultForPolicies(String[])50%n/a111111
listOpenFiles(long)50%n/a111111
satisfyStoragePolicy(String)50%n/a112211
getEnclosingRoot(String)50%n/a111111
getMostRecentNameNodeFileTxId(NNStorage.NameNodeFile)50%n/a111111
registerSubordinateNamenode(NamenodeRegistration)50%n/a111111
startCheckpoint(NamenodeRegistration)50%n/a111111
getEditLogManifest(long)50%n/a111111
getGroupsForUser(String)50%n/a111111
lambda$invokeAtAvailableNsAsync$5(String, FederationNamespaceInfo)50%n/a111111
lambda$invokeAtAvailableNs$3(String, FederationNamespaceInfo)50%n/a111111
getServerDefaults()40%n/a111111
getStoragePolicies()40%n/a111111
getBatchedListing(String[], byte[], boolean)40%n/a111111
getStats()40%n/a111111
rollEdits()40%n/a111111
refreshNodes()40%n/a112211
finalizeUpgrade()40%n/a112211
upgradeStatus()40%n/a111111
getSnapshottableDirListing()40%n/a111111
getCurrentEditLogTxid()40%n/a111111
getDataEncryptionKey()40%n/a111111
getErasureCodingPolicies()40%n/a111111
getErasureCodingCodecs()40%n/a111111
getECBlockGroupStats()40%n/a111111
getReplicatedBlockStats()40%n/a111111
getHAServiceState()40%n/a111111
msync()40%n/a112211
getSlowDatanodeReport()40%n/a111111
getBlockKeys()40%n/a111111
getTransactionID()40%n/a111111
getMostRecentCheckpointTxId()40%n/a111111
rollEditLog()40%n/a111111
versionRequest()40%n/a111111
isUpgradeFinalized()40%n/a111111
isRollingUpgrade()40%n/a111111
getNextSPSPath()40%n/a111111
setCurrentUser(UserGroupInformation)40%n/a112211
resetCurrentUser()40%n/a112211
getRPCMetrics()40%n/a111111
refreshUserToGroupsMappings()40%n/a112211
refreshSuperUserGroupsConfiguration()40%n/a112211
getRouterFederationRenameCount()40%n/a111111
getFedRenameScheduler()0%n/a111111
getRouterStateIdContext()0%n/a111111
getRouterSecurityManager()0%n/a111111
getRPCClient()0%n/a111111
getSubclusterResolver()0%n/a111111
getNamenodeResolver()0%n/a111111
getRPCMonitor()0%n/a111111
getServer()0%n/a111111
getRpcAddress()0%n/a111111
getQuotaModule()0%n/a111111
getClientProtocolModule()0%n/a111111
isAsync()0%n/a111111
getAsyncRouterHandlerExecutors()0%n/a111111
getRouterAsyncHandlerDefaultExecutor()0%n/a111111
lambda$getCreateLocationAsync$14(RemoteLocation, Object, FileNotFoundException)0%n/a111111