DatabaseTransactionMgr

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,941 of 7,96750%554 of 98643%4126208561,83248127
finishCheckQuorumReplicas(TransactionState, Set)4900%580%303010010011
checkCommitStatus(List, TransactionState, List, TxnCommitAttachment, Set, Map, Set)31538354%334758%24415513601
unprotectedCommitTransaction(TransactionState, Set, Map, Set, List, Database)2450%260%1414545411
checkQuorumReplicas(TransactionState, long, Partition, Tablet, int, boolean, long, List, List, List, DatabaseTransactionMgr.PublishResult, DatabaseTransactionMgr.TabletsPublishResultLogs)193219%10428%78202601
finishCheckPartitionVersionWithSubTxns(TransactionState, Database)1880%140%88454511
commitTransaction(long, List, List)1660%140%88404011
updatePartitionNextVersion(TransactionState, Database, boolean, List)12717157%132161%1018276601
updateCatalogAfterVisible(TransactionState, Database, Map, Map)10633676%152965%1223259701
getPartitionTransInfo(long, long)970%100%66212111
getTabletWriteDetail(List, List, List)910%60%44171711
abortTransaction2PC(long)880%140%88272711
cleanLabel(String, boolean)765341%14630%811223801
checkTransactionStateBeforeCommit(Database, List, long, boolean, TransactionState)759756%212352%1523184501
getTableTransInfo(long)740%60%44181811
getTransactionIdByLabel(String, List)680%120%77171711
isPreviousTransactionsFinished(long, long, long)670%160%99161611
getTransactionStateByCallbackIdAndStatus(long, Set)600%120%77111111
replayBatchRemoveTransaction(List)590%100%66131311
finishTransaction(long, Map, Map)5814571%131145%1113186301
getResourceGroupSuccQuorum()543841%8433%5792001
checkReplicaContinuousVersionSucc(List, long, long, Replica, long, long, List, Set, List, List, List)536555%191136%141682101
beginTransaction(List, String, TUniqueId, TransactionState.TxnCoordinator, TransactionState.LoadJobSourceType, long, long)5214974%191340%1317104801
getTransactionStateByCallbackId(long)500%80%55111111
isPreviousTransactionsFinished(long, List)491422%9110%5681201
preCommitTransaction2PC(List, long, List, TxnCommitAttachment)488463%14630%1011123401
replayDeleteTransaction(TransactionState)480%80%55131311
getDbTransStateInfo()440%n/a118811
unprotectUpdateInMemoryState(TransactionState, boolean)416360%41477%31092301
clearBackendTransactions(TransactionState)388468%61062%4962601
finishCheckPartitionVersion(TransactionState, Database, List)369873%3975%37113601
getTxnStateInfoList(TransactionStatus)350%40%33121211
getLabelState(String)340%40%337711
getStackTrace(Thread)330%20%225511
getTxnStateInfoList(String)320%n/a11111111
unprotectedCommitTransaction2PC(TransactionState, Database)319074%71161%710134101
getTxnStateInfoList(boolean, int)310%20%22121211
getTransactionIdByLabel(String)270%40%336611
checkAndLogWriteLockDuration(long, long)251028%1150%1291201
removeExpiredAndTimeoutTxns(long)231437%1150%1261001
abortTransaction(String, String)230%n/a116611
unprotectAbortTransaction(long, String)223460%4450%4551501
updateMultiTableRunningTransactionTableIds(long, List)210%40%336611
getUnFinishedPreviousLoad(long, List)205272%5758%4751401
checkRunningTxnExceedLimit(List)194570%3562%3531101
getPreCommittedTxnList()190%n/a116611
lambda$finishCheckQuorumReplicas$26(Long, long, PublishVersionTask)190%60%443311
abortTransaction(long, String, TxnCommitAttachment)187480%8850%8962901
produceEvent(TransactionState, Database)164372%2466%2441401
setTableVersion(TransactionState, Database)163870%2466%2441401
lambda$checkCommitStatus$5(Long)160%20%222211
getDbRunningTransInfo()151651%1150%122701
waitForTransactionFinished(DatabaseIf, long, long)144676%3562%3531701
cleanSubTransactions(long)14939%3125%234701
finishCheckQuorumReplicas(TransactionState, List, Set)1324795%112367%101815501
persistTransactionState(TransactionState)130%40%334411
awaitTransactionState(EditLog.EditLogItem, TransactionState)113576%1583%1421401
getTxnNumByStatus(TransactionStatus)112064%1150%122701
commitTransaction(List, long, List, TxnCommitAttachment, Boolean)1010991%3770%3643301
updateCatalogAfterCommitted(TransactionState, Database, boolean)102369%1375%133901
lambda$updateCatalogAfterVisible$19(TableCommitInfo, OlapTable, Long, Triple)101152%3125%231301
lambda$finishCheckQuorumReplicas$24(Long, Long, List)100%20%224411
removeUselessTxns(long)97589%2880%2622001
lambda$updateCatalogAfterVisible$18(long, long, long, Partition, Long, Triple)91257%3125%231301
addSubTransaction(long, long)90%n/a112211
lambda$finishCheckQuorumReplicas$25(long, TPartitionVersionInfo)90%20%221111
clearTransactionState(long)83782%3350%3421201
unprotectedGetTransactionState(Long)82777%1583%141901
lambda$getTxnNumByStatus$22(TransactionStatus, TransactionState)80%20%221111
lambda$getPreCommittedTxnList$9(TransactionState)80%20%221111
lambda$getTxnStateInfoList$1(TransactionStatus, TransactionState)80%20%221111
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$21(Set, TransactionState)60%n/a111111
lambda$cleanLabel$20(Set, TransactionState)60%n/a111111
lambda$getTxnStateInfoList$3(String, TransactionState)0%n/a111111
getFinishedTxnNums()0%n/a111111
lambda$updatePartitionNextVersion$17(Replica)0%n/a111111
lambda$updatePartitionNextVersion$16(Replica)0%n/a111111
lambda$unprotectedCommitTransaction$12(Long)0%n/a111111
lambda$finishTransaction$11(TableCommitInfo)0%n/a111111
lambda$getTabletWriteDetail$8(Replica)0%n/a111111
lambda$getTabletWriteDetail$7(Replica)0%n/a111111
lambda$getTabletWriteDetail$6(Replica)0%n/a111111
buildLockTableListNoException(List, TransactionState)6797%3770%3621701
isIntersectionNotEmpty(List, List)3694%2880%261901
updateStreamOffset(TransactionState, Long)3594%2466%2421001
unprotectedCommitTransaction(TransactionState, Set, Map, Set, Database)12199%41275%4912901
unprotectedPreCommitTransaction2PC(TransactionState, Set, Map, Set, Database)8598%1583%1412001
replayUpsertTransactionState(TransactionState)81100%12100%0702201
updateCommittedTxnCountPerTable(List)70100%3975%3701401
DatabaseTransactionMgr(long, Env, TransactionIdGenerator)68100%n/a0101901
unprotectedRemoveUselessTxns(long, ConcurrentLinkedDeque, int)67100%51168%5901601
replayBatchRemoveTransaction(BatchRemoveTransactionsOperationV2)51100%21083%2701301
unprotectWriteAllTransactionStates(DataOutput)49100%6100%0401001
checkStreamOffset(TransactionState)36100%4100%030801
getMaxAlterWaterschedTxnId(OlapTable)34100%4100%030801
getSingleTranInfo(long, long)32100%2100%020901
lambda$getPrepareTransactionIdByCoordinateBe$14(String, long, TransactionState)31100%4660%460401
getCommittedTxnList()24100%n/a010901
getPrepareTransactionIdByCoordinateBe(long, String, int)24100%n/a010801
generatePartitionCommitInfo(OlapTable, long, long, long)19100%n/a010401
generatePartitionCommitInfo(OlapTable, long, long)18100%n/a010501
enqueueTransactionState(TransactionState)16100%4100%030401
updateTxnLabels(TransactionState)15100%n/a010301
getTransactionNum()12100%n/a010201
lambda$buildLockTableListNoException$27(TreeSet, TableIf)12100%n/a010101
lambda$buildLockTableListNoException$28(TreeSet, TableStreamUpdateInfo)11100%n/a010101
lambda$getPrepareTransactionIdByCoordinateBe$15(ArrayList, TransactionState)11100%n/a010101
writeUnlock()10100%n/a010301
writeLock()8100%n/a010301
lambda$getTxnNumByStatus$23(TransactionStatus, TransactionState)8100%2100%020101
lambda$getCommittedTxnList$10(TransactionState)8100%2100%020101
unprotectedGetTxnIdsByLabel(String)6100%n/a010101
static {...}6100%n/a010201
readLock()100%n/a010201
readUnlock()100%n/a010201
unprotectUpsertTransactionState(TransactionState, boolean)100%n/a010201
getTransactionState(Long)100%n/a010101
getRunningTxnNums()100%n/a010101
updateDatabaseUsedQuotaData(long)100%n/a010201
getRunningTxnNumsWithLock()100%n/a010101
getDbId()100%n/a010101
lambda$updateTxnLabels$13(String)100%n/a010101