From 14dfabc652c8259b42af01a5abb7def82cbfa3a7 Mon Sep 17 00:00:00 2001
From: matst80 <mats.tornberg@gmail.com>
Date: Sat, 9 Nov 2024 22:02:03 +0100
Subject: [PATCH] small cleanup

---
 synced-pool.go | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/synced-pool.go b/synced-pool.go
index ff69246..0def54b 100644
--- a/synced-pool.go
+++ b/synced-pool.go
@@ -51,8 +51,8 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
 		remotes:     make([]*RemoteHost, 0),
 		remoteIndex: make(map[CartId]*RemoteGrainPool),
 	}
-	pingTimer := time.NewTicker(time.Second)
-	go func() {
+
+	go func(pingTimer *time.Ticker) {
 		for {
 			<-pingTimer.C
 			log.Printf("Pinging remotes %d\n", len(pool.remotes))
@@ -73,10 +73,9 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
 			}
 			connectedRemotes.Set(float64(len(pool.remotes)))
 		}
-	}()
+	}(time.NewTicker(time.Second))
 	if d != nil {
-		discoveryTimer := time.NewTicker(time.Second * 5)
-		go func() {
+		go func(discoveryTimer *time.Ticker) {
 			<-discoveryTimer.C
 			log.Printf("Looking for new nodes\n")
 			hosts, err := d.Discover()
@@ -117,7 +116,7 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
 				}
 			}
 
-		}()
+		}(time.NewTicker(time.Second * 5))
 	}
 	go func() {
 		for {