Function read_hdr_from_peer

connectd/multiplex.c:1562–1607

}

static struct io_plan *read_hdr_from_peer(struct io_conn *peer_conn,
					  struct peer *peer)
{
	struct timemono now = time_mono();
	assert(peer->to_peer == peer_conn);

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

	/* You sent too much this second? */
	if (peer->bytes_rcvd_this_second > peer->daemon->incoming_stream_limit) {
		status_unusual_once(&peer->throttle_warned,
				    CI_UNEXPECTED
				    "Throttling incoming peer %s:"
				    " too much traffic",
				    fmt_node_id(tmpctx, &peer->id));

		/* Set timer for next second (if not already) */
		if (!peer->recv_timer) {
			peer->recv_timer = new_abstimer(&peer->daemon->timers,
							peer,
							timemono_add(peer->bytes_rcvd_start_time,
								     time_from_sec(1)),
							recv_throttle_timeout,
							peer);
		}
		return io_wait(peer_conn, &peer->peer_in,
			       read_hdr_from_peer, peer);
	}

	/* BOLT #8:
	 *
	 * ### Receiving and Decrypting Messages
	 *
	 * In order to decrypt the _next_ message in the network
	 * stream, the following steps are completed:
	 *
	 *  1. Read _exactly_ 18 bytes from the network buffer.
	 */
	peer->peer_in = tal_arr(peer, u8, CRYPTOMSG_HDR_SIZE);
	return io_read(peer_conn, peer->peer_in, CRYPTOMSG_HDR_SIZE,
		       read_body_from_peer, peer);
}

static struct io_plan *subd_conn_init(struct io_conn *subd_conn,
				      struct subd *subd)