RoutineLoadManager

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total832 of 2,23762%99 of 20852%831691674931465
getAvailableBeForTask(long, long)1247136%21930%1416194001
getMinTaskBeId(String)1030%120%77222211
checkPrivAndGetAllJobs(String)700%120%77171711
cleanOverLimitRoutineLoadJobs()60811%8220%56202301
getAvailableBackendIds(long)594543%6650%67102301
getTagsFromReplicaAllocation(long, long)510%20%22111111
checkPrivAndGetJob(String, String)426861%2675%2561901
getJobByName(String)360%40%338811
addRoutineLoadJob(RoutineLoadJob, String, String)315061%2250%2321201
getJob(String, String, boolean, PatternMatcher)289877%51372%51072801
isInBlacklist(long)271128%3125%235801
getSizeOfIdToRoutineLoadTask()220%20%225511
getRoutineLoadJobByMultiLoadTaskTxnId(long)210%20%224411
getBeCurrentTasksNumMap()195273%1583%1411101
pauseRoutineLoadJob(PauseRoutineLoadCommand)187380%3350%2452101
resumeRoutineLoadJob(ResumeRoutineLoadCommand)186578%3350%2452301
replayChangeRoutineLoadJob(RoutineLoadOperation)183163%n/a0151301
alterRoutineLoadJob(AlterRoutineLoadCommand)143068%1375%1321001
createRoutineLoadJob(CreateRoutineLoadInfo, ConnectContext)138186%1375%1311901
addMultiLoadTaskTxnIdToRoutineLoadJobId(long, long)90%n/a112211
addToBlacklist(long)90%n/a112211
getTotalMaxConcurrentTaskNum()80%n/a111111
lambda$getJob$9(PatternMatcher, RoutineLoadJob)50%n/a111111
getAvailableBackendIdsForUt(long)40%n/a111111
cleanOldRoutineLoadJobs()3770%1150%121401
getBlacklist()30%n/a111111
lambda$cleanOverLimitRoutineLoadJobs$11(RoutineLoadJob)30%n/a111111
lambda$getTotalMaxConcurrentTaskNum$3(Integer)30%n/a111111
readFields(DataInput)27397%1990%1611801
getJob(String, String)21588%1150%121401
checkTaskInJob(RoutineLoadTaskInfo)21588%1150%121401
lambda$isNameUsed$7(RoutineLoadJob)2675%1150%120101
lambda$getActiveRoutineLoadJobs$0(RoutineLoadJob)2675%1150%120101
sortRoutineLoadJob(List)5798%21285%2811501
clearRoutineLoadJobIf(Predicate)66100%4100%0301901
unprotectedRemoveJobFromDb(RoutineLoadJob)55100%4100%030601
getClusterIdleSlotNum()53100%4100%0301001
stopRoutineLoadJob(StopRoutineLoadCommand)52100%n/a0101201
unprotectedAddJob(RoutineLoadJob)34100%n/a010801
isNameUsed(Long, String)34100%4100%030901
RoutineLoadManager()28100%n/a010801
replayRemoveOldRoutineLoad(RoutineLoadOperation)24100%1150%120701
write(DataOutput)22100%2100%020501
updateRoutineLoadJob()20100%4100%030501
replayCreateRoutineLoadJob(RoutineLoadJob)17100%n/a010501
processTimeoutTasks()16100%2100%020401
replayAlterRoutineLoadJob(AlterRoutineLoadJobOperationLog)15100%n/a010401
getRoutineLoadJobByState(Set)13100%n/a010301
updateBeIdToMaxConcurrentTasks()12100%n/a010301
getActiveRoutineLoadJobs()10100%n/a010301
lambda$getJob$8(RoutineLoadJob)8100%2100%020101
getAllRoutineLoadJobs()7100%n/a010101
removeMultiLoadTaskTxnIdToRoutineLoadJobId(long)7100%n/a010201
getJob(long)7100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
writeLock()5100%n/a010201
writeUnlock()5100%n/a010201
lambda$getRoutineLoadJobByState$10(Set, RoutineLoadJob)5100%n/a010101
lambda$isNameUsed$6(String, RoutineLoadJob)5100%n/a010101
static {...}4100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$2(Long)3100%n/a010101
lambda$unprotectedAddJob$5(String)2100%n/a010101
lambda$unprotectedAddJob$4(Long)2100%n/a010101
lambda$updateBeIdToMaxConcurrentTasks$1(Long)2100%n/a010101