| 202 | } |
| 203 | |
| 204 | static bool peer_made_progress(struct seeker *seeker, const struct peer *peer) |
| 205 | { |
| 206 | /* Has it made progress (at least one valid update per second)? If |
| 207 | * not, we assume it's finished, and if it hasn't, we'll end up |
| 208 | * querying backwards in next steps. */ |
| 209 | if (peer->query_reply_counter |
| 210 | >= seeker->prev_gossip_count + GOSSIP_SEEKER_INTERVAL(seeker)) { |
| 211 | seeker->prev_gossip_count = peer->query_reply_counter; |
| 212 | return true; |
| 213 | } |
| 214 | |
| 215 | return false; |
| 216 | } |
| 217 | |
| 218 | static void disable_gossip_stream(struct seeker *seeker, struct peer *peer) |
| 219 | { |
no outgoing calls
no test coverage detected