DataXceiver

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,241 of 3,2410%218 of 2180%1461467577573737
writeBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo[], StorageType[], DatanodeInfo, BlockConstructionStage, int, long, long, long, DataChecksum, CachingStrategy, boolean, boolean, boolean[], String, String[])7810%760%393916216211
replaceBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo, String)4060%140%88888811
run()3140%400%2121767611
readBlock(ExtendedBlock, Token, String, long, long, boolean, CachingStrategy)3040%100%66555511
requestShortCircuitFds(ExtendedBlock, Token, ShortCircuitShm.SlotId, int, boolean)2640%240%1313636311
copyBlock(ExtendedBlock, Token)2010%60%44454511
requestShortCircuitShm(String)1400%100%66363611
blockGroupChecksum(StripedBlockInfo, Token, long, BlockChecksumOptions)860%n/a11262611
releaseShortCircuitFds(ShortCircuitShm.SlotId)840%40%33222211
blockChecksum(ExtendedBlock, Token, BlockChecksumOptions)810%n/a11262611
DataXceiver(Peer, DataNode, DataXceiverServer)780%20%22202011
checkAccess(OutputStream, boolean, ExtendedBlock, Token, Op, BlockTokenIdentifier.AccessMode, StorageType[], String[])760%60%44212111
transferBlock(ExtendedBlock, Token, String, DatanodeInfo[], StorageType[], String[])570%n/a11141411
checkAndWaitForBP(ExtendedBlock)570%20%22161611
updateCurrentThreadName(String)380%40%339911
sendShmSuccessResponse(DomainSocket, ShortCircuitRegistry.NewShmInfo)370%n/a119911
writeSuccessWithChecksumInfo(BlockSender, DataOutputStream)230%n/a11111111
stopWriter()220%20%227711
getBlockReceiver(ExtendedBlock, StorageType, DataInputStream, String, String, BlockConstructionStage, long, long, long, String, DatanodeInfo, DataNode, DataChecksum, CachingStrategy, boolean, boolean, String)210%n/a111111
incrReadWriteOpMetrics(Op)180%40%335511
decrReadWriteOpMetrics(Op)180%40%335511
writeResponse(DataTransferProtos.Status, String, OutputStream)170%20%227711
sendOOB()140%20%226611
collectThreadLocalStates()140%40%333311
static {...}120%20%223311
getBufferedOutputStream()110%n/a112211
checkAccess(OutputStream, boolean, ExtendedBlock, Token, Op, BlockTokenIdentifier.AccessMode)110%n/a112211
sendShmErrorResponse(DataTransferProtos.Status, String)100%n/a113311
releaseSocket()90%n/a113311
create(Peer, DataNode, DataXceiverServer)70%n/a111111
sendResponse(DataTransferProtos.Status, String)0%n/a112211
incrDatanodeNetworkErrors()0%n/a112211
elapsed()0%n/a111111
setCurrentBlockReceiver(BlockReceiver)0%n/a112211
getDataNode()0%n/a111111
getOutputStream()0%n/a111111
getCurrentBlockReceiver()0%n/a111111