RouterRpcServer

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,341 of 2,3410%143 of 1430%257257551551185185
RouterRpcServer(Configuration, Router, ActiveNamenodeResolver, FileSubclusterResolver)3720%40%33737311
getLocationsForPath(String, boolean, boolean)1650%300%1616464611
initRouterFedRename()1060%70%55252511
updateDnMap(Map, Map)770%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
getCreateLocation(String, List)440%80%55111111
merge(Map, Class)420%60%447711
getSlowDatanodeReport(boolean, long)380%n/a119911
checkSafeMode()350%40%336611
clearStaleNamespacesInRouterStateIdContext()300%20%22111111
checkOperation(NameNode.OperationCategory)290%80%55101011
checkOperation(NameNode.OperationCategory, boolean)280%40%337711
serviceStop()270%80%55101011
getCachedDatanodeReport(HdfsConstants.DatanodeReportType)260%20%227711
serviceInit(Configuration)230%20%226611
isInvokeConcurrent(String)220%40%337711
getCachedDatanodeReportImpl(HdfsConstants.DatanodeReportType)200%n/a116611
getMountTable(String)190%20%226611
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
addBlock(String, String, ExtendedBlock, DatanodeInfo[], long, String[], EnumSet)110%n/a111111
getMethodName()100%n/a113311
getCreateLocation(String)100%n/a112211
getSchedulerJobCount()100%20%223311
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$1(Set, String)90%20%223311
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
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
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
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$invokeAtAvailableNs$2(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