Function next_msg_for_peer

connectd/multiplex.c:1173–1205

}

static const u8 *next_msg_for_peer(struct peer *peer)
{
	const u8 *msg;

	msg = msg_dequeue(peer->peer_outq);
	if (msg) {
		if (is_urgent(fromwire_peektype(msg))) {
			peer->peer_out_urgent--;
		}
	} else {
		/* Nothing in queue means nothing urgent in queue, surely! */
		assert(peer->peer_out_urgent == 0);

		/* Draining?  Don't send gossip. */
		if (peer->draining_state == WRITING_TO_PEER)
			return NULL;

		/* If they want us to send gossip, do so now. */
		msg = maybe_gossip_msg(NULL, peer);
		if (!msg)
			return NULL;
	}

	/* dev_disconnect can disable writes (discard everything) */
	if (peer->dev_writes_enabled) {
		if (*peer->dev_writes_enabled == 0) {
			return tal_free(msg);
		}
		(*peer->dev_writes_enabled)--;
	}

	return msg;
}

static void nonurgent_flush(struct peer *peer)
{