Skip to content

P
power-node
Commit 41972a29 authored by duanjinfei's avatar duanjinfei
Browse files
Options

Merge branch 'master' into test

parents 6e356ee3 dbb8aeb3
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
nm/msg_handler.go
View file @ 41972a29
...@@ -53,6 +53,7 @@ func (n *NodeManagerHandler) DistributionMsgWorker(nodeManagerMsgChan chan *node ...@@ -53,6 +53,7 @@ func (n *NodeManagerHandler) DistributionMsgWorker(nodeManagerMsgChan chan *node
ackParams := utils.BuildParams(taskMsg.TaskId, isCanExecute, bootUpTime, queueWaitTime, executeTime) ackParams := utils.BuildParams(taskMsg.TaskId, isCanExecute, bootUpTime, queueWaitTime, executeTime)
msgRespWorker.RegisterMsgResp(n.nodeManager, n.worker, RespTaskAck, ackParams) msgRespWorker.RegisterMsgResp(n.nodeManager, n.worker, RespTaskAck, ackParams)
if !isCanExecute { if !isCanExecute {
log.WithField("taskId", taskMsg.TaskId).Error("The task is not executed")
return return
} }
taskMsgWorker.Wg.Add(1) taskMsgWorker.Wg.Add(1)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment