Skip to content

N
nodemanager
Commit 029efb42 authored by vicotor's avatar vicotor
Browse files
Options

update

parent b90c22d8
Show whitespace changes
Inline Side-by-side
Showing with 3 additions and 3 deletions
server/workerManager.go
View file @ 029efb42
...@@ -521,9 +521,9 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) { ...@@ -521,9 +521,9 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
"worker-addr": worker.workerAddr, "worker-addr": worker.workerAddr,
}).Infof("receive worker resource map:%v", msg.ResourceMap) }).Infof("receive worker resource map:%v", msg.ResourceMap)
if !worker.registed { //if !worker.registed {
continue // continue
} //}
worker.info.resourceInfo = msg.ResourceMap worker.info.resourceInfo = msg.ResourceMap
wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap) wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap)
wm.UpdateWorkerBootedResourceInfo(worker, msg.ResourceMap.BootupMap) wm.UpdateWorkerBootedResourceInfo(worker, msg.ResourceMap.BootupMap)
......
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