Commit e8c750dd authored by vicotor's avatar vicotor

fix bug

parent 0a638eb4
......@@ -166,6 +166,7 @@ func (wm *WorkerManager) AddNewWorker(id int64, worker omanager.NodeManagerServi
installOp: wm.workerInstalledOperator,
runningOp: wm.workerRunningOperator,
}
w.latestNmValue = wm.LastNmValue(w)
taskCache, err := lru.NewARC(100)
if err != nil {
......
......@@ -140,6 +140,21 @@ func (wm *WorkerManager) AddWorker(worker *Worker) error {
return errors.New("can't replace worker info")
}
func (wm *WorkerManager) LastNmValue(worker *Worker) string {
nmlist, _ := wm.WorkerNmList(worker)
if len(nmlist) == 0 {
return ""
}
for _, nmvalue := range nmlist {
endpoint, _ := wm.parseWorkerNmValue(nmvalue)
if endpoint == config.GetConfig().PublicEndpoint() {
return nmvalue
}
}
return ""
}
func (wm *WorkerManager) UpdateWorkerActive(worker *Worker) {
if !worker.online {
return
......
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