add log

server/workerManager.go

@@ -296,12 +296,15 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
 				log.WithField("worker", worker.uuid).Error("task not found for verify result")
 				continue
 			}
+
 			task := data.(*odysseus.TaskContent)
 			if result.TaskUuid != task.TaskUuid {
 				log.WithField("worker", worker.uuid).Error("task id not match")
 				continue
 			}
 
+			log.WithField("task-uuid", task.TaskUuid).WithField("result", result).Debug("got task result")
+
 			if result.IsSuccessed == false {
 				taskResponse := &odysseus.TaskResponse{
 					TaskUuid:         task.TaskUuid,

server/workerstatu.go

@@ -19,7 +19,7 @@ func (wm *WorkerManager) AddWorkerFirst(worker *Worker) error {
 		// add device to redis
 		priority := 0
 		_ = device // todo: set priority with device info.
-		if err := wm.rdb.LPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(priority), worker.addr).Err(); err != nil {
+		if err := wm.rdb.RPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(priority), worker.addr).Err(); err != nil {
 			continue
 		}
 	}
@@ -33,9 +33,10 @@ func (wm *WorkerManager) AddWorkerFirst(worker *Worker) error {
 func (wm *WorkerManager) AddWorkerSingle(worker *Worker) error {
 	log.WithField("worker", worker.addr).Info("add worker on back.")
 	{
-		// add device to redis
+		// add worker to redis
 		priority := 0
-		if err := wm.rdb.LPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(priority), worker.addr).Err(); err != nil {
+		if err := wm.rdb.RPush(context.Background(), config.WORKER_QUEUE_PREFIX+strconv.Itoa(priority), worker.addr).Err(); err != nil {
+			log.WithError(err).Error("add worker back to queue failed.")
 		}
 	}
 	// add worker to redis queue