processCommandFromActive(DatanodeCommand, InetSocketAddress) |  | 0% |  | 0% | 17 | 17 | 55 | 55 | 1 | 1 |
updateActorStatesFromHeartbeat(BPServiceActor, NNHAStatusHeartbeat) |  | 0% |  | 0% | 13 | 13 | 24 | 24 | 1 | 1 |
refreshNNList(String, List, ArrayList, ArrayList) |  | 0% |  | 0% | 6 | 6 | 23 | 23 | 1 | 1 |
BPOfferService(String, List, List, List, DataNode) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
processCommandFromActor(DatanodeCommand, BPServiceActor) |  | 0% |  | 0% | 7 | 7 | 14 | 14 | 1 | 1 |
registrationSucceeded(BPServiceActor, DatanodeRegistration) |  | 0% |  | 0% | 5 | 5 | 15 | 15 | 1 | 1 |
notifyNamenodeBlock(ExtendedBlock, ReceivedDeletedBlockInfo.BlockStatus, String, String, boolean) |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
toString() |  | 0% |  | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
setNamespaceInfo(NamespaceInfo) |  | 0% |  | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
blockIdArrayToString(long[]) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
verifyAndSetNamespaceInfo(BPServiceActor, NamespaceInfo) |  | 0% |  | 0% | 5 | 5 | 13 | 13 | 1 | 1 |
processCommandFromStandby(DatanodeCommand, InetSocketAddress) |  | 0% |  | 0% | 4 | 4 | 12 | 12 | 1 | 1 |
getBlockPoolId(boolean) |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
reportRemoteBadBlock(DatanodeInfo, ExtendedBlock) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
checkNSEquality(Object, Object, String) |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
signalRollingUpgrade(RollingUpgradeStatus) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
checkBlock(ExtendedBlock) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
reportBadBlocks(ExtendedBlock, String, StorageType) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
shutdownActor(BPServiceActor) |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
trySendErrorReport(int, String) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
containsNN(InetSocketAddress) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
createRegistration() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
isAlive() |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
scheduleBlockReport(long) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
isSlownode() |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
getActiveNN() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
triggerDeletionReportForTests() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
start() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
stop() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
join() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
triggerBlockReportForTests() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
triggerHeartbeatForTests() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
static {...} |  | 0% |  | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getNamespaceInfo() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
hasBlockPoolId() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
notifyNamenodeReceivedBlock(ExtendedBlock, String, String, boolean) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
notifyNamenodeReceivingBlock(ExtendedBlock, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
notifyNamenodeDeletedBlock(ExtendedBlock, String) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
shouldRetryInit() |  | 0% |  | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
isInitialized() |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
readLock() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
readUnlock() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
writeLock() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
writeUnlock() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getBlockPoolId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getBPServiceActors() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
countNameNodes() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getNameserviceId() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getDataNode() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |