DataNode

Element	Missed Instructions	Cov.	Missed Branches	Cov.	Missed	Cxty	Missed	Lines	Missed	Methods
Total	6,633 of 6,633	0%	714 of 714	0%	571	571	1,688	1,688	209	209
shutdown()		0%		0%	29	29	103	103	1	1
DataNode(Configuration, List, StorageLocationChecker, SecureDataNodeStarter.SecureResources)		0%		0%	6	6	77	77	1	1
startDataNode(List, SecureDataNodeStarter.SecureResources)		0%		0%	9	9	50	50	1	1
refreshVolumes(String)		0%		0%	10	10	60	60	1	1
reconfigurePropertyImpl(String, String)		0%		0%	17	17	47	47	1	1
reconfSlowDiskParameters(String, String)		0%		0%	19	19	50	50	1	1
reconfDfsUsageParameters(String, String)		0%		0%	15	15	45	45	1	1
parseChangedVolumes(String)		0%		0%	14	14	51	51	1	1
reconfDataXceiverParameters(String, String)		0%		0%	12	12	42	42	1	1
DataNode(Configuration)		0%		0%	2	2	44	44	1	1
reconfSlowPeerParameters(String, String)		0%		0%	13	13	36	36	1	1
transferReplicaForPipelineRecovery(ExtendedBlock, DatanodeInfo[], StorageType[], String[], String)		0%		0%	7	7	32	32	1	1
transferBlock(ExtendedBlock, DatanodeInfo[], StorageType[], String[])		0%		0%	6	6	39	39	1	1
reconfBlockReportParameters(String, String)		0%		0%	10	10	30	30	1	1
static {...}		0%		0%	2	2	10	10	1	1
initDataXceiver()		0%		0%	6	6	25	25	1	1
initIpcServer()		0%		0%	2	2	27	27	1	1
initStorage(NamespaceInfo)		0%		0%	4	4	20	20	1	1
reconfDiskBalancerParameters(String, String)		0%		0%	8	8	24	24	1	1
registerBlockPoolWithSecretManager(DatanodeRegistration, String)		0%		0%	5	5	17	17	1	1
getVolumeReport()		0%		0%	3	3	19	19	1	1
validateVolumesWithSameDiskTiering(DataNode.ChangedVolumes)		0%		0%	8	8	17	17	1	1
removeVolumes(Collection, boolean)		0%		0%	5	5	20	20	1	1
handleVolumeFailures(Set)		0%		0%	3	3	18	18	1	1
checkSecureConfig(DNConf, Configuration, SecureDataNodeStarter.SecureResources)		0%		0%	13	13	21	21	1	1
requestShortCircuitFdsForRead(ExtendedBlock, Token, int)		0%		0%	3	3	15	15	1	1
parseArguments(String[], Configuration)		0%		0%	9	9	14	14	1	1
initBlockPool(BPOfferService)		0%		0%	2	2	15	15	1	1
checkReadAccess(ExtendedBlock)		0%		0%	4	4	15	15	1	1
getDomainPeerServer(Configuration, int)		0%		0%	6	6	15	15	1	1
createBPRegistration(NamespaceInfo)		0%		0%	2	2	11	11	1	1
handleDiskError(String, int)		0%		0%	4	4	15	15	1	1
isDatanodeFullyStarted(boolean)		0%		0%	9	9	11	11	1	1
handleBadBlock(ExtendedBlock, IOException, boolean)		0%		0%	8	8	15	15	1	1
triggerBlockReport(BlockReportOptions)		0%		0%	7	7	11	11	1	1
startPlugins(Configuration)		0%		0%	2	2	14	14	1	1
getBlockLocalPathInfo(ExtendedBlock, Token)		0%		0%	2	2	10	10	1	1
initDirectoryScanner(Configuration)		0%		0%	5	5	12	12	1	1
checkFileSystemWithConfigured(Configuration, StorageLocation)		0%		0%	5	5	10	10	1	1
reconfCacheReportParameters(String, String)		0%		0%	2	2	10	10	1	1
reconfSlowIoWarningThresholdParameters(String, String)		0%		0%	2	2	11	11	1	1
getStorageLocations(Configuration)		0%		0%	3	3	15	15	1	1
startInfoServer()		0%		0%	4	4	9	9	1	1
makeInstance(Collection, Configuration, SecureDataNodeStarter.SecureResources)		0%		0%	3	3	8	8	1	1
getNamenodeAddresses()		0%		0%	4	4	9	9	1	1
instantiateDataNode(String[], Configuration, SecureDataNodeStarter.SecureResources)		0%		0%	4	4	13	13	1	1
initOOBTimeout()		0%		0%	3	3	9	9	1	1
checkDiskError()		0%		0%	2	2	12	12	1	1
getBPServiceActorInfoMap()		0%		0%	4	4	8	8	1	1
checkSuperuserPrivilege()		0%		0%	7	7	11	11	1	1
reportCorruptedBlocks(DFSUtilClient.CorruptedBlocks)		0%		0%	4	4	9	9	1	1
updateReplicaUnderRecovery(ExtendedBlock, long, long, long)		0%		n/a	1	1	10	10	1	1
getHostName(Configuration)		0%		0%	3	3	11	11	1	1
transferBlocks(String, Block[], DatanodeInfo[][], StorageType[][], String[][])		0%		0%	2	2	6	6	1	1
startMetricsLogger()		0%		0%	2	2	7	7	1	1
checkBlockToken(ExtendedBlock, Token, BlockTokenIdentifier.AccessMode)		0%		0%	2	2	8	8	1	1
isConnectedToNN(InetSocketAddress)		0%		0%	4	4	7	7	1	1
shutdownBlockPool(BPOfferService)		0%		0%	5	5	10	10	1	1
runDatanodeDaemon()		0%		0%	3	3	10	10	1	1
join()		0%		0%	3	3	11	11	1	1
shutdownDatanode(boolean)		0%		0%	2	2	11	11	1	1
createInterDataNodeProtocolProxy(DatanodeID, Configuration, int, boolean)		0%		n/a	1	1	8	8	1	1
secureMain(String[], SecureDataNodeStarter.SecureResources)		0%		0%	2	2	12	12	1	1
getDiskBalancerSetting(String)		0%		0%	3	3	7	7	1	1
deleteBlockPool(String, boolean)		0%		0%	2	2	9	9	1	1
bpRegistrationSucceeded(DatanodeRegistration, String)		0%		0%	2	2	7	7	1	1
reportBadBlock(BPOfferService, ExtendedBlock, String)		0%		0%	2	2	8	8	1	1
getOOBTimeout(DataTransferProtos.Status)		0%		0%	3	3	4	4	1	1
submitDiskBalancerPlan(String, long, String, String, boolean)		0%		0%	2	2	5	5	1	1
setClusterId(String, String)		0%		0%	3	3	4	4	1	1
notifyNamenodeReceivedBlock(ExtendedBlock, String, String, boolean)		0%		0%	2	2	6	6	1	1
getDNRegistrationForBP(String)		0%		0%	3	3	5	5	1	1
lambda$checkDiskErrorAsync$0(Set, Set)		0%		0%	2	2	7	7	1	1
getECN()		0%		0%	3	3	6	6	1	1
initDiskBalancer(FsDatasetSpi, Configuration)		0%		0%	2	2	5	5	1	1
getBPOSForBlock(ExtendedBlock)		0%		0%	2	2	6	6	1	1
isDatanodeUp()		0%		0%	3	3	5	5	1	1
getEffectiveFileSystem(String, Configuration)		0%		n/a	1	1	5	5	1	1
notifyNamenodeReceivingBlock(ExtendedBlock, String)		0%		0%	2	2	6	6	1	1
notifyNamenodeDeletedBlock(ExtendedBlock, String)		0%		0%	2	2	6	6	1	1
incrDatanodeNetworkErrors(String)		0%		n/a	1	1	6	6	1	1
checkDatanodeUuid()		0%		0%	2	2	6	6	1	1
checkBlockLocalPathAccess()		0%		0%	2	2	5	5	1	1
reportBadBlocks(ExtendedBlock)		0%		0%	2	2	6	6	1	1
handleAddBlockPoolError(AddBlockPoolException)		0%		0%	3	3	6	6	1	1
getActiveTransferThreadCount()		0%		0%	2	2	5	5	1	1
scheduleAllBlockReport(long)		0%		0%	2	2	4	4	1	1
getSlowDisks()		0%		0%	3	3	4	4	1	1
connectToDN(DatanodeInfo, int, ExtendedBlock, Token)		0%		n/a	1	1	3	3	1	1
getBlockAccessToken(ExtendedBlock, EnumSet, StorageType[], String[])		0%		0%	2	2	4	4	1	1
checkStorageState(String)		0%		0%	2	2	5	5	1	1
checkKerberosAuthMethod(String)		0%		0%	3	3	5	5	1	1
decrementXmitsInProgress(int)		0%		0%	2	2	3	3	1	1
getSLOWByBlockPoolId(String)		0%		0%	3	3	4	4	1	1
toString()		0%		n/a	1	1	3	3	1	1
getVolumeInfo()		0%		0%	2	2	4	4	1	1
getDatanodeInfo()		0%		n/a	1	1	2	2	1	1
getSendPacketDownstreamAvgInfo()		0%		0%	3	3	2	2	1	1
reportBadBlocks(ExtendedBlock, FsVolumeSpi)		0%		n/a	1	1	4	4	1	1
incrementXmitsInProcess(int)		0%		0%	2	2	3	3	1	1
main(String[])		0%		0%	2	2	4	4	1	1
getDiskBalancerStatus()		0%		n/a	1	1	4	4	1	1
refreshNamenodes()		0%		n/a	1	1	4	4	1	1
isBPServiceAlive(String)		0%		0%	2	2	2	2	1	1
createDataNode(String[], Configuration, SecureDataNodeStarter.SecureResources)		0%		0%	2	2	4	4	1	1
getDiskBalancer()		0%		0%	2	2	3	3	1	1
createTracer(Configuration)		0%		n/a	1	1	3	3	1	1
shutdownDiskBalancer()		0%		0%	2	2	4	4	1	1
closeBlock(ExtendedBlock, String, String, boolean)		0%		n/a	1	1	3	3	1	1
getRpcPort()		0%		n/a	1	1	3	3	1	1
getDataPort()		0%		n/a	1	1	3	3	1	1
stopMetricsLogger()		0%		0%	2	2	4	4	1	1
isTransfer(BlockConstructionStage, String)		0%		0%	3	3	3	3	1	1
isWrite(BlockConstructionStage)		0%		0%	3	3	1	1	1	1
lambda$incrDatanodeNetworkErrors$1(String, Long)		0%		0%	2	2	1	1	1	1
removeVolumes(Collection)		0%		0%	2	2	4	4	1	1
reportRemoteBadBlock(DatanodeInfo, ExtendedBlock)		0%		n/a	1	1	3	3	1	1
getXceiverCount()		0%		0%	2	2	3	3	1	1
getStartupOption(Configuration)		0%		n/a	1	1	3	3	1	1
evictWriters()		0%		n/a	1	1	4	4	1	1
getBalancerBandwidth()		0%		n/a	1	1	3	3	1	1
getDatanodeUuid()		0%		0%	2	2	1	1	1	1
checkDiskErrorAsync(FsVolumeSpi)		0%		n/a	1	1	2	2	1	1
initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock)		0%		n/a	1	1	2	2	1	1
getReplicaVisibleLength(ExtendedBlock)		0%		n/a	1	1	2	2	1	1
shutdownDirectoryScanner()		0%		0%	2	2	3	3	1	1
registerMXBean()		0%		n/a	1	1	2	2	1	1
connectToNN(InetSocketAddress)		0%		n/a	1	1	1	1	1	1
connectToLifelineNN(InetSocketAddress)		0%		n/a	1	1	2	2	1	1
cancelDiskBalancePlan(String)		0%		n/a	1	1	3	3	1	1
shutdownPeriodicScanners()		0%		n/a	1	1	3	3	1	1
getInfoAddr(Configuration)		0%		n/a	1	1	1	1	1	1
getDisplayName()		0%		n/a	1	1	1	1	1	1
getDataEncryptionKeyFactoryForBlock(ExtendedBlock)		0%		n/a	1	1	1	1	1	1
setStartupOption(Configuration, HdfsServerConstants.StartupOption)		0%		n/a	1	1	2	2	1	1
getStreamingAddr(Configuration)		0%		n/a	1	1	2	2	1	1
queryDiskBalancerPlan()		0%		n/a	1	1	2	2	1	1
getBPOfferService(String)		0%		n/a	1	1	1	1	1	1
getBpOsCount()		0%		n/a	1	1	1	1	1	1
getIpcPort()		0%		n/a	1	1	1	1	1	1
incrementXmitsInProgress()		0%		n/a	1	1	2	2	1	1
decrementXmitsInProgress()		0%		n/a	1	1	2	2	1	1
instantiateDataNode(String[], Configuration)		0%		n/a	1	1	1	1	1	1
createDataNode(String[], Configuration)		0%		n/a	1	1	1	1	1	1
finalizeUpgradeForPool(String)		0%		n/a	1	1	2	2	1	1
refreshNamenodes(Configuration)		0%		n/a	1	1	2	2	1	1
startReconfiguration()		0%		n/a	1	1	3	3	1	1
getReconfigurationStatus()		0%		n/a	1	1	2	2	1	1
isSlownodeByBlockPoolId(String)		0%		n/a	1	1	1	1	1	1
getNewConf()		0%		n/a	1	1	1	1	1	1
setHeartbeatsDisabledForTests(boolean)		0%		n/a	1	1	2	2	1	1
setIBRDisabledForTest(boolean)		0%		n/a	1	1	2	2	1	1
setCacheReportsDisabledForTest(boolean)		0%		n/a	1	1	2	2	1	1
getAllBpOs()		0%		n/a	1	1	1	1	1	1
getXferPort()		0%		n/a	1	1	1	1	1	1
newSocket()		0%		n/a	1	1	1	1	1	1
getDatanodeNetworkCounts()		0%		n/a	1	1	1	1	1	1
getXmitsInProgress()		0%		n/a	1	1	1	1	1	1
printUsage(PrintStream)		0%		n/a	1	1	2	2	1	1
getVersion()		0%		n/a	1	1	1	1	1	1
getHttpPort()		0%		n/a	1	1	1	1	1	1
getBPServiceActorInfo()		0%		n/a	1	1	1	1	1	1
listReconfigurableProperties()		0%		n/a	1	1	2	2	1	1
isDatanodeFullyStarted()		0%		n/a	1	1	1	1	1	1
clearAllBlockSecretKeys()		0%		n/a	1	1	2	2	1	1
setBlockScanner(BlockScanner)		0%		n/a	1	1	2	2	1	1
isSlownode()		0%		n/a	1	1	1	1	1	1
createSocketAddr(String)		0%		n/a	1	1	1	1	1	1
getFileIoProvider()		0%		n/a	1	1	1	1	1	1
areHeartbeatsDisabledForTests()		0%		n/a	1	1	1	1	1	1
areIBRDisabledForTests()		0%		n/a	1	1	1	1	1	1
areCacheReportsDisabledForTests()		0%		n/a	1	1	1	1	1	1
generateUuid()		0%		n/a	1	1	1	1	1	1
getSaslClient()		0%		n/a	1	1	1	1	1	1
getXferServer()		0%		n/a	1	1	1	1	1	1
getSaslServer()		0%		n/a	1	1	1	1	1	1
getXferAddress()		0%		n/a	1	1	1	1	1	1
getMetrics()		0%		n/a	1	1	1	1	1	1
getDiskMetrics()		0%		n/a	1	1	1	1	1	1
getPeerMetrics()		0%		n/a	1	1	1	1	1	1
getMaxNumberOfBlocksToLog()		0%		n/a	1	1	1	1	1	1
getFSDataset()		0%		n/a	1	1	1	1	1	1
getBlockScanner()		0%		n/a	1	1	1	1	1	1
getDirectoryScanner()		0%		n/a	1	1	1	1	1	1
getBlockPoolTokenSecretManager()		0%		n/a	1	1	1	1	1	1
getDNStartedTimeInMillis()		0%		n/a	1	1	1	1	1	1
getInfoPort()		0%		n/a	1	1	1	1	1	1
getInfoSecurePort()		0%		n/a	1	1	1	1	1	1
getDatanodeHostname()		0%		n/a	1	1	1	1	1	1
getClusterId()		0%		n/a	1	1	1	1	1	1
isRestarting()		0%		n/a	1	1	1	1	1	1
getDatanodeId()		0%		n/a	1	1	1	1	1	1
getDnConf()		0%		n/a	1	1	1	1	1	1
shouldRun()		0%		n/a	1	1	1	1	1	1
getStorage()		0%		n/a	1	1	1	1	1	1
getShortCircuitRegistry()		0%		n/a	1	1	1	1	1	1
getEcReconstuctReadThrottler()		0%		n/a	1	1	1	1	1	1
getEcReconstuctWriteThrottler()		0%		n/a	1	1	1	1	1	1
getLastDiskErrorCheck()		0%		n/a	1	1	1	1	1	1
getBlockRecoveryWorker()		0%		n/a	1	1	1	1	1	1
getErasureCodingWorker()		0%		n/a	1	1	1	1	1	1
getMetricsLoggerTimer()		0%		n/a	1	1	1	1	1	1
getTracer()		0%		n/a	1	1	1	1	1	1
getDataSetLockManager()		0%		n/a	1	1	1	1	1	1
getBlockPoolManager()		0%		n/a	1	1	1	1	1	1
getReconfigurableProperties()		0%		n/a	1	1	1	1	1	1
getSoftwareVersion()		0%		n/a	1	1	1	1	1	1
getRevision()		0%		n/a	1	1	1	1	1	1
isSecurityEnabled()		0%		n/a	1	1	1	1	1	1