From 385f1573548444d85d0546c2edcb9b0703dc08a0 Mon Sep 17 00:00:00 2001
From: Max Ma <mayabin@gmail.com>
Date: Tue, 8 Oct 2024 10:37:32 +0200
Subject: [PATCH] remove go routine for peerUpdate in pull

---
 controllers/hosts.go | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/controllers/hosts.go b/controllers/hosts.go
index bae8eb3e1..d1b22facb 100644
--- a/controllers/hosts.go
+++ b/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()