Browse Source

fix updateBranchAsync for some db

pull/281/head v1.13.3
yedf2 4 years ago
parent
commit
041b99728e
  1. 2
      dtmsvr/svr.go
  2. 2
      dtmsvr/trans_status.go
  3. 2
      dtmsvr/utils.go

2
dtmsvr/svr.go

@ -107,6 +107,8 @@ func updateBranchAsync() {
updates = append(updates, TransBranch{ updates = append(updates, TransBranch{
ModelBase: dtmutil.ModelBase{ID: updateBranch.id}, ModelBase: dtmutil.ModelBase{ID: updateBranch.id},
Gid: updateBranch.gid, Gid: updateBranch.gid,
BranchID: updateBranch.branchID,
Op: updateBranch.op,
Status: updateBranch.status, Status: updateBranch.status,
FinishTime: updateBranch.finishTime, FinishTime: updateBranch.finishTime,
}) })

2
dtmsvr/trans_status.go

@ -62,7 +62,7 @@ func (t *TransGlobal) changeBranchStatus(b *TransBranch, status string, branchPo
logger.Infof("LockGlobalSaveBranches ok: gid: %s old status: %s branches: %s", logger.Infof("LockGlobalSaveBranches ok: gid: %s old status: %s branches: %s",
b.Gid, dtmcli.StatusPrepared, b.String()) b.Gid, dtmcli.StatusPrepared, b.String())
} else { // for better performance, batch the updates of branch status } else { // for better performance, batch the updates of branch status
updateBranchAsyncChan <- branchStatus{id: b.ID, gid: t.Gid, status: status, finishTime: &now} updateBranchAsyncChan <- branchStatus{id: b.ID, gid: t.Gid, branchID: b.BranchID, op: b.Op, status: status, finishTime: &now}
} }
} }

2
dtmsvr/utils.go

@ -20,6 +20,8 @@ import (
type branchStatus struct { type branchStatus struct {
id uint64 id uint64
gid string gid string
branchID string
op string
status string status string
finishTime *time.Time finishTime *time.Time
} }

Loading…
Cancel
Save