未验证 提交 bb086f47 编写于 作者: S smellthemoon 提交者: GitHub

Swap execution flow order in enqueue (#21845)

Signed-off-by: Nlixinguo <xinguo.li@zilliz.com>
Co-authored-by: Nlixinguo <xinguo.li@zilliz.com>
上级 73c44d4b
......@@ -227,12 +227,13 @@ type dmTaskQueue struct {
func (queue *dmTaskQueue) Enqueue(t task) error {
queue.statsLock.Lock()
defer queue.statsLock.Unlock()
err := queue.baseTaskQueue.Enqueue(t)
err := queue.addPChanStats(t)
if err != nil {
return err
}
err = queue.addPChanStats(t)
err = queue.baseTaskQueue.Enqueue(t)
if err != nil {
queue.popPChanStats(t)
return err
}
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册