Kaynağa Gözat

flush all peers to host on joining a network

Abhishek Kondur 2 yıl önce
ebeveyn
işleme
b4a250c45b
1 değiştirilmiş dosya ile 6 ekleme ve 5 silme
  1. 6 5
      mq/publishers.go

+ 6 - 5
mq/publishers.go

@@ -139,12 +139,13 @@ func FlushNetworkPeersToHost(host *models.Host, hNode *models.Node) error {
 			ReplaceAllowedIPs:           true,
 			AllowedIPs:                  logic.GetAllowedIPs(hNode, &nodeI, nil),
 		})
-		data, err := json.Marshal(p)
-		if err != nil {
-			continue
-		}
-		publish(host, fmt.Sprintf("peer/host/%s/%s", host.ID.String(), servercfg.GetServer()), data)
+
+	}
+	data, err := json.Marshal(p)
+	if err != nil {
+		return err
 	}
+	publish(host, fmt.Sprintf("peer/host/%s/%s", host.ID.String(), servercfg.GetServer()), data)
 	return nil
 }