We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0bff309 commit 3c0cdffCopy full SHA for 3c0cdff
state.go
@@ -449,7 +449,11 @@ HANDLE_REMOTE_FAILURE:
449
defer close(fallbackCh)
450
didContact, err := m.sendPingAndWaitForAck(node.FullAddress(), ping, deadline)
451
if err != nil {
452
- m.logger.Printf("[ERR] memberlist: Failed fallback ping: %s", err)
+ var to string
453
+ if ne, ok := err.(net.Error); ok && ne.Timeout() {
454
+ to = fmt.Sprintf("timeout %s: ", probeInterval)
455
+ }
456
+ m.logger.Printf("[ERR] memberlist: Failed fallback ping: %s%s", to, err)
457
} else {
458
fallbackCh <- didContact
459
}
0 commit comments