FsDatasetImpl

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total7,372 of 7,3720%748 of 7480%5265261,6631,663151151
checkAndUpdate(String, FsVolumeSpi.ScanInfo)5830%940%484814814811
removeVolumes(Collection, boolean)2680%200%1111474711
FsDatasetImpl(DataNode, DataStorage, Configuration)2480%160%99515111
createTemporary(StorageType, String, ExtendedBlock, boolean)2230%300%1616525211
removeReplicaFromMem(ExtendedBlock, FsVolumeImpl)2120%260%1414464611
invalidate(String, Block[], boolean)2080%240%1313373711
createRbw(StorageType, String, ExtendedBlock, boolean, long)1980%240%1313434311
activateVolume(ReplicaMap, Storage.StorageDirectory, StorageType, FsVolumeReference)1860%80%55313111
updateReplicaUnderRecovery(ExtendedBlock, long, long, long)1660%280%1515303011
convertTemporaryToRbw(ExtendedBlock)1490%140%88313111
recoverRbwImpl(ReplicaInPipeline, ExtendedBlock, long, long, long)1480%140%88323211
moveBlockAcrossStorage(ExtendedBlock, StorageType, String)1460%180%1010363611
cacheBlock(String, long)1450%220%1212373711
initReplicaRecoveryImpl(String, ReplicaMap, Block, long)1400%220%1212333311
addBlockPool(String, Configuration)1400%80%55272711
computeChecksum(ReplicaInfo, File, int, Configuration)1380%120%77343411
finalizeReplica(String, ReplicaInfo)1340%160%99282811
addVolume(StorageLocation, List)1110%40%33323211
append(ExtendedBlock, long, long)1050%60%44212111
updateReplicaUnderRecovery(String, ReplicaInfo, long, long, long)1050%160%99212111
recoverRbw(ExtendedBlock, long, long, long)990%60%44212111
recoverCheck(ExtendedBlock, long, long)980%180%1010212111
getBlockLocalPathInfo(ExtendedBlock)980%60%44191911
hardLinkBlockFiles(ReplicaInfo, File, File)970%20%22181811
recoverAppend(ExtendedBlock, long, long)890%20%22202011
finalizeBlock(ExtendedBlock, boolean)890%140%88222211
unfinalizeBlock(ExtendedBlock)840%100%66181811
append(String, ReplicaInfo, long, long)830%40%33161611
getBlockReports(String)790%40%33151511
recoverClose(ExtendedBlock, long, long)770%20%22141411
getTmpInputStreams(ExtendedBlock, long, long)760%n/a11151511
getVolumeInfoMap()710%20%22131311
deleteBlockPool(String, boolean)670%80%55181811
getVolumeFailureSummary()650%60%44151511
getBlockInputStream(ExtendedBlock, long)650%60%44101011
copyBlockFiles(ReplicaInfo, File, File, boolean, int, Configuration)650%60%44151511
onCompleteLazyPersist(String, long, long, File[], FsVolumeImpl)640%20%22111111
lambda$getBlockReports$3(Map, Set, Iterator)620%140%99191911
moveBlockFiles(Block, ReplicaInfo, File)610%20%22171711
getStorageReports(String)580%20%22171711
shutdown()560%120%77202011
getStoredBlock(String, long)530%40%338811
getVolumeInfo()530%20%22171711
checkBlock(ExtendedBlock, long, HdfsServerConstants.ReplicaState)520%80%55121211
getReplicaVisibleLength(ExtendedBlock)510%20%228811
getInitialVolumeFailureInfos(Collection, DataStorage)480%40%33131311
addVolume(Storage.StorageDirectory)480%n/a11151511
getBlockInputStreamWithCheckingPmemCache(ReplicaInfo, ExtendedBlock, long)480%40%33121211
checkReplicaFiles(ReplicaInfo)460%80%55101011
initReplicaRecovery(String, ReplicaMap, Block, long, long)460%20%22101011
initReplicaRecovery(String, ReplicaMap, Block, long, long, DataSetLockManager)450%20%22101011
moveBlockAcrossVolumes(ExtendedBlock, FsVolumeSpi)440%40%33111111
invalidateMissingBlock(String, Block, boolean)380%80%557711
getFailedStorageLocations()370%20%227711
contains(ExtendedBlock)360%40%336611
setupAsyncLazyPersistThread(FsVolumeImpl)360%140%88101011
stopAllDataxceiverThreads(FsVolumeImpl)360%20%225511
shouldConsiderSameMountVolume(FsVolumeSpi, StorageType, String)350%140%88101011
getReplicaInfo(ExtendedBlock)330%40%336611
removeDeletedBlocks(String, Set)320%40%338811
getLastVolumeFailureDate()310%40%336611
addDeletingBlock(String, Long)310%20%228811
getVolume(ExtendedBlock)300%20%225511
adjustCrcChannelPosition(ExtendedBlock, ReplicaOutputStreams, int)290%20%228811
shutdownBlockPool(String)290%n/a117711
lambda$removeVolumes$2(StorageLocation, List, Iterator)290%40%33101011
reserveLockedMemory(long)280%40%335511
fetchReplicaInfo(String, long)270%40%336611
getEstimatedCapacityLostTotal()270%20%224411
moveBlock(ExtendedBlock, ReplicaInfo, FsVolumeReference, boolean)270%20%226611
cleanupReplica(String, ReplicaInfo)270%80%556611
invalidate(String, ReplicaInfo)270%n/a116611
lambda$stopAllDataxceiverThreads$5(FsVolumeImpl, Iterator)270%80%559911
finalizeNewReplica(ReplicaInfo, ExtendedBlock)260%n/a11101011
validateBlockFile(String, long)260%40%337711
getReplicaString(String, long)260%20%223311
removeOldReplica(ReplicaInfo, ReplicaInfo, String)260%n/a118811
hasEnoughResource()230%60%443311
copyBlockFiles(long, long, ReplicaInfo, File, boolean, int, Configuration)230%n/a114411
registerMBean(String)230%n/a117711
delBlockFromDisk(ReplicaInfo, String)220%40%337711
isDeletingBlock(String, long)220%20%223311
static {...}220%60%446611
lambda$getFinalizedBlocks$4(ArrayList, Iterator)210%40%336611
hardLinkBlockFiles(long, long, ReplicaInfo, File)200%n/a114411
ramDiskConfigured()200%40%335511
onFailLazyPersist(String, long)190%20%226611
createFsVolume(String, Storage.StorageDirectory, StorageLocation)180%n/a117711
getMetaDataInputStream(ExtendedBlock)170%40%335511
getReplicaInfo(String, long)170%20%224411
initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock)170%n/a113311
setupAsyncLazyPersistThreads()170%20%224411
uncache(String, long[])160%20%223311
getBlockReplica(String, long)150%20%224411
copyReplicaToVolume(ExtendedBlock, ReplicaInfo, FsVolumeReference)150%n/a113311
cache(String, long[])150%20%223311
getPinning(ExtendedBlock)140%20%224411
releaseLockedMemory(long, boolean)140%20%224411
isReplicaProvided(ReplicaInfo)130%40%333311
submitBackgroundSyncFileRangeRequest(ExtendedBlock, ReplicaOutputStreams, long, long, int)130%n/a113311
setPinning(ExtendedBlock)130%20%225511
evictLazyPersistBlocks(long)130%n/a115511
lambda$deepCopyReplica$0(Set, Iterator)130%20%225511
deepCopyReplica(String)120%n/a113311
getMetrics(MetricsCollector, boolean)120%n/a116611
getFinalizedBlocks(String)120%n/a113311
moveReplicaToVolumeOnSameMount(ExtendedBlock, ReplicaInfo, FsVolumeReference)110%n/a113311
isValid(ExtendedBlock, HdfsServerConstants.ReplicaState)110%n/a115511
isValidBlock(ExtendedBlock)90%20%223311
isValidRbw(ExtendedBlock)90%20%223311
getStorageUuidForLock(ExtendedBlock)80%n/a112211
createRbw(StorageType, String, ExtendedBlock, boolean)80%n/a111111
getFsVolumeReferences()70%n/a111111
getBlockReplica(ExtendedBlock)70%n/a111111
getStorage(String)60%n/a111111
invalidate(String, Block[])60%n/a112211
invalidateMissingBlock(String, Block)60%n/a112211
isCached(String, long)60%n/a111111
getReplica(String, long)60%n/a111111
getBlockPoolUsed(String)50%n/a111111
getNumFailedVolumes()50%n/a111111
getLength(ExtendedBlock)50%n/a111111
getCacheReport(String)50%n/a111111
handleVolumeFailures(Set)50%n/a112211
enableTrash(String)50%n/a112211
clearTrash(String)50%n/a112211
trashEnabled(String)50%n/a111111
setRollingUpgradeMarker(String)50%n/a112211
clearRollingUpgradeMarker(String)50%n/a112211
getVolumeCount()50%n/a111111
getDfsUsed()0%n/a111111
getCapacity()0%n/a111111
getRemaining()0%n/a111111
getCacheUsed()0%n/a111111
getCacheCapacity()0%n/a111111
getNumBlocksFailedToCache()0%n/a111111
getNumBlocksFailedToUncache()0%n/a111111
getNumBlocksCached()0%n/a111111
toString()0%n/a111111
getMountVolumeMap()0%n/a111111
getNonPersistentReplicas()0%n/a111111
setTimer(Timer)0%n/a112211
getBPServiceCount()0%n/a111111
getVolumeList()0%n/a111111
setLastDirScannerFinishTime(long)0%n/a112211
getPendingAsyncDeletions()0%n/a111111
lambda$removeVolumes$1(String)0%n/a111111
acquireDatasetLockManager()0%n/a111111
getStorageInfo()0%n/a111111
setBlockPoolId(String)0%n/a112211
getLastDirScannerFinishTime()0%n/a111111