DataXceiver

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,076 of 3,0760%218 of 2180%1461467577573737
writeBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo[], StorageType[], DatanodeInfo, BlockConstructionStage, int, long, long, long, DataChecksum, CachingStrategy, boolean, boolean, boolean[], String, String[])7710%760%393916216211
replaceBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo, String)3700%140%88888811
run()2860%400%2121767611
readBlock(ExtendedBlock, Token, String, long, long, boolean, CachingStrategy)2840%100%66555511
requestShortCircuitFds(ExtendedBlock, Token, ShortCircuitShm.SlotId, int, boolean)2590%240%1313636311
copyBlock(ExtendedBlock, Token)1710%60%44454511
requestShortCircuitShm(String)1270%100%66363611
releaseShortCircuitFds(ShortCircuitShm.SlotId)840%40%33222211
blockGroupChecksum(StripedBlockInfo, Token, long, BlockChecksumOptions)810%n/a11262611
DataXceiver(Peer, DataNode, DataXceiverServer)780%20%22202011
blockChecksum(ExtendedBlock, Token, BlockChecksumOptions)760%n/a11262611
checkAccess(OutputStream, boolean, ExtendedBlock, Token, Op, BlockTokenIdentifier.AccessMode, StorageType[], String[])760%60%44212111
transferBlock(ExtendedBlock, Token, String, DatanodeInfo[], StorageType[], String[])520%n/a11141411
checkAndWaitForBP(ExtendedBlock)490%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