Commit 59f12f26 authored by duanjinfei's avatar duanjinfei

add standard task handler

parent 7956b770
...@@ -192,7 +192,7 @@ func handlerStandardTask(nodeManager *models.NodeManagerClient, ...@@ -192,7 +192,7 @@ 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) ticker := time.NewTicker(time.Second * 30)
for { for {
select { select {
case <-ticker.C: case <-ticker.C:
...@@ -200,19 +200,14 @@ func handlerStandardTask(nodeManager *models.NodeManagerClient, ...@@ -200,19 +200,14 @@ func handlerStandardTask(nodeManager *models.NodeManagerClient,
if taskMsgWorker.IsExecStandardTask { if taskMsgWorker.IsExecStandardTask {
continue continue
} }
noExecAiTaskTime := time.Now() if !taskMsgWorker.IsExecAiTask {
for !taskMsgWorker.IsExecAiTask {
since := time.Since(noExecAiTaskTime)
if since.Seconds() == 30 {
msgRespWorker.RegisterMsgResp(nodeManager, worker, FetchStandardTaskResp, nil) msgRespWorker.RegisterMsgResp(nodeManager, worker, FetchStandardTaskResp, nil)
taskMsgWorker.IsExecStandardTask = true taskMsgWorker.IsExecStandardTask = true
noExecAiTaskTime = time.Now()
break break
} }
} }
} }
} }
}
} }
// handlerMsg 通过 goroutine 处理Msg // handlerMsg 通过 goroutine 处理Msg
......
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