Function peer_in

channeld/channeld.c:5095–5254

}

static void peer_in(struct peer *peer, const u8 *msg)
{
	enum peer_wire type = fromwire_peektype(msg);

	if (handle_peer_error_or_warning(peer->pps, msg))
		return;

	check_tx_abort(peer, msg, NULL);

	/* If we're in STFU mode and aren't waiting for a STFU mode
	 * specific message, the only valid message was tx_abort (or a
	 * belated announcement_signatures!) */
	if (is_stfu_active(peer) && !peer->stfu_wait_single_msg) {
		if (peer->splicing && type == WIRE_TX_SIGNATURES) {
			if (peer->splicing->tx_sig_msg)
				peer_failed_warn(peer->pps, &peer->channel_id,
						 "Received TX_SIGNATURES while"
						 " we already have one cached");
			peer->splicing->tx_sig_msg = tal_steal(peer->splicing,
							       msg);
			return;
		} else if (type != WIRE_ANNOUNCEMENT_SIGNATURES) {
			peer_failed_warn(peer->pps, &peer->channel_id,
					 "Received message %s when only TX_ABORT was"
					 " valid", peer_wire_name(type));
		}
	}

	/* Must get channel_ready before almost anything. */
	if (!peer->channel_ready[REMOTE]) {
		if (type != WIRE_CHANNEL_READY
		    && type != WIRE_SHUTDOWN
		    /* We expect these for v2 !! */
		    && type != WIRE_TX_SIGNATURES
		    /* lnd sends these early; it's harmless. */
		    && type != WIRE_UPDATE_FEE
		    && type != WIRE_ANNOUNCEMENT_SIGNATURES) {
			peer_failed_warn(peer->pps, &peer->channel_id,
					 "%s (%u) before funding locked",
					 peer_wire_name(type), type);
		}
	}

	/* For cleaner errors, we check message is valid during STFU mode */
	if (peer->stfu_wait_single_msg)
		if (!VALID_STFU_MESSAGE(type))
			peer_failed_warn(peer->pps, &peer->channel_id,
					 "Got invalid message during STFU "
					 "mode: %s",
					 peer_wire_name(type));

	peer->stfu_wait_single_msg = false;

	switch (type) {
	case WIRE_CHANNEL_READY:
		handle_peer_channel_ready(peer, msg);
		return;
	case WIRE_ANNOUNCEMENT_SIGNATURES: