DatanodeManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,752 of 3,7520%472 of 4720%354354911911118118
handleHeartbeat(DatanodeRegistration, StorageReport[], String, long, long, int, int, int, VolumeFailureSummary, SlowPeerReports, SlowDiskReports)3700%540%2828777711
DatanodeManager(BlockManager, Namesystem, Configuration)3600%160%99727211
registerDatanode(DatanodeRegistration)3230%360%1919929211
getBlockRecoveryCommand(String, DatanodeDescriptor)2320%360%1919484811
getDatanodeListForReport(HdfsConstants.DatanodeReportType)2220%560%2929393911
sortLocatedBlock(LocatedBlock, String, Comparator)1160%180%1010313111
getDatanodeStorageInfos(DatanodeID[], String[], String, Object[])790%140%88181811
sortLocatedStripedBlock(LocatedBlock, Comparator)780%40%33131311
getDatanodeDescriptor(String)780%160%99242411
refreshDatanodes()750%80%55171711
parseDNFromHostsEntry(String)640%40%33151511
getStaleIntervalFromConf(Configuration, long)530%60%44101011
countSoftwareVersions()520%60%44101011
fetchDatanodes(List, List, boolean)520%180%1010171711
addCacheCommands(String, DatanodeDescriptor, List)510%100%66171711
markAllDatanodesStaleAndSetKeyUpdateIfNeed()500%60%44101011
sortLocatedBlocks(String, List)460%80%559911
addDatanode(DatanodeDescriptor)440%20%22111111
resolveNetworkLocation(DatanodeID)430%40%33111111
removeDatanode(DatanodeDescriptor, boolean)420%60%44101011
wipeDatanode(DatanodeID)420%20%228811
checkIfClusterIsNowMultiRack(DatanodeDescriptor)420%100%66121211
getDnDescriptorsFromIpAddr(List)420%80%55111111
getDatanodeStorageReport(HdfsConstants.DatanodeReportType)400%20%229911
decrementVersionCount(String)390%60%44101011
getCacheCommand(DatanodeDescriptor.CachedBlocksList, int, String)360%40%339911
datanodeDump(PrintWriter)350%20%228811
setBlockInvalidateLimit(int)340%n/a116611
incrementVersionCount(String)330%40%338811
getDatanode(DatanodeID)300%40%339911
getNetworkDependencies(DatanodeInfo)290%40%33111111
getNumLiveDataNodes()290%40%338811
handleLifeline(DatanodeRegistration, StorageReport[], long, long, int, int, VolumeFailureSummary)290%60%448811
clearPendingCachingCommands()270%20%227711
startAdminOperationIfNecessary(DatanodeDescriptor)260%40%337711
initSlowPeerTracker(Configuration, Timer, boolean)250%40%337711
removeDatanode(DatanodeID)250%20%227711
stopSlowPeerCollector()240%20%22101011
removeDeadDatanode(DatanodeID, boolean)240%40%338811
setBalancerBandwidth(long)240%20%226611
resetLastCachingDirectiveSentTime()240%20%226611
startSlowPeerCollector()230%20%227711
createSecondaryNodeSorter()230%40%33101011
clearPendingQueues()230%20%226611
setHeartbeatInterval(long, int)230%n/a115511
getSlowPeersUuidSet()230%n/a116611
restartSlowPeerCollector(long)220%20%227711
shouldAvoidStaleDataNodesForWrite()220%60%442211
isInactive(DatanodeInfo)210%100%664411
getAllSlowDataNodes()190%20%225511
removeDecomNodeFromList(List)170%40%336611
refreshNodes(Configuration)170%n/a116611
isNameResolved(InetAddress)170%40%333311
getDatanodes()160%n/a114411
getDatanode(String)160%20%224411
lambda$createSecondaryNodeSorter$0(StorageType, StorageType)160%60%445511
resolveNetworkLocationWithFallBackToDefaultLocation(DatanodeID)150%n/a117711
getNetworkDependenciesWithDefault(DatanodeInfo)150%n/a117711
resolveUpgradeDomain(DatanodeDescriptor)140%40%334411
refreshHostsReader(Configuration)140%20%225511
static {...}130%20%223311
isDatanodeDead(DatanodeDescriptor)120%20%222211
getDatanodesSoftwareVersions()120%n/a112211
isSlowNode(String)110%40%331111
shouldCountVersion(DatanodeDescriptor)100%40%331111
getNumOfDataNodes()100%n/a112211
setMaxSlowPeersToReport(int)100%n/a113311
close()90%n/a114411
getSlowPeersReport()90%n/a112211
getSlowDisksReport()90%20%222211
activate(Configuration)80%n/a113311
setDatanodeDead(DatanodeDescriptor)70%n/a113311
toString()70%n/a111111
isSlowPeerCollectorInitialized()70%20%221111
getDatanodeByXferAddr(String, int)60%n/a111111
setHeartbeatInterval(long)60%n/a112211
setHeartbeatRecheckInterval(int)60%n/a112211
getBlockInvalidateLimitFromHBInterval()60%n/a111111
lambda$getSlowPeersUuidSet$3(Set, DatanodeDescriptor)60%n/a111111
getDatanodeByHost(String)50%n/a111111
getDatanodeByHostName(String)50%n/a111111
removeDatanode(DatanodeDescriptor)50%n/a112211
resolveNetworkLocation(List)50%n/a111111
getNumDeadDataNodes()50%n/a111111
newFSClusterStats()50%n/a111111
getBlockInvalidateLimit(int)50%n/a111111
addSlowPeers(String)50%n/a112211
setHeartbeatExpireInterval(long)40%n/a112211
setAvoidSlowDataNodesForReadEnabled(boolean)40%n/a112211
setMaxSlowpeerCollectNodes(int)40%n/a112211
getDecommissioningNodes()40%n/a111111
getEnteringMaintenanceNodes()40%n/a111111
getHeartbeatRecheckInterval()40%n/a111111
setNumStaleNodes(int)40%n/a112211
setNumStaleStorages(int)40%n/a112211
setShouldSendCachingCommands(boolean)40%n/a112211
lambda$createSecondaryNodeSorter$2(Comparator, List)40%n/a111111
lambda$createSecondaryNodeSorter$1(Comparator, List)40%n/a111111
getNetworkTopology()0%n/a111111
getHeartbeatManager()0%n/a111111
getDatanodeAdminManager()0%n/a111111
getHostConfigManager()0%n/a111111
getFSClusterStats()0%n/a111111
getBlockInvalidateLimit()0%n/a111111
getDatanodeStatistics()0%n/a111111
getEnableAvoidSlowDataNodesForRead()0%n/a111111
getMaxSlowpeerCollectNodes()0%n/a111111
getHost2DatanodeMap()0%n/a111111
getBlocksPerPostponedMisreplicatedBlocksRescan()0%n/a111111
getStaleInterval()0%n/a111111
getHeartbeatInterval()0%n/a111111
getNumStaleNodes()0%n/a111111
getNumStaleStorages()0%n/a111111
getSlowPeerTracker()0%n/a111111
getSlowDiskTracker()0%n/a111111
getDatanodeMap()0%n/a111111
getSlowPeerCollectionInterval()0%n/a111111
getSlowNodesUuidSet()0%n/a111111