Commit 7956b770 authored by duanjinfei's avatar duanjinfei

add standard task handler

parent 9f0883f3
...@@ -192,17 +192,24 @@ func handlerStandardTask(nodeManager *models.NodeManagerClient, ...@@ -192,17 +192,24 @@ func handlerStandardTask(nodeManager *models.NodeManagerClient,
worker nodeManagerV1.NodeManagerService_RegisterWorkerClient, worker nodeManagerV1.NodeManagerService_RegisterWorkerClient,
msgRespWorker *RespMsgWorker, msgRespWorker *RespMsgWorker,
taskMsgWorker *TaskHandler) { taskMsgWorker *TaskHandler) {
ticker := time.NewTicker(time.Second * 3)
for { for {
for taskMsgWorker.IsExecStandardTask { select {
} case <-ticker.C:
noExecAiTaskTime := time.Now() {
for !taskMsgWorker.IsExecAiTask { if taskMsgWorker.IsExecStandardTask {
since := time.Since(noExecAiTaskTime) continue
if since.Seconds() == 30 { }
msgRespWorker.RegisterMsgResp(nodeManager, worker, FetchStandardTaskResp, nil) noExecAiTaskTime := time.Now()
taskMsgWorker.IsExecStandardTask = true for !taskMsgWorker.IsExecAiTask {
noExecAiTaskTime = time.Now() since := time.Since(noExecAiTaskTime)
break if since.Seconds() == 30 {
msgRespWorker.RegisterMsgResp(nodeManager, worker, FetchStandardTaskResp, nil)
taskMsgWorker.IsExecStandardTask = true
noExecAiTaskTime = time.Now()
break
}
}
} }
} }
} }
......
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