tikv
/
client-go
mirror of https://github.com/tikv/client-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

set group name in twoPhaseCommitter (#718) 

Signed-off-by: glorv <glorvs@163.com>
This commit is contained in:
glorv 2023-02-27 16:39:23 +08:00 committed by GitHub
parent 891ef575be
commit 596b79404d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
txnkv/transaction/2pc.go
View File

@ -454,14 +454,15 @@ func (c *PlainMutations) AppendMutation(mutation PlainMutation) {
// newTwoPhaseCommitter creates a twoPhaseCommitter. // newTwoPhaseCommitter creates a twoPhaseCommitter.
func newTwoPhaseCommitter(txn *KVTxn, sessionID uint64) (*twoPhaseCommitter, error) { func newTwoPhaseCommitter(txn *KVTxn, sessionID uint64) (*twoPhaseCommitter, error) {
return &twoPhaseCommitter{ return &twoPhaseCommitter{
store: txn.store, store: txn.store,
txn: txn, txn: txn,
startTS: txn.StartTS(), startTS: txn.StartTS(),
sessionID: sessionID, sessionID: sessionID,
regionTxnSize: map[uint64]int{}, regionTxnSize: map[uint64]int{},
isPessimistic: txn.IsPessimistic(), isPessimistic: txn.IsPessimistic(),
binlog: txn.binlog, binlog: txn.binlog,
diskFullOpt: kvrpcpb.DiskFullOpt_NotAllowedOnFull, diskFullOpt: kvrpcpb.DiskFullOpt_NotAllowedOnFull,
resourceGroupName: txn.resourceGroupName,
}, nil }, nil
} }