FsDatasetImpl

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total8,152 of 8,1520%742 of 7420%5235231,6261,626151151
checkAndUpdate(String, FsVolumeSpi.ScanInfo)6970%940%484814714711
FsDatasetImpl(DataNode, DataStorage, Configuration)2840%160%99505011
createTemporary(StorageType, String, ExtendedBlock, boolean)2480%300%1616515111
invalidate(String, Block[], boolean)2430%240%1313373711
removeVolumes(Collection, boolean)2380%180%1010424211
updateReplicaUnderRecovery(ExtendedBlock, long, long, long)2320%280%1515303011
createRbw(StorageType, String, ExtendedBlock, boolean, long)2160%240%1313424211
initReplicaRecoveryImpl(String, ReplicaMap, Block, long)2030%220%1212333311
removeReplicaFromMem(ExtendedBlock, FsVolumeImpl)2000%260%1414454511
convertTemporaryToRbw(ExtendedBlock)1990%140%88303011
cacheBlock(String, long)1910%220%1212373711
moveBlockAcrossStorage(ExtendedBlock, StorageType, String)1820%180%1010363611
recoverRbwImpl(ReplicaInPipeline, ExtendedBlock, long, long, long)1800%140%88313111
recoverCheck(ExtendedBlock, long, long)1470%180%1010212111
computeChecksum(ReplicaInfo, File, int, Configuration)1460%120%77343411
finalizeReplica(String, ReplicaInfo)1440%160%99272711
updateReplicaUnderRecovery(String, ReplicaInfo, long, long, long)1340%160%99212111
activateVolume(ReplicaMap, Storage.StorageDirectory, StorageType, FsVolumeReference)1320%60%44252511
append(ExtendedBlock, long, long)1320%60%44202011
addVolume(StorageLocation, List)1280%40%33323211
hardLinkBlockFiles(ReplicaInfo, File, File)1150%20%22181811
recoverRbw(ExtendedBlock, long, long, long)1120%60%44202011
copyBlockFiles(ReplicaInfo, File, File, boolean, int, Configuration)1030%60%44151511
moveBlockFiles(Block, ReplicaInfo, File)1000%20%22171711
addBlockPool(String, Configuration)960%60%44222211
append(String, ReplicaInfo, long, long)950%40%33151511
getBlockLocalPathInfo(ExtendedBlock)930%60%44181811
finalizeBlock(ExtendedBlock, boolean)890%140%88212111
unfinalizeBlock(ExtendedBlock)840%100%66171711
onCompleteLazyPersist(String, long, long, File[], FsVolumeImpl)820%20%22111111
recoverAppend(ExtendedBlock, long, long)810%20%22191911
getBlockReports(String)790%40%33151511
checkReplicaFiles(ReplicaInfo)740%80%55101011
deleteBlockPool(String, boolean)730%80%55181811
lambda$getBlockReports$3(Map, Set, Iterator)730%140%99191911
getVolumeInfoMap()710%20%22131311
recoverClose(ExtendedBlock, long, long)690%20%22131311
getTmpInputStreams(ExtendedBlock, long, long)680%n/a11141411
getVolumeFailureSummary()650%60%44151511
checkBlock(ExtendedBlock, long, HdfsServerConstants.ReplicaState)620%80%55121211
getStorageReports(String)580%20%22171711
initReplicaRecovery(String, ReplicaMap, Block, long, long)580%20%22101011
addVolume(Storage.StorageDirectory)570%n/a11151511
getBlockInputStream(ExtendedBlock, long)570%60%449911
initReplicaRecovery(String, ReplicaMap, Block, long, long, DataSetLockManager)570%20%22101011
shutdown()560%120%77202011
getVolumeInfo()530%20%22171711
moveBlockAcrossVolumes(ExtendedBlock, FsVolumeSpi)500%40%33111111
getInitialVolumeFailureInfos(Collection, DataStorage)480%40%33131311
getBlockInputStreamWithCheckingPmemCache(ReplicaInfo, ExtendedBlock, long)480%40%33121211
getReplicaVisibleLength(ExtendedBlock)460%20%227711
getReplicaInfo(ExtendedBlock)450%40%336611
adjustCrcChannelPosition(ExtendedBlock, ReplicaOutputStreams, int)410%20%228811
getStoredBlock(String, long)380%40%336611
invalidateMissingBlock(String, Block, boolean)380%80%557711
lambda$removeVolumes$2(StorageLocation, List, Iterator)380%40%33101011
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
shutdownBlockPool(String)350%n/a117711
removeDeletedBlocks(String, Set)320%40%338811
getLastVolumeFailureDate()310%40%336611
addDeletingBlock(String, Long)310%20%228811
getVolume(ExtendedBlock)300%20%225511
registerMBean(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
onFailLazyPersist(String, long)270%20%226611
lambda$stopAllDataxceiverThreads$5(FsVolumeImpl, Iterator)270%80%559911
getReplicaInfo(String, long)260%20%224411
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
getBlockReplica(String, long)230%20%224411
copyBlockFiles(long, long, ReplicaInfo, File, boolean, int, Configuration)230%n/a114411
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
createFsVolume(String, Storage.StorageDirectory, StorageLocation)180%n/a117711
getMetrics(MetricsCollector, boolean)180%n/a116611
getMetaDataInputStream(ExtendedBlock)170%40%335511
initReplicaRecovery(BlockRecoveryCommand.RecoveringBlock)170%n/a113311
setupAsyncLazyPersistThreads()170%20%224411
uncache(String, long[])160%20%223311
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
getFinalizedBlocks(String)120%n/a113311
toString()120%n/a111111
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)0%n/a111111
getNumFailedVolumes()0%n/a111111
getLength(ExtendedBlock)0%n/a111111
getCacheReport(String)0%n/a111111
handleVolumeFailures(Set)0%n/a112211
enableTrash(String)0%n/a112211
clearTrash(String)0%n/a112211
trashEnabled(String)0%n/a111111
setRollingUpgradeMarker(String)0%n/a112211
clearRollingUpgradeMarker(String)0%n/a112211
getVolumeCount()0%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