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

less logs
All checks were successful
Build and Publish / BuildAndDeploy (push) Successful in 1m52s
Details

Browse Source
This commit is contained in:
matst80
2024-11-11 10:32:15 +01:00
parent 3935eb68eb
commit 1c31ff9d80
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
synced-pool.go
View File

@@ -85,10 +85,7 @@ func (p *SyncedPool) NegotiateHandler(data []byte) (uint32, []byte, error) {
negotiationCount.Inc() negotiationCount.Inc()
log.Printf("Handling negotiation\n") log.Printf("Handling negotiation\n")
for _, host := range p.ExcludeKnown(strings.Split(string(data), ";")) { for _, host := range p.ExcludeKnown(strings.Split(string(data), ";")) {
err := p.AddRemote(host) p.AddRemote(host)
if err != nil {
log.Printf("Error adding remote %s: %v\n", host, err)
}
} }
return RemoteNegotiateResponse, []byte("ok"), nil return RemoteNegotiateResponse, []byte("ok"), nil
@@ -169,10 +166,7 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, discovery Discovery)
go func(h string) { go func(h string) {
log.Printf("Discovered host %s, waiting for startup", h) log.Printf("Discovered host %s, waiting for startup", h)
time.Sleep(time.Second) time.Sleep(time.Second)
err := pool.AddRemote(h) pool.AddRemote(h)
if err != nil {
log.Printf("Error adding remote %s: %v", h, err)
}
}(chng.Host) }(chng.Host)
} else if chng.Type == watch.Deleted && known { } else if chng.Type == watch.Deleted && known {
log.Printf("Host removed %s, removing from index", chng.Host) log.Printf("Host removed %s, removing from index", chng.Host)