DatabaseTransactionMgr

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,725 of 7,58177%286 of 90468%2465713581,70823119
updatePartitionNextVersion(TransactionState, Database, boolean, List)11817960%112367%918266601
getPartitionTransInfo(long, long)1050%100%66212111
checkCommitStatus(List, TransactionState, List, TxnCommitAttachment, Set, Map, Set)10346281%164875%12331610701
updateCatalogAfterVisible(TransactionState, Database, Map, Map)10232376%143068%1123249501
checkQuorumReplicas(TransactionState, long, Partition, Tablet, int, boolean, long, List, List, List, DatabaseTransactionMgr.PublishResult, DatabaseTransactionMgr.TabletsPublishResultLogs)10011453%6857%5892601
checkTransactionStateBeforeCommit(Database, List, long, boolean, TransactionState)8913760%152965%1323124401
getTableTransInfo(long)820%60%44181811
isPreviousTransactionsFinished(long, long, long)670%160%99161611
getTabletWriteDetail(List, List, List)624441%3350%3481701
getTransactionStateByCallbackIdAndStatus(long, Set)600%120%77111111
replayBatchRemoveTransaction(List)590%100%66131311
getTransactionStateByCallbackId(long)500%80%55111111
preCommitTransaction2PC(List, long, List, TxnCommitAttachment)488463%14630%1011123401
replayDeleteTransaction(TransactionState)480%80%55131311
getDbTransStateInfo()440%n/a118811
getTxnStateInfoList(TransactionStatus)350%40%33121211
getStackTrace(Thread)330%20%225511
finishTransaction(long, Map, Map)3217184%61875%613106301
checkReplicaContinuousVersionSucc(List, long, long, Replica, long, long, List, Set, List, List, List)308072%91765%61432001
unprotectedCommitTransaction2PC(TransactionState, Database)256772%3770%36113401
checkAndLogWriteLockDuration(long, long)251028%1150%1291201
finishCheckPartitionVersionWithSubTxns(TransactionState, Database)2416487%11392%1844501
getTransactionIdByLabel(String, List)245670%3975%3721701
abortTransaction2PC(long)237376%7750%7852701
abortTransaction(String, String)230%n/a116611
clearTransactionState(long)223762%2466%2421201
beginTransaction(List, String, TUniqueId, TransactionState.TxnCoordinator, TransactionState.LoadJobSourceType, long, long)2018190%102268%91744801
getPreCommittedTxnList()190%n/a116611
finishCheckPartitionVersion(TransactionState, Database, List)1811686%11191%1733601
isPreviousTransactionsFinished(long, List)154876%3770%3641201
unprotectAbortTransaction(long, String)147083%2675%2511501
waitForTransactionFinished(DatabaseIf, long, long)134778%1787%1531701
persistTransactionState(TransactionState)130%40%334411
produceEvent(TransactionState, Database)124779%1583%1431401
setTableVersion(TransactionState, Database)124277%1583%1431401
commitTransaction(long, List, List)1116193%41071%4844001
getUnFinishedPreviousLoad(long, List)116184%3975%3731401
getTxnNumByStatus(TransactionStatus)112064%1150%122701
finishCheckQuorumReplicas(TransactionState, Set)1048697%134577%1330710001
commitTransaction(List, long, List, TxnCommitAttachment, Boolean)911092%2880%2633301
abortTransaction(long, String, TxnCommitAttachment)98390%61062%6942901
removeUselessTxns(long)97589%2880%2622001
lambda$getTxnNumByStatus$21(TransactionStatus, TransactionState)80%20%221111
lambda$getPreCommittedTxnList$8(TransactionState)80%20%221111
lambda$getTxnStateInfoList$1(TransactionStatus, TransactionState)80%20%221111
removeExpiredAndTimeoutTxns(long)73884%2100%0221001
checkDatabaseDataQuota()72678%1375%131701
lambda$getTxnStateInfoList$2(List, TransactionState)70%n/a112211
lambda$cleanLabel$20(Set, TransactionState)60%n/a111111
getTxnStateInfoList(boolean, int)2787%1150%1211201
getFinishedTxnNums()0%n/a111111
lambda$updatePartitionNextVersion$16(Replica)0%n/a111111
lambda$updatePartitionNextVersion$15(Replica)0%n/a111111
lambda$getTabletWriteDetail$7(Replica)0%n/a111111
lambda$getTabletWriteDetail$5(Replica)0%n/a111111
isIntersectionNotEmpty(List, List)3694%2880%261901
updateMultiTableRunningTransactionTableIds(long, List)1990%2250%232601
lambda$updateCatalogAfterVisible$17(long, long, Partition, Long, Triple)1688%1375%131301
finishCheckQuorumReplicas(TransactionState, List, Set)26599%52985%51805501
unprotectedCommitTransaction(TransactionState, Set, Map, Set, List, Database)18899%21487%2914301
clearBackendTransactions(TransactionState)12199%11593%1902601
unprotectedCommitTransaction(TransactionState, Set, Map, Set, Database)8698%2675%2512101
unprotectedPreCommitTransaction2PC(TransactionState, Set, Map, Set, Database)8598%1583%1412001
cleanLabel(String, boolean)129100%21890%21103801
unprotectUpdateInMemoryState(TransactionState, boolean)104100%18100%01002301
checkRunningTxnExceedLimit(List)88100%1787%1501101
replayUpsertTransactionState(TransactionState)76100%12100%0702101
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
awaitTransactionState(EditLog.EditLogItem, TransactionState)46100%6100%0401401
getSingleTranInfo(long, long)40100%2100%020901
unprotectedGetTransactionState(Long)35100%6100%040901
getLabelState(String)34100%1375%130701
getMaxAlterWaterschedTxnId(OlapTable)34100%4100%030801
getTxnStateInfoList(String)32100%n/a0101101
getDbRunningTransInfo()31100%2100%020701
getTimeoutTxns(long)31100%4100%030801
lambda$getPrepareTransactionIdByCoordinateBe$13(String, long, TransactionState)31100%3770%360401
getTransactionIdByLabel(String)27100%1375%130601
getCommittedTxnList()24100%n/a010901
getPrepareTransactionIdByCoordinateBe(long, String, int)24100%n/a010801
updateCatalogAfterCommitted(TransactionState, Database, boolean)23100%2100%020701
cleanSubTransactions(long)23100%4100%030701
lambda$updateCatalogAfterVisible$18(TableCommitInfo, OlapTable, Long, Triple)21100%1375%130301
lambda$finishCheckQuorumReplicas$25(Long, long, PublishVersionTask)19100%2466%240301
generatePartitionCommitInfo(OlapTable, long, long)18100%n/a010501
enqueueTransactionState(TransactionState)16100%4100%030401
updateTxnLabels(TransactionState)15100%n/a010301
getTransactionNum()12100%n/a010201
lambda$getPrepareTransactionIdByCoordinateBe$14(ArrayList, TransactionState)11100%n/a010101
writeUnlock()10100%n/a010301
lambda$finishCheckQuorumReplicas$23(Long, Long, List)10100%2100%020401
addSubTransaction(long, long)9100%n/a010201
lambda$finishCheckQuorumReplicas$24(long, TPartitionVersionInfo)9100%2100%020101
writeLock()8100%n/a010301
lambda$getTxnNumByStatus$22(TransactionStatus, TransactionState)8100%2100%020101
lambda$getCommittedTxnList$9(TransactionState)8100%2100%020101
removeSubTransaction(long)7100%n/a010201
lambda$getTxnStateInfoList$4(List, TransactionState)7100%n/a010201
lambda$getTxnStateInfoList$0(List, TransactionState)7100%n/a010201
unprotectedGetTxnIdsByLabel(String)6100%n/a010101
lambda$cleanLabel$19(Set, TransactionState)6100%n/a010101
readLock()5100%n/a010201
readUnlock()5100%n/a010201
unprotectUpsertTransactionState(TransactionState, boolean)5100%n/a010201
lambda$getTxnStateInfoList$3(String, TransactionState)5100%n/a010101
getTransactionState(Long)100%n/a010101
getRunningTxnNums()100%n/a010101
updateDatabaseUsedQuotaData(long)100%n/a010201
getRunningTxnNumsWithLock()100%n/a010101
lambda$unprotectedCommitTransaction$11(Long)100%n/a010101
lambda$finishTransaction$10(TableCommitInfo)100%n/a010101
lambda$getTabletWriteDetail$6(Replica)100%n/a010101
static {...}100%n/a010101
getDbId()100%n/a010101
lambda$updateTxnLabels$12(String)100%n/a010101