DFSInputStream

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,983 of 3,9830%414 of 4140%2982989239239191
actualGetFromOneDataNode(DFSInputStream.DNAddrPair, long, long, ByteBuffer, DFSUtilClient.CorruptedBlocks, Map)2690%160%99575711
tryReadZeroCopy(int, EnumSet)2620%120%77414111
hedgedFetchBlockByteRange(LocatedBlock, long, long, ByteBuffer, DFSUtilClient.CorruptedBlocks, Map)2030%140%88636311
readWithStrategy(ReaderStrategy)1830%200%1111454511
refetchLocations(LocatedBlock, Collection)1720%60%44262611
readBlockLength(LocatedBlock)1700%300%1616474711
blockSeekTo(long)1700%120%77404011
pread(long, ByteBuffer)1530%180%1010333311
seek(long)1360%160%99252511
readBuffer(ReaderStrategy, int, DFSUtilClient.CorruptedBlocks, Map)1270%60%44292911
fetchBlockAt(long, long, boolean)1120%200%1111212111
getBestNodeDNAddrPair(LocatedBlock, Collection)1120%220%1212262611
reportCheckSumFailure(DFSUtilClient.CorruptedBlocks, int, boolean)950%180%1010222211
DFSInputStream(DFSClient, String, boolean, LocatedBlocks)900%n/a11262611
getBestNodeDNAddrPairErrorString(DatanodeInfo[], AbstractMap, Collection)820%80%55171711
read(ByteBufferPool, int, EnumSet)790%200%1111181811
getBlockRange(long, long)780%100%66141411
getBlockReader(LocatedBlock, long, long, InetSocketAddress, StorageType, DatanodeInfo)750%20%22242411
getFinalizedBlockRange(long, long)700%100%66141411
logDataNodeExceptionsOnReadError(long, Map)700%40%33121211
fetchAndCheckLocatedBlocks(LocatedBlocks)690%100%66121211
openInfo(boolean)660%80%55151511
close()630%60%44151511
getBlockAt(long)620%100%668811
refreshBlockLocations(Map)610%60%44171711
allBlocksLocal(LocatedBlocks, Map)500%100%66141411
seekToNewSource(long)430%60%44121211
maybeRegisterBlockRefresh()390%100%66111111
releaseBuffer(ByteBuffer)380%80%559911
getCurrentBlockLocationsLength()360%20%226611
getLastBlockLength(LocatedBlocks)350%80%55121211
skip(long)350%60%448811
getFirstToComplete(CompletionService, ArrayList)330%20%22101011
read(byte[], int, int)260%20%225511
readFully(long, ByteBuffer)260%40%338811
read()250%40%334411
setRefreshedValues(LocatedBlocks, long)250%20%227711
reportLostBlock(LocatedBlock, Collection)240%n/a114411
available()240%40%334411
fetchBlockByteRange(LocatedBlock, long, long, ByteBuffer, DFSUtilClient.CorruptedBlocks, Map)220%n/a117711
setReadahead(Long)210%n/a116611
setDropBehind(Boolean)210%n/a116611
chooseDataNode(LocatedBlock, Collection, boolean)200%40%337711
read(long, byte[], int, int)200%20%225511
closeCurrentBlockReaders()200%20%228811
getFileLength()190%20%223311
isValidNode(DatanodeInfo, Collection)170%60%444411
checkInterrupted(IOException)160%60%444411
cancelAll(List)160%20%224411
lambda$allBlocksLocal$0(DatanodeInfoWithStorage, String)160%n/a113311
tokenRefetchNeeded(IOException, InetSocketAddress)150%40%334411
setLocatedBlocksFields(LocatedBlocks, long)140%n/a115511
static {...}140%20%224411
addToLocalDeadNodes(DatanodeInfo)130%n/a113311
waitFor(int)130%n/a116611
read(ByteBuffer)130%n/a112211
hasCapability(String)130%20%223311
getExtendedReadBuffers()120%20%223311
shortCircuitForbidden()110%n/a112211
getFromOneDataNode(DFSInputStream.DNAddrPair, long, long, ByteBuffer, DFSUtilClient.CorruptedBlocks, Map)110%n/a111111
isResolveableAndLocal(InetSocketAddress)110%n/a114411
removeFromLocalDeadNodes(DatanodeInfo)100%n/a113311
read(long, ByteBuffer)100%20%223311
getFileEncryptionInfo()100%n/a112211
getCurrentBlock()90%20%223311
maybeDeRegisterBlockRefresh()90%20%223311
clearCachedNodeState(Collection)70%20%224411
seekToBlockSource(long)70%n/a112211
getAllBlocks()60%n/a111111
fetchBlockAt(long)60%n/a111111
chooseDataNode(LocatedBlock, Collection)60%n/a111111
deadNodesContain(DatanodeInfo)50%n/a111111
refreshLocatedBlock(LocatedBlock)50%n/a111111
reset()50%n/a111111
clearLocalDeadNodes()40%n/a112211
clearReadStatistics()40%n/a112211
setLastRefreshedBlocksAtForTesting(long)40%n/a112211
setLastRefreshedBlocksAt()40%n/a112211
getLocalDeadNodes()30%n/a111111
getDFSClient()30%n/a111111
getlastBlockBeingWrittenLengthForTesting()30%n/a111111
getCurrentDatanode()30%n/a111111
getSrc()30%n/a111111
getLocatedBlocks()30%n/a111111
getHedgedReadOpsLoopNumForTesting()30%n/a111111
getPos()30%n/a111111
getReadStatistics()30%n/a111111
unbuffer()30%n/a112211
getLastRefreshedBlocksAtForTesting()30%n/a111111
markSupported()0%n/a111111
mark(int)0%n/a111111