From 4c5c66e7ed39bd4c2414b991acd65f41762cf151 Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Sat, 9 Nov 2024 19:38:05 +0100
Subject: [PATCH] sync

---
 synced-pool.go | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/synced-pool.go b/synced-pool.go
index a7c9892..dcd658d 100644
--- a/synced-pool.go
+++ b/synced-pool.go
@@ -97,11 +97,30 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
 					continue
 				}
 				log.Printf("Discovered host %s\n", h)
+
 				err := pool.AddRemote(h)
 				if err != nil {
 					log.Printf("Error adding remote %s: %v\n", h, err)
 				}
 			}
+			otherHosts, err := pool.Negotiate(hosts)
+			if err != nil {
+				log.Printf("Error negotiating: %v\n", err)
+			}
+			for _, h := range otherHosts {
+				if h == hostname {
+					continue
+				}
+				for _, r := range pool.remotes {
+					if r.Host == h {
+						continue
+					}
+				}
+				err := pool.AddRemote(h)
+				if err != nil {
+					log.Printf("Error adding undiscovered remote %s: %v\n", h, err)
+				}
+			}
 		}()
 	}
 	go func() {