writeBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo[], StorageType[], DatanodeInfo, BlockConstructionStage, int, long, long, long, DataChecksum, CachingStrategy, boolean, boolean, boolean[], String, String[]) |  | 0% |  | 0% | 39 | 39 | 162 | 162 | 1 | 1 |
replaceBlock(ExtendedBlock, StorageType, Token, String, DatanodeInfo, String) |  | 0% |  | 0% | 8 | 8 | 88 | 88 | 1 | 1 |
run() |  | 0% |  | 0% | 21 | 21 | 76 | 76 | 1 | 1 |
readBlock(ExtendedBlock, Token, String, long, long, boolean, CachingStrategy) |  | 0% |  | 0% | 6 | 6 | 55 | 55 | 1 | 1 |
requestShortCircuitFds(ExtendedBlock, Token, ShortCircuitShm.SlotId, int, boolean) |  | 0% |  | 0% | 13 | 13 | 63 | 63 | 1 | 1 |
copyBlock(ExtendedBlock, Token) |  | 0% |  | 0% | 4 | 4 | 45 | 45 | 1 | 1 |
requestShortCircuitShm(String) |  | 0% |  | 0% | 6 | 6 | 36 | 36 | 1 | 1 |
releaseShortCircuitFds(ShortCircuitShm.SlotId) |  | 0% |  | 0% | 3 | 3 | 22 | 22 | 1 | 1 |
blockGroupChecksum(StripedBlockInfo, Token, long, BlockChecksumOptions) |  | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
DataXceiver(Peer, DataNode, DataXceiverServer) |  | 0% |  | 0% | 2 | 2 | 20 | 20 | 1 | 1 |
checkAccess(OutputStream, boolean, ExtendedBlock, Token, Op, BlockTokenIdentifier.AccessMode, StorageType[], String[]) |  | 0% |  | 0% | 4 | 4 | 21 | 21 | 1 | 1 |
blockChecksum(ExtendedBlock, Token, BlockChecksumOptions) |  | 0% | | n/a | 1 | 1 | 26 | 26 | 1 | 1 |
transferBlock(ExtendedBlock, Token, String, DatanodeInfo[], StorageType[], String[]) |  | 0% | | n/a | 1 | 1 | 14 | 14 | 1 | 1 |
checkAndWaitForBP(ExtendedBlock) |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
updateCurrentThreadName(String) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
sendShmSuccessResponse(DomainSocket, ShortCircuitRegistry.NewShmInfo) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
writeSuccessWithChecksumInfo(BlockSender, DataOutputStream) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
stopWriter() |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
getBlockReceiver(ExtendedBlock, StorageType, DataInputStream, String, String, BlockConstructionStage, long, long, long, String, DatanodeInfo, DataNode, DataChecksum, CachingStrategy, boolean, boolean, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
incrReadWriteOpMetrics(Op) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
decrReadWriteOpMetrics(Op) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
writeResponse(DataTransferProtos.Status, String, OutputStream) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
sendOOB() |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
collectThreadLocalStates() |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getBufferedOutputStream() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
checkAccess(OutputStream, boolean, ExtendedBlock, Token, Op, BlockTokenIdentifier.AccessMode) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
sendShmErrorResponse(DataTransferProtos.Status, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
releaseSocket() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
create(Peer, DataNode, DataXceiverServer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
sendResponse(DataTransferProtos.Status, String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
incrDatanodeNetworkErrors() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
elapsed() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setCurrentBlockReceiver(BlockReceiver) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getDataNode() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getOutputStream() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getCurrentBlockReceiver() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |