FsDatasetImpl

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total7,507 of 7,5070%748 of 7480%5265261,6631,663151151
checkAndUpdate(String, FsVolumeSpi.ScanInfo)5900%940%484814814811
removeVolumes(Collection, boolean)2700%200%1111474711
FsDatasetImpl(DataNode, DataStorage, Configuration)2480%160%99515111
createTemporary(StorageType, String, ExtendedBlock, boolean)2270%300%1616525211
invalidate(String, Block[], boolean)2140%240%1313373711
removeReplicaFromMem(ExtendedBlock, FsVolumeImpl)2120%260%1414464611
createRbw(StorageType, String, ExtendedBlock, boolean, long)2010%240%1313434311
activateVolume(ReplicaMap, Storage.StorageDirectory, StorageType, FsVolumeReference)1860%80%55313111
updateReplicaUnderRecovery(ExtendedBlock, long, long, long)1760%280%1515303011
convertTemporaryToRbw(ExtendedBlock)1580%140%88313111
moveBlockAcrossStorage(ExtendedBlock, StorageType, String)1520%180%1010363611
recoverRbwImpl(ReplicaInPipeline, ExtendedBlock, long, long, long)1510%140%88323211
initReplicaRecoveryImpl(String, ReplicaMap, Block, long)1510%220%1212333311
cacheBlock(String, long)1460%220%1212373711
addBlockPool(String, Configuration)1400%80%55272711
computeChecksum(ReplicaInfo, File, int, Configuration)1390%120%77343411
finalizeReplica(String, ReplicaInfo)1360%160%99282811
addVolume(StorageLocation, List)1140%40%33323211
append(ExtendedBlock, long, long)1090%60%44212111
updateReplicaUnderRecovery(String, ReplicaInfo, long, long, long)1080%160%99212111
recoverRbw(ExtendedBlock, long, long, long)1020%60%44212111
hardLinkBlockFiles(ReplicaInfo, File, File)1010%20%22181811
recoverCheck(ExtendedBlock, long, long)1010%180%1010212111
getBlockLocalPathInfo(ExtendedBlock)1000%60%44191911
recoverAppend(ExtendedBlock, long, long)900%20%22202011
finalizeBlock(ExtendedBlock, boolean)900%140%88222211
append(String, ReplicaInfo, long, long)850%40%33161611
unfinalizeBlock(ExtendedBlock)850%100%66181811
getBlockReports(String)790%40%33151511
recoverClose(ExtendedBlock, long, long)770%20%22141411
getTmpInputStreams(ExtendedBlock, long, long)760%n/a11151511
copyBlockFiles(ReplicaInfo, File, File, boolean, int, Configuration)730%60%44151511
getVolumeInfoMap()710%20%22131311
moveBlockFiles(Block, ReplicaInfo, File)700%20%22171711
deleteBlockPool(String, boolean)670%80%55181811
onCompleteLazyPersist(String, long, long, File[], FsVolumeImpl)670%20%22111111
getBlockInputStream(ExtendedBlock, long)660%60%44101011
getVolumeFailureSummary()650%60%44151511
lambda$getBlockReports$3(Map, Set, Iterator)630%140%99191911
getStorageReports(String)580%20%22171711
shutdown()560%120%77202011
getStoredBlock(String, long)530%40%338811
checkBlock(ExtendedBlock, long, HdfsServerConstants.ReplicaState)530%80%55121211
getReplicaVisibleLength(ExtendedBlock)530%20%228811
getVolumeInfo()530%20%22171711
checkReplicaFiles(ReplicaInfo)510%80%55101011
addVolume(Storage.StorageDirectory)500%n/a11151511
getInitialVolumeFailureInfos(Collection, DataStorage)480%40%33131311
getBlockInputStreamWithCheckingPmemCache(ReplicaInfo, ExtendedBlock, long)480%40%33121211
initReplicaRecovery(String, ReplicaMap, Block, long, long)480%20%22101011
initReplicaRecovery(String, ReplicaMap, Block, long, long, DataSetLockManager)470%20%22101011
moveBlockAcrossVolumes(ExtendedBlock, FsVolumeSpi)450%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
getReplicaInfo(ExtendedBlock)350%40%336611
shouldConsiderSameMountVolume(FsVolumeSpi, StorageType, String)350%140%88101011
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)300%20%228811
lambda$removeVolumes$2(StorageLocation, List, Iterator)300%40%33101011
shutdownBlockPool(String)290%n/a117711
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
onFailLazyPersist(String, long)200%20%226611
ramDiskConfigured()200%40%335511
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
toString()50%n/a111111
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
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