()
| 498 | } |
| 499 | |
| 500 | func (c *Client) markSubscriptionTimeout() { |
| 501 | switched, addr := c.failoverAfterSubscriptionTimeout() |
| 502 | if switched { |
| 503 | log.Warnf("home subscription heartbeat timeout; switching to %s", addr) |
| 504 | } |
| 505 | } |
| 506 | |
| 507 | func (c *Client) resetReconnectFailures() { |
| 508 | if c == nil { |
no test coverage detected