| 205 | } |
| 206 | |
| 207 | static void enable_gossip_stream(struct seeker *seeker, struct peer *peer) |
| 208 | { |
| 209 | /* We seek some way back, to take into account propagation time */ |
| 210 | const u32 polltime = GOSSIP_SEEKER_INTERVAL(seeker) * 10; |
| 211 | u32 start = seeker->daemon->rstate->last_timestamp; |
| 212 | u8 *msg; |
| 213 | |
| 214 | if (start > polltime) |
| 215 | start -= polltime; |
| 216 | else |
| 217 | start = 0; |
| 218 | |
| 219 | status_peer_debug(&peer->id, "seeker: starting gossip"); |
| 220 | |
| 221 | /* This is allowed even if they don't understand it (odd) */ |
| 222 | msg = towire_gossip_timestamp_filter(NULL, |
| 223 | &chainparams->genesis_blockhash, |
| 224 | start, |
| 225 | UINT32_MAX); |
| 226 | queue_peer_msg(peer, take(msg)); |
| 227 | } |
| 228 | |
| 229 | static void normal_gossip_start(struct seeker *seeker, struct peer *peer) |
| 230 | { |
no test coverage detected