Function write_to_subd

connectd/multiplex.c:1325–1359

These four function handle peer->subd */

/* These four function handle peer->subd */
static struct io_plan *write_to_subd(struct io_conn *subd_conn,
				     struct subd *subd)
{
	const u8 *msg;
	assert(subd->conn == subd_conn);

	/* Pop tail of send queue */
	msg = msg_dequeue(subd->outq);

	/* Nothing to send? */
	if (!msg) {
		/* If peer is closed, close this. */
		if (!subd->peer->to_peer)
			return io_close(subd_conn);

		/* Tell them to read again. */
		io_wake(&subd->peer->peer_in);
		if (subd->peer->peer_in_lastmsg != -1) {
			u64 msec = time_to_msec(timemono_between(time_mono(),
								 subd->peer->peer_in_lasttime));
			if (msec > 5000 && !subd->peer->daemon->dev_lightningd_is_slow)
				status_peer_broken(&subd->peer->id,
						   "wake delay for %s: %"PRIu64"msec",
						   peer_wire_name(subd->peer->peer_in_lastmsg),
						   msec);
			subd->peer->peer_in_lastmsg = -1;
		}

		/* Wait for them to wake us */
		return msg_queue_wait(subd_conn, subd->outq,
				      write_to_subd, subd);
	}

	return io_write_wire(subd_conn, take(msg), write_to_subd, subd);
}

static void destroy_connected_subd(struct subd *subd)
{