Function read_body_from_peer_done

connectd/multiplex.c:1484–1614

static struct io_plan *read_hdr_from_peer(struct io_conn *peer_conn,
					  struct peer *peer);
static struct io_plan *read_body_from_peer_done(struct io_conn *peer_conn,
						struct peer *peer)
{
       u8 *decrypted;
       struct channel_id channel_id;
       struct subd *subd;
       enum peer_wire type;
       struct timemono handled_start;
       struct io_plan *(*next_read)(struct io_conn *peer_conn,
				    struct peer *peer) = read_hdr_from_peer;

       decrypted = cryptomsg_decrypt_body(tmpctx, &peer->cs,
					  peer->peer_in);
       if (!decrypted) {
	       status_peer_debug(&peer->id, "Bad encrypted packet len %zu",
				 tal_bytelen(peer->peer_in));
               return io_close(peer_conn);
       }

       peer->gs.bytes_rcvd_this_second += tal_bytelen(peer->peer_in);
       tal_free(peer->peer_in);

       type = fromwire_peektype(decrypted);

       /* dev_disconnect can disable read */
       if (!peer->dev_read_enabled)
	       return read_hdr_from_peer(peer_conn, peer);

       switch (dev_disconnect_in(&peer->id, type)) {
       case DEV_DISCONNECT_IN_NORMAL:
	       break;
       case DEV_DISCONNECT_IN_AFTER_RECV:
	       next_read = close_peer_dev_disconnect;
	       break;
       }

       /* We got something! */
       peer->last_recv_time = time_mono();

       /* Don't process packets while we're closing */
       if (peer->draining_state != NOT_DRAINING)
	       return next_read(peer_conn, peer);

       /* If we swallow this, just try again. */
       handled_start = time_mono();
       /* Count the CPU time for local messages (esp. gossip queries) */
       if (handle_message_locally(peer, decrypted)) {
	       peer->gs.cpu_usec_this_second
		       += time_to_usec(timemono_between(time_mono(), handled_start));
	       /* Make sure to update peer->peer_in_lastmsg so we blame correct msg! */
	       goto out;
       }

       /* After this we should be able to match to subd by channel_id */
       if (!extract_channel_id(decrypted, &channel_id)) {
	       /* We won't log this anywhere else, so do it here. */
	       status_peer_io(LOG_IO_IN, &peer->id, decrypted);