ソースを参照

remove go routine for peerUpdate in pull

Max Ma 11 ヶ月 前
コミット
385f157354
1 ファイル変更3 行追加5 行削除
  1. 3 5
      controllers/hosts.go

+ 3 - 5
controllers/hosts.go

@@ -176,11 +176,9 @@ func pull(w http.ResponseWriter, r *http.Request) {
 		}
 		if node.FailedOverBy != uuid.Nil {
 			logic.ResetFailedOverPeer(&node)
-			go func() {
-				if err := mq.PublishPeerUpdate(false); err != nil {
-					logger.Log(0, "fail to publish peer update: ", err.Error())
-				}
-			}()
+			if err := mq.PublishPeerUpdate(true); err != nil {
+				logger.Log(0, "fail to publish peer update: ", err.Error())
+			}
 		}
 	}
 	allNodes, err := logic.GetAllNodes()