Function maybe_gossip_msg

connectd/multiplex.c:622–701

Gossip response or something from gossip store */

/* Gossip response or something from gossip store */
static const u8 *maybe_gossip_msg(const tal_t *ctx, struct peer *peer)
{
	const u8 *msg;
	struct timemono now;
	struct gossmap *gossmap;
	u32 timestamp;
	const u8 **msgs;

	/* If it's been over a second, make a fresh start. */
	now = time_mono();
	if (time_to_sec(timemono_between(now, peer->gs.bytes_start_time)) > 0) {
		peer->gs.bytes_start_time = now;
		peer->gs.bytes_this_second = 0;
	}

	/* Sent too much this second? */
	if (peer->gs.bytes_this_second > peer->daemon->gossip_stream_limit) {
		/* Replace normal timer with a timer after throttle. */
		peer->gs.active = false;
		tal_free(peer->gs.gossip_timer);
		peer->gs.gossip_timer
			= new_abstimer(&peer->daemon->timers,
				       peer,
				       timemono_add(peer->gs.bytes_start_time,
						    time_from_sec(1)),
				       wake_gossip, peer);
		return NULL;
	}

	gossmap = get_gossmap(peer->daemon);

	/* This can return more than one. */
	msgs = maybe_create_query_responses(tmpctx, peer, gossmap);
	if (tal_count(msgs) > 0) {
		/* We return the first one for immediate sending, and queue
		 * others for future.  We add all the lengths now though! */
		for (size_t i = 0; i < tal_count(msgs); i++) {
			peer->gs.bytes_this_second += tal_bytelen(msgs[i]);
			status_peer_io(LOG_IO_OUT, &peer->id, msgs[i]);
			if (i > 0)
				msg_to_peer_outq(peer, take(msgs[i]));
		}
		return msgs[0];
	}

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

	/* 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 = gossmap_stream_next(ctx, gossmap, peer->gs.iter, &timestamp);