diff --git a/dtmsvr/svr.go b/dtmsvr/svr.go
index 8e55512..166d777 100644
--- a/dtmsvr/svr.go
+++ b/dtmsvr/svr.go
@@ -107,6 +107,8 @@ func updateBranchAsync() {
 				updates = append(updates, TransBranch{
 					ModelBase:  dtmutil.ModelBase{ID: updateBranch.id},
 					Gid:        updateBranch.gid,
+					BranchID:   updateBranch.branchID,
+					Op:         updateBranch.op,
 					Status:     updateBranch.status,
 					FinishTime: updateBranch.finishTime,
 				})
diff --git a/dtmsvr/trans_status.go b/dtmsvr/trans_status.go
index 2ab720f..6f6a344 100644
--- a/dtmsvr/trans_status.go
+++ b/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",
 			b.Gid, dtmcli.StatusPrepared, b.String())
 	} 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}
 	}
 }
 
diff --git a/dtmsvr/utils.go b/dtmsvr/utils.go
index 3afac50..8f8263c 100644
--- a/dtmsvr/utils.go
+++ b/dtmsvr/utils.go
@@ -20,6 +20,8 @@ import (
 type branchStatus struct {
 	id         uint64
 	gid        string
+	branchID   string
+	op         string
 	status     string
 	finishTime *time.Time
 }