update SubmitResourceMapRes

8e3360e9 · duanjinfei · a76b6b4e · 8e3360e9
Commit 8e3360e9 authored Apr 02, 2024 by duanjinfei
Hide whitespace changes
Inline Side-by-side

Showing with 8 additions and 4 deletions

monitor.go nm/monitor.go +8 -4

No files found.
--- a/nm/monitor.go
+++ b/nm/monitor.go
@@ -52,11 +52,15 @@ func (m *MonitorNm) monitorNmClient() {
 				log.Info("Distribution task worker started.......................")

 				go func(dockerOp *operate.DockerOp) {
+					ticker := time.NewTicker(time.Second * 1)
 					for {
-						if len(dockerOp.ReportTaskIds) > 0 {
-							params := utils.BuildParams(dockerOp.ReportTaskIds)
-							msgRespWorker.RegisterMsgResp(nodeManager, worker, SubmitResourceMapRes, params)
-							return
+						select {
+						case <-ticker.C:
+							if len(dockerOp.ReportTaskIds) > 0 {
+								params := utils.BuildParams(dockerOp.ReportTaskIds)
+								msgRespWorker.RegisterMsgResp(nodeManager, worker, SubmitResourceMapRes, params)
+								ticker = time.NewTicker(time.Minute * 10)
+							}
 						}
 					}
 				}(m.DockerOp)