DatabaseTransactionMgr

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total6,231 of 7,57017%785 of 90212%5085701,3781,71583119
finishCheckQuorumReplicas(TransactionState, Set)4960%580%303010010011
updateCatalogAfterVisible(TransactionState, Database, Map, Map)4250%440%2323959511
finishCheckQuorumReplicas(TransactionState, List, Set)2660%340%1818555511
checkCommitStatus(List, TransactionState, List, TxnCommitAttachment, Set, Map, Set)24631956%313351%23334210701
checkQuorumReplicas(TransactionState, long, Partition, Tablet, int, boolean, long, List, List, List, DatabaseTransactionMgr.PublishResult, DatabaseTransactionMgr.TabletsPublishResultLogs)2140%140%88262611
checkTransactionStateBeforeCommit(Database, List, long, boolean, TransactionState)205219%38613%2223374401
finishTransaction(long, Map, Map)2000%240%1313636311
unprotectedCommitTransaction(TransactionState, Set, Map, Set, List, Database)1890%160%99434311
finishCheckPartitionVersionWithSubTxns(TransactionState, Database)1880%140%88454511
commitTransaction(long, List, List)1690%140%88404011
finishCheckPartitionVersion(TransactionState, Database, List)1340%120%77363611
preCommitTransaction2PC(List, long, List, TxnCommitAttachment)1290%200%1111343411
cleanLabel(String, boolean)1290%200%1111383811
updatePartitionNextVersion(TransactionState, Database, boolean, List)12717057%142058%1118276601
clearBackendTransactions(TransactionState)1220%160%99262611
checkReplicaContinuousVersionSucc(List, long, long, Replica, long, long, List, Set, List, List, List)1100%260%1414202011
getTabletWriteDetail(List, List, List)1060%60%44171711
getPartitionTransInfo(long, long)1050%100%66212111
abortTransaction2PC(long)930%140%88272711
beginTransaction(List, String, TUniqueId, TransactionState.TxnCoordinator, TransactionState.LoadJobSourceType, long, long)9210653%26618%1517184701
unprotectedCommitTransaction2PC(TransactionState, Database)920%100%66343411
abortTransaction(long, String, TxnCommitAttachment)890%160%99292911
unprotectedPreCommitTransaction2PC(TransactionState, Set, Map, Set, Database)860%60%44202011
unprotectAbortTransaction(long, String)840%80%55151511
unprotectUpdateInMemoryState(TransactionState, boolean)822422%12425%79162201
getTableTransInfo(long)820%60%44181811
getTransactionIdByLabel(String, List)800%120%77171711
replayUpsertTransactionState(TransactionState)760%120%77212111
waitForTransactionFinished(DatabaseIf, long, long)600%80%55171711
getTransactionStateByCallbackIdAndStatus(long, Set)600%120%77111111
replayBatchRemoveTransaction(List)590%100%66131311
produceEvent(TransactionState, Database)590%60%44141411
clearTransactionState(long)590%60%44121211
replayBatchRemoveTransaction(BatchRemoveTransactionsOperationV2)570%120%77171711
getUnFinishedPreviousLoad(long, List)541825%1118%6791401
setTableVersion(TransactionState, Database)540%60%44141411
isPreviousTransactionsFinished(long, long, long)531420%1516%89121601
getTransactionStateByCallbackId(long)500%80%55111111
isPreviousTransactionsFinished(long, List)491422%9110%5681201
unprotectWriteAllTransactionStates(DataOutput)490%60%44101011
replayDeleteTransaction(TransactionState)480%80%55131311
unprotectedRemoveUselessTxns(long, ArrayDeque, int)471928%11321%78141901
getDbTransStateInfo()430%n/a117711
checkRunningTxnExceedLimit(List)424451%3562%3521001
updateCommittedTxnCountPerTable(List)412941%8433%5771401
getSingleTranInfo(long, long)400%20%229911
removeUselessTxns(long)384654%7330%5672001
isIntersectionNotEmpty(List, List)380%100%669911
getTxnStateInfoList(TransactionStatus)350%40%33121211
getLabelState(String)340%40%337711
getMaxAlterWaterschedTxnId(OlapTable)340%40%338811
getStackTrace(Thread)330%20%225511
getTxnStateInfoList(String)320%n/a11111111
removeExpiredAndTimeoutTxns(long)311431%1150%1261001
getTxnStateInfoList(boolean, int)310%20%22121211
getDbRunningTransInfo()310%20%227711
getTxnNumByStatus(TransactionStatus)310%20%227711
lambda$getPrepareTransactionIdByCoordinateBe$13(String, long, TransactionState)310%100%664411
getTransactionIdByLabel(String)270%40%336611
unprotectedGetTransactionState(Long)251028%5116%346901
checkAndLogWriteLockDuration(long, long)251028%1150%1291201
getPrepareTransactionIdByCoordinateBe(long, String, int)240%n/a118811
awaitTransactionState(EditLog.EditLogItem, TransactionState)232350%2466%2451401
abortTransaction(String, String)230%n/a116611
cleanSubTransactions(long)230%40%337711
updateMultiTableRunningTransactionTableIds(long, List)210%40%336611
lambda$updateCatalogAfterVisible$18(TableCommitInfo, OlapTable, Long, Triple)210%40%333311
lambda$finishCheckQuorumReplicas$25(Long, long, PublishVersionTask)190%60%443311
lambda$updateCatalogAfterVisible$17(long, long, Partition, Long, Triple)180%40%333311
persistTransactionState(TransactionState)130%40%334411
getTransactionNum()120%n/a112211
lambda$getPrepareTransactionIdByCoordinateBe$14(ArrayList, TransactionState)110%n/a111111
updateCatalogAfterCommitted(TransactionState, Database, boolean)101356%1150%123701
unprotectUpsertTransactionState(TransactionState, boolean)100%20%224411
lambda$finishCheckQuorumReplicas$23(Long, Long, List)100%20%224411
commitTransaction(List, long, List, TxnCommitAttachment, Boolean)910792%5550%5633301
getRunningTxnNumsWithLock()90%n/a113311
addSubTransaction(long, long)90%n/a112211
lambda$finishCheckQuorumReplicas$24(long, TPartitionVersionInfo)90%20%221111
lambda$getTxnNumByStatus$22(TransactionStatus, TransactionState)80%20%221111
lambda$getTxnNumByStatus$21(TransactionStatus, TransactionState)80%20%221111
lambda$getPreCommittedTxnList$8(TransactionState)80%20%221111
lambda$getTxnStateInfoList$1(TransactionStatus, TransactionState)80%20%221111
unprotectedCommitTransaction(TransactionState, Set, Map, Set, Database)78091%2675%2522101
checkDatabaseDataQuota()72678%1375%131701
removeSubTransaction(long)70%n/a112211
lambda$getTxnStateInfoList$4(List, TransactionState)70%n/a112211
lambda$getTxnStateInfoList$2(List, TransactionState)70%n/a112211
lambda$getTxnStateInfoList$0(List, TransactionState)70%n/a112211
getTimeoutTxns(long)62580%1375%131801
lambda$cleanLabel$20(Set, TransactionState)60%n/a111111
lambda$cleanLabel$19(Set, TransactionState)60%n/a111111
lambda$getTxnStateInfoList$3(String, TransactionState)50%n/a111111
getFinishedTxnNums()0%n/a111111
updateDatabaseUsedQuotaData(long)0%n/a112211
lambda$updatePartitionNextVersion$16(Replica)0%n/a111111
lambda$updatePartitionNextVersion$15(Replica)0%n/a111111
lambda$unprotectedCommitTransaction$11(Long)0%n/a111111
lambda$finishTransaction$10(TableCommitInfo)0%n/a111111
lambda$getTabletWriteDetail$7(Replica)0%n/a111111
lambda$getTabletWriteDetail$6(Replica)0%n/a111111
lambda$getTabletWriteDetail$5(Replica)0%n/a111111
getDbId()0%n/a111111
getRunningTxnNums()0%n/a111111
lambda$getCommittedTxnList$9(TransactionState)675%1150%120101
DatabaseTransactionMgr(long, Env, TransactionIdGenerator)65100%n/a0101901
getCommittedTxnList()24100%n/a010901
getPreCommittedTxnList()19100%n/a010601
generatePartitionCommitInfo(OlapTable, long, long)18100%n/a010501
enqueueTransactionState(TransactionState)16100%4100%030401
updateTxnLabels(TransactionState)15100%n/a010301
writeUnlock()10100%n/a010301
writeLock()8100%n/a010301
unprotectedGetTxnIdsByLabel(String)6100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
getTransactionState(Long)100%n/a010101
static {...}100%n/a010101
lambda$updateTxnLabels$12(String)100%n/a010101