Function maybe_from_gossip_store

connectd/multiplex.c:496–548

If we are streaming gossip, get something from gossip store */

/* If we are streaming gossip, get something from gossip store */
static u8 *maybe_from_gossip_store(const tal_t *ctx, struct peer *peer)
{
	u8 *msg;

	/* dev-mode can suppress all gossip */
	if (IFDEV(peer->daemon->dev_suppress_gossip, false))
		return NULL;

	/* BOLT #7:
	 *   - if the `gossip_queries` feature is negotiated:
	 *     - MUST NOT relay any gossip messages it did not generate itself,
	 *       unless explicitly requested.
	 */

	/* So, even if they didn't send us a timestamp_filter message,
	 * we *still* send our own gossip. */
	if (!peer->gs.gossip_timer) {
		return gossip_store_next(ctx, &peer->daemon->gossip_store_fd,
					 0, 0xFFFFFFFF,
					 true,
					 false,
					 &peer->gs.off,
					 &peer->daemon->gossip_store_end);
	}

	/* Not streaming right now? */
	if (!peer->gs.active)
		return NULL;

	/* This should be around to kick us every 60 seconds */
	assert(peer->gs.gossip_timer);

again:
	msg = gossip_store_next(ctx, &peer->daemon->gossip_store_fd,
				peer->gs.timestamp_min,
				peer->gs.timestamp_max,
				false,
				false,
				&peer->gs.off,
				&peer->daemon->gossip_store_end);
	/* Don't send back gossip they sent to us! */
	if (msg) {
		if (gossip_rcvd_filter_del(peer->gs.grf, msg)) {
			msg = tal_free(msg);
			goto again;
		}
		status_peer_io(LOG_IO_OUT, &peer->id, msg);
		return msg;
	}

	peer->gs.active = false;
	return NULL;
}

/* Mutual recursion */
static void send_ping(struct peer *peer);