DataNode

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total6,860 of 6,8600%714 of 7140%5715711,6881,688209209
shutdown()3170%560%292910310311
DataNode(Configuration, List, StorageLocationChecker, SecureDataNodeStarter.SecureResources)2980%100%66777711
startDataNode(List, SecureDataNodeStarter.SecureResources)2650%160%99505011
refreshVolumes(String)2510%180%1010606011
reconfigurePropertyImpl(String, String)2110%230%1717474711
reconfSlowDiskParameters(String, String)2090%360%1919505011
reconfDfsUsageParameters(String, String)1960%280%1515454511
parseChangedVolumes(String)1880%260%1414515111
transferReplicaForPipelineRecovery(ExtendedBlock, DatanodeInfo[], StorageType[], String[], String)1640%120%77323211
reconfDataXceiverParameters(String, String)1630%220%1212424211
DataNode(Configuration)1600%20%22444411
reconfSlowPeerParameters(String, String)1540%240%1313363611
transferBlock(ExtendedBlock, DatanodeInfo[], StorageType[], String[])1520%100%66393911
static {...}1310%20%22101011
reconfBlockReportParameters(String, String)1280%180%1010303011
initDataXceiver()1210%100%66252511
reconfDiskBalancerParameters(String, String)1000%140%88242411
initIpcServer()990%20%22272711
validateVolumesWithSameDiskTiering(DataNode.ChangedVolumes)960%140%88171711
initStorage(NamespaceInfo)950%60%44202011
registerBlockPoolWithSecretManager(DatanodeRegistration, String)850%80%55171711
getVolumeReport()810%40%33191911
removeVolumes(Collection, boolean)720%80%55202011
requestShortCircuitFdsForRead(ExtendedBlock, Token, int)680%40%33151511
handleVolumeFailures(Set)670%40%33181811
checkSecureConfig(DNConf, Configuration, SecureDataNodeStarter.SecureResources)650%240%1313212111
initBlockPool(BPOfferService)620%20%22151511
getDomainPeerServer(Configuration, int)600%100%66151511
parseArguments(String[], Configuration)580%160%99141411
checkReadAccess(ExtendedBlock)550%60%44151511
createBPRegistration(NamespaceInfo)510%20%22111111
handleDiskError(String, int)510%60%44151511
isDatanodeFullyStarted(boolean)510%160%99111111
handleBadBlock(ExtendedBlock, IOException, boolean)510%140%88151511
triggerBlockReport(BlockReportOptions)490%120%77111111
startPlugins(Configuration)460%20%22141411
getBlockLocalPathInfo(ExtendedBlock, Token)460%20%22101011
initDirectoryScanner(Configuration)450%80%55121211
checkFileSystemWithConfigured(Configuration, StorageLocation)450%80%55101011
reconfCacheReportParameters(String, String)430%20%22101011
reconfSlowIoWarningThresholdParameters(String, String)430%20%22111111
getStorageLocations(Configuration)430%40%33151511
startInfoServer()420%60%449911
makeInstance(Collection, Configuration, SecureDataNodeStarter.SecureResources)420%40%338811
getNamenodeAddresses()420%60%449911
instantiateDataNode(String[], Configuration, SecureDataNodeStarter.SecureResources)410%60%44131311
initOOBTimeout()400%40%339911
checkDiskError()390%20%22121211
getBPServiceActorInfoMap()380%60%448811
checkSuperuserPrivilege()370%120%77111111
reportCorruptedBlocks(DFSUtilClient.CorruptedBlocks)370%60%449911
updateReplicaUnderRecovery(ExtendedBlock, long, long, long)370%n/a11101011
getHostName(Configuration)360%40%33111111
transferBlocks(String, Block[], DatanodeInfo[][], StorageType[][], String[][])360%20%226611
startMetricsLogger()360%20%227711
checkBlockToken(ExtendedBlock, Token, BlockTokenIdentifier.AccessMode)350%20%228811
bpRegistrationSucceeded(DatanodeRegistration, String)340%20%227711
isConnectedToNN(InetSocketAddress)340%60%447711
setClusterId(String, String)330%40%334411
shutdownBlockPool(BPOfferService)330%80%55101011
runDatanodeDaemon()330%40%33101011
join()330%40%33111111
shutdownDatanode(boolean)330%20%22111111
createInterDataNodeProtocolProxy(DatanodeID, Configuration, int, boolean)320%n/a118811
secureMain(String[], SecureDataNodeStarter.SecureResources)320%20%22121211
getDiskBalancerSetting(String)320%30%337711
deleteBlockPool(String, boolean)310%20%229911
toString()290%n/a113311
checkBlockLocalPathAccess()280%20%225511
getOOBTimeout(DataTransferProtos.Status)280%40%334411
getDNRegistrationForBP(String)270%40%335511
getBPOSForBlock(ExtendedBlock)260%20%226611
notifyNamenodeDeletedBlock(ExtendedBlock, String)250%20%226611
reportBadBlock(BPOfferService, ExtendedBlock, String)230%20%228811
checkKerberosAuthMethod(String)220%40%335511
submitDiskBalancerPlan(String, long, String, String, boolean)220%20%225511
notifyNamenodeReceivedBlock(ExtendedBlock, String, String, boolean)210%20%226611
checkStorageState(String)210%20%225511
lambda$checkDiskErrorAsync$0(Set, Set)210%20%227711
getECN()200%40%336611
initDiskBalancer(FsDatasetSpi, Configuration)200%20%225511
isDatanodeUp()200%40%335511
getEffectiveFileSystem(String, Configuration)200%n/a115511
notifyNamenodeReceivingBlock(ExtendedBlock, String)190%20%226611
incrDatanodeNetworkErrors(String)190%n/a116611
checkDatanodeUuid()180%20%226611
reportBadBlocks(ExtendedBlock)170%20%226611
handleAddBlockPoolError(AddBlockPoolException)170%40%336611
getActiveTransferThreadCount()170%20%225511
scheduleAllBlockReport(long)170%20%224411
getSlowDisks()170%40%334411
connectToDN(DatanodeInfo, int, ExtendedBlock, Token)160%n/a113311
getBlockAccessToken(ExtendedBlock, EnumSet, StorageType[], String[])150%20%224411
decrementXmitsInProgress(int)140%20%223311
getSLOWByBlockPoolId(String)130%40%334411
getDisplayName()130%n/a111111
getVolumeInfo()130%20%224411
getDatanodeInfo()130%n/a112211
getSendPacketDownstreamAvgInfo()130%40%332211
reportBadBlocks(ExtendedBlock, FsVolumeSpi)120%n/a114411
incrementXmitsInProcess(int)120%20%223311
main(String[])120%20%224411
getDiskBalancerStatus()120%n/a114411
refreshNamenodes()120%n/a114411
isBPServiceAlive(String)120%20%222211
createDataNode(String[], Configuration, SecureDataNodeStarter.SecureResources)110%20%224411
getVersion()110%n/a111111
getDiskBalancer()110%20%223311
createTracer(Configuration)100%n/a113311
shutdownDiskBalancer()100%20%224411
closeBlock(ExtendedBlock, String, String, boolean)100%n/a113311
getRpcPort()100%n/a113311
getDataPort()100%n/a113311
stopMetricsLogger()100%20%224411
isTransfer(BlockConstructionStage, String)100%40%333311
isWrite(BlockConstructionStage)100%40%331111
lambda$incrDatanodeNetworkErrors$1(String, Long)100%20%221111
removeVolumes(Collection)90%20%224411
reportRemoteBadBlock(DatanodeInfo, ExtendedBlock)90%n/a113311
getXceiverCount()90%20%223311
getStartupOption(Configuration)90%n/a113311
evictWriters()90%n/a114411
getBalancerBandwidth()90%n/a113311
getDatanodeUuid()90%20%221111
checkDiskErrorAsync(FsVolumeSpi)80%n/a112211
initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock)80%n/a112211
getReplicaVisibleLength(ExtendedBlock)80%n/a112211
shutdownDirectoryScanner()70%20%223311
registerMXBean()70%n/a112211
connectToNN(InetSocketAddress)70%n/a111111
connectToLifelineNN(InetSocketAddress)70%n/a112211
cancelDiskBalancePlan(String)70%n/a113311
shutdownPeriodicScanners()60%n/a113311
getInfoAddr(Configuration)60%n/a111111
getDataEncryptionKeyFactoryForBlock(ExtendedBlock)60%n/a111111
setStartupOption(Configuration, HdfsServerConstants.StartupOption)60%n/a112211
getStreamingAddr(Configuration)60%n/a112211
queryDiskBalancerPlan()60%n/a112211
getBPOfferService(String)50%n/a111111
getBpOsCount()50%n/a111111
getIpcPort()50%n/a111111
incrementXmitsInProgress()50%n/a112211
decrementXmitsInProgress()50%n/a112211
instantiateDataNode(String[], Configuration)50%n/a111111
createDataNode(String[], Configuration)50%n/a111111
finalizeUpgradeForPool(String)50%n/a112211
refreshNamenodes(Configuration)50%n/a112211
startReconfiguration()50%n/a113311
getReconfigurationStatus()50%n/a112211
isSlownodeByBlockPoolId(String)50%n/a111111
getNewConf()40%n/a111111
setHeartbeatsDisabledForTests(boolean)40%n/a112211
setIBRDisabledForTest(boolean)40%n/a112211
setCacheReportsDisabledForTest(boolean)40%n/a112211
getAllBpOs()40%n/a111111
getXferPort()40%n/a111111
newSocket()40%n/a111111
getDatanodeNetworkCounts()40%n/a111111
getXmitsInProgress()40%n/a111111
printUsage(PrintStream)40%n/a112211
getHttpPort()40%n/a111111
getBPServiceActorInfo()40%n/a111111
listReconfigurableProperties()40%n/a112211
isDatanodeFullyStarted()40%n/a111111
clearAllBlockSecretKeys()40%n/a112211
setBlockScanner(BlockScanner)40%n/a112211
isSlownode()40%n/a111111
createSocketAddr(String)30%n/a111111
getFileIoProvider()30%n/a111111
areHeartbeatsDisabledForTests()30%n/a111111
areIBRDisabledForTests()30%n/a111111
areCacheReportsDisabledForTests()30%n/a111111
generateUuid()30%n/a111111
getSaslClient()30%n/a111111
getXferServer()30%n/a111111
getSaslServer()30%n/a111111
getXferAddress()30%n/a111111
getMetrics()30%n/a111111
getDiskMetrics()30%n/a111111
getPeerMetrics()30%n/a111111
getMaxNumberOfBlocksToLog()30%n/a111111
getFSDataset()30%n/a111111
getBlockScanner()30%n/a111111
getDirectoryScanner()30%n/a111111
getBlockPoolTokenSecretManager()30%n/a111111
getDNStartedTimeInMillis()30%n/a111111
getInfoPort()30%n/a111111
getInfoSecurePort()30%n/a111111
getDatanodeHostname()30%n/a111111
getClusterId()30%n/a111111
isRestarting()30%n/a111111
getDatanodeId()30%n/a111111
getDnConf()30%n/a111111
shouldRun()30%n/a111111
getStorage()30%n/a111111
getShortCircuitRegistry()30%n/a111111
getEcReconstuctReadThrottler()30%n/a111111
getEcReconstuctWriteThrottler()30%n/a111111
getLastDiskErrorCheck()30%n/a111111
getBlockRecoveryWorker()30%n/a111111
getErasureCodingWorker()30%n/a111111
getMetricsLoggerTimer()30%n/a111111
getTracer()30%n/a111111
getDataSetLockManager()30%n/a111111
getBlockPoolManager()30%n/a111111
getReconfigurableProperties()0%n/a111111
getSoftwareVersion()0%n/a111111
getRevision()0%n/a111111
isSecurityEnabled()0%n/a111111