Commit 401d6169 authored by vicotor's avatar vicotor

update

parent 68970e05
...@@ -571,12 +571,14 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) { ...@@ -571,12 +571,14 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
wm.UpdateWorkerDeviceStatusInfo(worker, msg.Status.DeviceStatus) wm.UpdateWorkerDeviceStatusInfo(worker, msg.Status.DeviceStatus)
case *omanager.WorkerMessage_ResourceMap: case *omanager.WorkerMessage_ResourceMap:
if !worker.registed {
continue
}
l.WithFields(log.Fields{ l.WithFields(log.Fields{
"registed": worker.registed,
"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 {
continue
}
worker.info.resourceInfo = msg.ResourceMap worker.info.resourceInfo = msg.ResourceMap
wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap) wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap)
......
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