BlockManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total10,425 of 10,4250%1,390 of 1,3900%9679672,3792,379266266
BlockManager(Namesystem, boolean, Configuration)3610%n/a11777711
addStoredBlock(BlockInfo, Block, DatanodeStorageInfo, DatanodeDescriptor, boolean)3000%460%2424555511
createLocatedBlock(LocatedBlockBuilder, BlockInfo, long)2790%520%2727535311
metaSave(PrintWriter)2670%300%1616686811
scheduleReconstruction(BlockInfo, int)2530%300%1616535311
processReport(DatanodeID, DatanodeStorage, BlockListAsLongs, BlockReportContext)2480%300%1616414111
checkReplicaCorrupt(Block, HdfsServerConstants.ReplicaState, BlockInfo, HdfsServerConstants.BlockUCState, DatanodeDescriptor)2430%340%1919454511
chooseSourceDatanodes(BlockInfo, List, List, NumberReplicas, List, List, List, int)2380%620%3232585811
computeReconstructionWorkForBlocks(List)2360%300%1616505011
chooseExcessRedundancyStriped(BlockCollection, Collection, BlockInfo, DatanodeDescriptor)2360%360%1919585811
processMisReplicatesAsync()2300%230%1515585811
processAndHandleReportedBlock(DatanodeStorageInfo, Block, HdfsServerConstants.ReplicaState, DatanodeDescriptor)2050%200%1111353511
getBlocksWithLocations(DatanodeID, long, long, long, StorageType)1980%360%1919414111
processFirstBlockReport(DatanodeStorageInfo, BlockListAsLongs)1610%300%1616363611
dumpBlockMeta(Block, PrintWriter)1600%280%1515393911
processTimedOutExcessBlocks()1570%240%1313444411
createBlockTokenSecretManager(Configuration)1560%100%66303011
processReportedBlock(DatanodeStorageInfo, Block, HdfsServerConstants.ReplicaState, Collection, Collection, Collection, Collection)1520%220%1212303011
markBlockAsCorrupt(BlockToMarkCorrupt, DatanodeStorageInfo, DatanodeDescriptor)1510%280%1515333311
chooseTarget4NewBlock(String, int, Node, Set, long, List, byte, BlockType, ErasureCodingPolicy, EnumSet)1450%120%77222211
processReport(DatanodeStorageInfo, BlockListAsLongs)1410%140%88282811
convertLastBlockToUnderConstruction(BlockCollection, long)1330%160%99282811
processIncrementalBlockReport(DatanodeDescriptor, StorageReceivedDeletedBlocks)1300%120%88282811
validateReconstructionWork(BlockReconstructionWork)1250%180%1010363611
reportDiff(DatanodeStorageInfo, BlockListAsLongs, Collection, Collection, Collection, Collection, Collection)1250%140%88262611
createLocatedBlocks(BlockInfo[], long, boolean, long, long, boolean, boolean, FileEncryptionInfo, ErasureCodingPolicy)1200%180%1010333311
invalidateCorruptReplicas(BlockInfo, Block, NumberReplicas)1180%180%1010252511
markBlockReplicasAsCorrupt(Block, BlockInfo, long, long, DatanodeStorageInfo[])1140%220%1212222211
rescanPostponedMisreplicatedBlocks()1130%120%77242411
addBlock(BlockInfo, List)1110%80%55232311
getBlockPlacementStatus(BlockInfo, DatanodeStorageInfo[])1100%200%1111222211
removeStoredBlock(BlockInfo, DatanodeDescriptor)1040%160%99212111
processExtraRedundancyBlockWithoutPostpone(BlockInfo, short, DatanodeDescriptor, DatanodeDescriptor)990%220%1212262611
adjustSrcNodesAndIndices(BlockInfoStriped, DatanodeDescriptor[], List, DatanodeDescriptor[], byte[])940%60%44131311
checkReplicaOnStorage(NumberReplicas, BlockInfo, DatanodeStorageInfo, Collection, boolean)920%260%1414282811
processExtraRedundancyBlocksOnInService(DatanodeDescriptor)920%140%88272711
createLocatedBlockList(LocatedBlockBuilder, BlockInfo[], long, long, BlockTokenIdentifier.AccessMode)910%200%1111181811
commitOrCompleteLastBlock(BlockCollection, Block, INodesInPath)860%180%1010252511
invalidateWorkForOneNode(DatanodeInfo)830%80%55212111
setBlockToken(LocatedBlock, BlockTokenIdentifier.AccessMode)770%60%44191911
findAndMarkBlockAsCorrupt(ExtendedBlock, DatanodeInfo, String, String)770%140%88212111
addExpectedReplicasToPending(BlockInfo)740%140%88171711
updateNeededReconstructions(BlockInfo, int, int)740%60%44151511
invalidateBlock(BlockToMarkCorrupt, DatanodeInfo, NumberReplicas)700%80%55141411
addToInvalidates(BlockInfo)670%160%99171711
removeBlocksAndUpdateSafemodeTotal(INode.BlocksMapUpdateInfo)670%160%99171711
removeBRLeaseIfNeeded(DatanodeID, BlockReportContext)650%60%44141411
addStoredBlockImmediate(BlockInfo, Block, DatanodeStorageInfo)650%180%1010131311
processMisReplicatedBlocks(List)630%120%77202011
checkRedundancy(BlockCollection)630%60%44101011
processPendingReconstructions()620%100%66141411
processMisReplicatedBlock(BlockInfo)600%120%77171711
completeBlock(BlockInfo, INodesInPath, boolean)570%120%77131311
processQueuedMessages(Iterable)550%60%44151511
addBlock(DatanodeStorageInfo, Block, String)540%120%77141411
computeDatanodeWork()510%20%22121211
chooseExcessRedundancies(Collection, BlockInfo, short, DatanodeDescriptor, DatanodeDescriptor)500%80%55111111
removeBlocksAssociatedTo(DatanodeStorageInfo)490%80%55131311
countLiveAndDecommissioningReplicas(NumberReplicas, NumberReplicas.StoredReplicaState, BitSet, BitSet, byte)480%120%77121211
removeBlock(BlockInfo)480%60%44111111
commitBlock(BlockInfo, Block)460%80%55101011
createLocatedBlock(LocatedBlockBuilder, BlockInfo[], long, BlockTokenIdentifier.AccessMode)460%60%448811
requestBlockReportLeaseId(DatanodeRegistration)450%60%44141411
processIncrementalBlockReport(DatanodeID, StorageReceivedDeletedBlocks)440%100%66111111
countNodes(BlockInfo, boolean)440%40%338811
printInitialConfigs()430%n/a118811
computeBlockReconstructionWork(int)430%40%33121211
close()420%20%22151511
getValidLocations(BlockInfo)420%60%449911
countReplicasForStripedBlock(NumberReplicas, BlockInfoStriped, Collection, boolean)420%20%229911
queueReportedBlock(DatanodeStorageInfo, Block, HdfsServerConstants.ReplicaState, String)410%60%446611
getStoredBlock(Block)410%60%44101011
computeInvalidateWork(int)400%60%44121211
isNodeHealthyForDecommissionOrMaintenance(DatanodeDescriptor)400%80%55121211
runBlockOp(Callable)380%40%33131311
createSPSManager(Configuration, String)380%60%44111111
processAllPendingDNMessages()370%100%668811
verifyReplication(String, short, String)360%80%559911
addStoredBlockUnderConstruction(BlockManager.StatefulBlockInfo, DatanodeStorageInfo)360%60%447711
activate(Configuration, long)350%n/a11111111
getDatanodeDescriptors(List)340%60%448811
setReplication(short, short, BlockInfo)340%60%44101011
updateHeartbeat(DatanodeDescriptor, StorageReport[], long, long, int, int, VolumeFailureSummary)330%20%225511
updateHeartbeatState(DatanodeDescriptor, StorageReport[], long, long, int, int, VolumeFailureSummary)330%20%225511
removeDNLeaseIfNeeded(DatanodeDescriptor)330%60%448811
chooseExcessRedundancyContiguous(Collection, BlockInfo, short, DatanodeDescriptor, DatanodeDescriptor, List)310%20%227711
initReplQueueResetToHeadThreshold(Configuration)300%20%226611
processMisReplicatedBlocks()300%40%338811
removeBlockFromMap(BlockInfo)300%20%226611
initMaxReplication(Configuration)280%40%336611
isHotBlock(BlockInfo, long)280%80%558811
removeBlocksAssociatedTo(DatanodeDescriptor)280%20%228811
initMinReplicationToBeInMaintenance(Configuration)270%40%336611
checkBlockReportLease(BlockReportContext, DatanodeID)270%40%338811
processChosenExcessRedundancy(Collection, DatanodeStorageInfo, BlockInfo)270%n/a116611
removeStaleReplicas(List, BlockInfo)270%40%337711
getStorages(BlockInfo)270%20%226611
hasEnoughEffectiveReplicas(BlockInfo, NumberReplicas, int)230%60%444411
isBlockUnderConstruction(BlockInfo, HdfsServerConstants.BlockUCState, HdfsServerConstants.ReplicaState)230%70%556611
chooseTarget4AdditionalDatanode(String, int, Node, List, Set, long, byte, BlockType)220%n/a115511
setBlockIndices(BlockInfo, byte[], int, DatanodeStorageInfo)220%60%445511
isSufficientlyReplicated(BlockInfo)210%40%334411
removeStoredBlock(DatanodeStorageInfo, Block, DatanodeDescriptor)210%40%335511
newLocatedBlock(ExtendedBlock, BlockInfo, DatanodeStorageInfo[], long)210%20%225511
getDefaultStorageNum(BlockInfo)200%30%335511
getMinStorageNum(BlockInfo)200%30%335511
addKeyUpdateCommand(List, DatanodeDescriptor)190%40%334411
updateState()190%n/a114411
clearQueues()190%n/a117711
refreshBlockPlacementPolicy(Configuration)180%n/a116611
stopReconstructionInitializer()180%20%228811
addBlockCollectionWithCheck(BlockInfo, BlockCollection)180%60%444411
chooseTarget4WebHDFS(String, DatanodeDescriptor, Set, long)170%n/a113311
isNeededReconstructionForMaintenance(BlockInfo, NumberReplicas)170%60%443311
adjustReplication(short)160%40%332211
setMinBlocksForWrite(int)160%n/a114411
initMinReplication(Configuration)150%20%224411
newLocatedStripedBlock(ExtendedBlock, DatanodeStorageInfo[], byte[], long, boolean)150%n/a114411
shouldPopulateReplQueues()150%40%334411
getMinMaintenanceStorageNum(BlockInfo)140%20%224411
forceCompleteBlock(BlockInfo)140%n/a114411
createLocatedBlock(LocatedBlockBuilder, BlockInfo, long, BlockTokenIdentifier.AccessMode)140%20%224411
setExcessRedundancyTimeout(long)140%20%224411
updateLastBlock(BlockInfo, ExtendedBlock)140%n/a115511
getExpectedLiveRedundancyNum(BlockInfo, NumberReplicas)140%n/a114411
newLocatedBlock(ExtendedBlock, DatanodeStorageInfo[], long, boolean)140%n/a114411
setExcessRedundancyTimeoutCheckLimit(long)130%20%224411
shouldProcessExtraRedundancy(NumberReplicas, int)130%40%332211
isNeededReconstruction(BlockInfo, NumberReplicas, int)130%40%332211
addBlockCollection(BlockInfo, BlockCollection)130%n/a113311
setExcludeSlowNodesEnabled(boolean)130%n/a113311
static {...}130%20%223311
shouldUpdateBlockKey(long)120%40%331111
hasMinStorage(BlockInfo)120%20%221111
generateDataEncryptionKey()120%40%333311
setBlockTotal(long)120%20%224411
removeQueuedBlock(DatanodeStorageInfo, Block)120%n/a114411
processQueuedMessagesForBlock(Block)120%20%225511
shutdown()120%n/a115511
enqueueBlockOp(Runnable)120%n/a115511
setBlockPoolId(String)110%20%224411
setReconstructionPendingTimeout(int)110%n/a113311
addToInvalidates(Block, DatanodeInfo)110%20%224411
getDatanodeDescriptorFromStorage(DatanodeStorageInfo)110%20%223311
processExtraRedundancyBlock(BlockInfo, short, DatanodeDescriptor, DatanodeDescriptor)110%20%223311
lambda$getBlocksWithLocations$1(StorageType, DatanodeStorageInfo)110%40%331111
ensurePositiveInt(int, String)100%20%222211
getBlockOnStorage(BlockInfo, DatanodeStorageInfo)100%20%222211
countLiveNodes(BlockInfo)100%n/a112211
getExpectedRedundancyNum(BlockInfo)100%20%223311
addBLocksToMarkedDeleteQueue(List)100%n/a114411
getPendingSPSPaths()90%20%223311
setMaxReplicationStreams(int, boolean)90%20%224411
hasMinStorage(BlockInfo, int)90%20%221111
convertToCompleteBlock(BlockInfo, INodesInPath)90%n/a113311
getBlockKeys()90%20%222211
clear()90%n/a114411
initializeReplQueues()90%n/a114411
registerDatanode(DatanodeRegistration)80%n/a113311
isPopulatingReplQueues()80%20%223311
flushBlockOps()80%n/a112211
isBlockTokenEnabled()70%20%221111
setReplicationStreamsHardLimit(int)70%n/a113311
setBlocksReplWorkMultiplier(int)70%n/a113311
getReconstructionPendingTimeout()70%n/a111111
lambda$getBlocksWithLocations$0(DatanodeStorageInfo)70%20%221111
postponeBlock(Block)60%n/a112211
isExcess(DatanodeDescriptor, BlockInfo)60%n/a111111
containsInvalidateBlock(DatanodeInfo, Block)60%n/a111111
isPlacementPolicySatisfied(BlockInfo)60%n/a112211
isNeededReconstruction(BlockInfo, NumberReplicas)60%n/a111111
getBlockCollection(BlockInfo)60%n/a111111
getCorruptReason(Block, DatanodeDescriptor)60%n/a111111
isReplicaCorrupt(BlockInfo, DatanodeDescriptor)60%n/a111111
getBlockRecoveryTimeout(long)60%n/a111111
getExcludeSlowNodesEnabled(BlockType)60%n/a111111
getMinBlocksForWrite(BlockType)60%n/a111111
getPostponedMisreplicatedBlocksCount()50%n/a111111
getStoragePolicy(String)50%n/a111111
getStoragePolicy(byte)50%n/a111111
getBlockPlacementPolicy()50%n/a111111
getStriptedBlockPlacementPolicy()50%n/a111111
setMaxReplicationStreams(int)50%n/a112211
leaveSafeMode(boolean)50%n/a111111
countNodes(BlockInfo)50%n/a111111
getExcessSize4Testing(String)50%n/a111111
getStorages(Block)50%n/a111111
getBlockPlacementStatus(BlockInfo)50%n/a111111
getMissingBlocksCount()50%n/a111111
numCorruptReplicas(Block)50%n/a111111
getCorruptReplicaBlockIterator()50%n/a111111
getCorruptReplicas(Block)50%n/a111111
getStorageTypeStats()50%n/a111111
successfulBlockRecovery(BlockInfo)50%n/a112211
addBlockRecoveryAttempt(BlockInfo)50%n/a111111
getBlockOpQueueLength()50%n/a111111
nextGenerationStamp(boolean)50%n/a111111
isLegacyBlock(Block)50%n/a111111
nextBlockId(BlockType)50%n/a111111
isGenStampInFuture(Block)50%n/a111111
setBlockRecoveryTimeout(long)50%n/a112211
createSPSManager(Configuration)50%n/a111111
getPendingDeletionBlocksCount()40%n/a111111
getExcessBlocksCount()40%n/a111111
getPendingDataNodeMessageCount()40%n/a111111
getNumTimedOutPendingReconstructions()40%n/a111111
getLowRedundancyBlocks()40%n/a111111
getCorruptBlocks()40%n/a111111
getMissingBlocks()40%n/a111111
getMissingReplicationOneBlocks()40%n/a111111
getBadlyDistributedBlocks()40%n/a111111
getPendingDeletionReplicatedBlocks()40%n/a111111
getTotalReplicatedBlocks()40%n/a111111
getLowRedundancyECBlockGroups()40%n/a111111
getCorruptECBlockGroups()40%n/a111111
getMissingECBlockGroups()40%n/a111111
getPendingDeletionECBlocks()40%n/a111111
getTotalECBlockGroups()40%n/a111111
getStoragePolicies()40%n/a111111
enableRMTerminationForTesting()40%n/a112211
setPostponeBlocksFromFuture(boolean)40%n/a112211
getUnderReplicatedNotMissingBlocks()40%n/a111111
isInSafeMode()40%n/a111111
getSafeModeTip()40%n/a111111
checkSafeMode()40%n/a112211
getBytesInFuture()40%n/a111111
getBytesInFutureReplicatedBlocks()40%n/a111111
getBytesInFutureECBlockGroups()40%n/a111111
getProvidedCapacity()40%n/a111111
getActiveBlockCount()40%n/a111111
getTotalBlocks()40%n/a111111
getMissingReplOneBlocksCount()40%n/a111111
getBadlyDistributedBlocksCount()40%n/a111111
getHighestPriorityReplicatedBlockCount()40%n/a111111
getHighestPriorityECBlockCount()40%n/a111111
getCapacity()40%n/a111111
numOfUnderReplicatedBlocks()40%n/a111111
getLastRedundancyMonitorTS()40%n/a111111
setInitializedReplQueues(boolean)40%n/a112211
disableSPS()40%n/a112211
getPendingReconstructionBlocksCount()0%n/a111111
getLowRedundancyBlocksCount()0%n/a111111
getCorruptReplicaBlocksCount()0%n/a111111
getScheduledReplicationBlocksCount()0%n/a111111
getStartupDelayBlockDeletionInMs()0%n/a111111
getBlockPoolId()0%n/a111111
getStoragePolicySuite()0%n/a111111
getBlockTokenSecretManager()0%n/a111111
getDatanodeManager()0%n/a111111
getMaxReplicationStreams()0%n/a111111
getReplicationStreamsHardLimit()0%n/a111111
getBlocksReplWorkMultiplier()0%n/a111111
getMinReplication()0%n/a111111
getMinReplicationToBeInMaintenance()0%n/a111111
getReconstructionQueuesInitProgress()0%n/a111111
hasNonEcBlockUsingStripedID()0%n/a111111
getBlockReportLeaseManager()0%n/a111111
getShouldPostponeBlocksFromFuture()0%n/a111111
getRedundancyThread()0%n/a111111
getBlockIdManager()0%n/a111111
getMarkedDeleteQueue()0%n/a111111
getProvidedStorageMap()0%n/a111111
getSPSManager()0%n/a111111
lambda$processTimedOutExcessBlocks$4(Block)0%n/a111111
lambda$processTimedOutExcessBlocks$3(Block)0%n/a111111
lambda$getBlocksWithLocations$2(int)0%n/a111111