Commit bbc8852a authored by duanjinfei's avatar duanjinfei

fix time ticker

parent 7ef255aa
...@@ -94,7 +94,7 @@ func (m *ModelHandler) MonitorModelInfo() { ...@@ -94,7 +94,7 @@ func (m *ModelHandler) MonitorModelInfo() {
if err != nil { if err != nil {
log.WithError(err).Error("Error writing models.json") log.WithError(err).Error("Error writing models.json")
} }
ticker = time.NewTicker(time.Minute * 10) ticker.Reset(time.Minute * 10)
} }
} }
} }
......
...@@ -138,7 +138,7 @@ func (m *MonitorNm) monitorNodeManagerSeed() { ...@@ -138,7 +138,7 @@ func (m *MonitorNm) monitorNodeManagerSeed() {
nodeManagerArr = append(nodeManagerArr, &NodeManager{Info: node, IsUsed: false, IsExist: true}) nodeManagerArr = append(nodeManagerArr, &NodeManager{Info: node, IsUsed: false, IsExist: true})
} }
m.IsInit = true m.IsInit = true
ticker = time.NewTicker(time.Minute * 10) ticker.Reset(time.Minute * 10)
} }
} }
} }
...@@ -195,7 +195,7 @@ func (n *NodeManagerHandler) ReportResourceMap(dockerOp *operate.DockerOp) { ...@@ -195,7 +195,7 @@ func (n *NodeManagerHandler) ReportResourceMap(dockerOp *operate.DockerOp) {
} }
params := utils.BuildParams(dockerOp.ReportModelIds, bootUpModelIds) params := utils.BuildParams(dockerOp.ReportModelIds, bootUpModelIds)
n.msgRespWorker.RegisterMsgResp(n.nodeManager, n.worker, SubmitResourceMapRes, params) n.msgRespWorker.RegisterMsgResp(n.nodeManager, n.worker, SubmitResourceMapRes, params)
ticker = time.NewTicker(time.Minute * 10) ticker.Reset(time.Minute * 10)
} }
} }
} }
......
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