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

better logs for ping
All checks were successful
Build and Publish / BuildAndDeploy (push) Successful in 1m55s
Details

Browse Source
This commit is contained in:
matst80
2024-11-11 10:08:37 +01:00
parent c3796da0d9
commit 3935eb68eb
1 changed files with 4 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
synced-pool.go
View File

@@ -151,30 +151,6 @@ func NewSyncedPool(local *GrainLocalPool, hostname string, discovery Discovery)
server.HandleCall(RemoteNegotiate, pool.NegotiateHandler) server.HandleCall(RemoteNegotiate, pool.NegotiateHandler)
server.HandleCall(RemoteGrainChanged, pool.GrainOwnerChangeHandler) server.HandleCall(RemoteGrainChanged, pool.GrainOwnerChangeHandler)
// // TODO FIX THIS, ONLY CLIENT OR SERVER SHOULD PING
// go func() {
// for {
// for range time.Tick(time.Second * 2) {
// for _, r := range pool.remotes {
// err := DoPing(r)
// if err != nil {
// r.MissedPings++
// log.Printf("Error pinging remote %s: %v\n, missed pings: %d", r.Host, err, r.MissedPings)
// if r.MissedPings > 3 {
// log.Printf("Removing remote %s\n", r.Host)
// go pool.RemoveHost(r)
// //pool.remotes = append(pool.remotes[:i], pool.remotes[i+1:]...)
// }
// } else {
// r.MissedPings = 0
// }
// }
// connectedRemotes.Set(float64(len(pool.remotes)))
// }
// }
// }()
if discovery != nil { if discovery != nil {
go func() { go func() {
time.Sleep(time.Second * 5) time.Sleep(time.Second * 5)
@@ -388,7 +364,7 @@ func (h *RemoteHost) Ping() error {
if err != nil { if err != nil {
h.MissedPings++ h.MissedPings++
log.Printf("Error pinging remote %s: %v\n, missed pings: %d", h.Host, err, h.MissedPings) log.Printf("Error pinging remote %s, missed pings: %d", h.Host, h.MissedPings)
} else { } else {
h.MissedPings = 0 h.MissedPings = 0
@@ -408,7 +384,7 @@ func (p *SyncedPool) AddRemote(host string) error {
_, err = client.Call(Ping, Pong, []byte{}) _, err = client.Call(Ping, Pong, []byte{})
if err != nil { if err != nil {
log.Printf("Error pinging remote %s: %v\n", host, err) log.Printf("No response from new remote %s", host)
return err return err
} }
@@ -427,7 +403,7 @@ func (p *SyncedPool) AddRemote(host string) error {
time.Sleep(time.Millisecond * 200) time.Sleep(time.Millisecond * 200)
err = remote.Ping() err = remote.Ping()
if remote.MissedPings > 3 { if remote.MissedPings > 3 {
log.Printf("Error pinging remote %s: %v\n, missed pings: %d", host, err, remote.MissedPings) log.Printf("Removing host, unable to communicate with %s", host)
p.RemoveHost(&remote) p.RemoveHost(&remote)
return return
} }
@@ -438,7 +414,7 @@ func (p *SyncedPool) AddRemote(host string) error {
go func() { go func() {
for range client.Errors { for range client.Errors {
if client.ErrorCount > 3 { if client.ErrorCount > 3 {
log.Printf("Error count exceeded, removing remote %s\n", host) log.Printf("Error count exceeded, removing remote %s", host)
p.RemoveHost(&remote) p.RemoveHost(&remote)
} }
} }