mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

name

Browse Source
This commit is contained in:
matst80
2024-11-09 13:15:48 +01:00
parent ec91990ea0
commit c87f4a01ab
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
synced-pool.go
View File

@@ -83,9 +83,9 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, d Discovery) (*Synced
remoteIndex: make(map[CartId]*RemoteGrainPool), remoteIndex: make(map[CartId]*RemoteGrainPool),
} }
if d != nil { if d != nil {
cartPurge := time.NewTicker(time.Minute) discoveryTimer := time.NewTicker(time.Second * 5)
go func() { go func() {
<-cartPurge.C <-discoveryTimer.C
hosts, err := d.Discover() hosts, err := d.Discover()
if err != nil { if err != nil {
log.Printf("Error discovering hosts: %v\n", err) log.Printf("Error discovering hosts: %v\n", err)