update server

server/workerManager.go

@@ -556,7 +556,8 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 				}
 				l.WithFields(log.Fields{
 					"worker-addr": worker.workerAddr,
-				}).Debugf("receive worker resource map:%v", msg.ResourceMap)
+				}).Infof("receive worker resource map:%v", msg.ResourceMap)
+				worker.info.resourceInfo = msg.ResourceMap
 				wm.UpdateWorkerResourceInfo(worker, msg.ResourceMap.ResourceMap)
 
 			case *omanager.WorkerMessage_FetchStandardTask:
@@ -636,7 +637,7 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 					continue
 				}
 				usageData, _ := json.Marshal(msg.DeviceUsage)
-				wm.UpdateWorkerDeviceInfo(worker, string(usageData))
+				wm.UpdateWorkerUsageInfo(worker, string(usageData))
 
 				worker.info.deviceUsageInfo = msg.DeviceUsage.Usage
 				l.WithFields(log.Fields{

server/workerstatu.go

@@ -27,6 +27,7 @@ func (wm *WorkerManager) UpdateWorkerDeviceInfo(worker *Worker, deviceInfos stri
 
 func (wm *WorkerManager) UpdateWorkerResourceInfo(worker *Worker, resourceInfo []byte) {
 	rstr := hex.EncodeToString(resourceInfo)
+	log.WithField("resourceinfo", rstr).Infof("update resourceinfo")
 	wm.rdb.Set(context.Background(), workerResourceInfoKey(worker), rstr, 0)
 }