Function handle_peer_in

openingd/dualopend.c:4196–4307

~ Standard "peer sent a message, handle it" demuxer. Though it really only * handles a few messages, we use the standard form as principle of least * surprise. */

 * handles a few messages, we use the standard form as principle of least
 * surprise. */
static u8 *handle_peer_in(struct state *state)
{
	u8 *msg = peer_read(tmpctx, state->pps);
	enum peer_wire t = fromwire_peektype(msg);
	struct channel_id channel_id;

	if (state->aborted_err && t != WIRE_TX_ABORT) {
		status_debug("Rcvd %s but already"
			     " sent TX_ABORT,"
			     " dropping",
			     peer_wire_name(t));
		return NULL;
	}

	switch (t) {
	case WIRE_OPEN_CHANNEL2:
		if (state->channel) {
			status_broken("Unexpected message %s",
				      peer_wire_name(t));
			peer_failed_connection_lost();
		}
		accepter_start(state, msg);
		return NULL;
	case WIRE_START_BATCH:
		/* We ignore batch messages as we dont need them */
		return NULL;
	case WIRE_COMMITMENT_SIGNED:
		handle_commit_signed(state, msg);
		return NULL;
	case WIRE_TX_SIGNATURES:
		handle_tx_sigs(state, msg);
		return NULL;
	case WIRE_CHANNEL_READY:
		return handle_channel_ready(state, msg);
	case WIRE_SHUTDOWN:
		handle_peer_shutdown(state, msg);
		return NULL;
	case WIRE_TX_INIT_RBF:
		rbf_remote_start(state, msg);
		return NULL;
	case WIRE_TX_ABORT:
		handle_tx_abort(state, msg);
		return NULL;
	case WIRE_ANNOUNCEMENT_SIGNATURES:
		handle_announcement_signatures(state, msg);
		return NULL;
		/* Otherwise we fall through */
	case WIRE_INIT:
	case WIRE_ERROR:
	case WIRE_OPEN_CHANNEL:
	case WIRE_ACCEPT_CHANNEL:
	case WIRE_FUNDING_CREATED:
	case WIRE_FUNDING_SIGNED:
	case WIRE_CLOSING_SIGNED:
	case WIRE_CLOSING_COMPLETE:
	case WIRE_CLOSING_SIG:
	case WIRE_UPDATE_ADD_HTLC:
	case WIRE_UPDATE_FULFILL_HTLC: