Function rbf_wrap_up

openingd/dualopend.c:3388–3479

Takes ownership of tx_state if successful */

/* Takes ownership of tx_state if successful */
static void rbf_wrap_up(struct state *state,
			struct tx_state *tx_state,
			struct amount_sat total)
{
	enum dualopend_wire msg_type;
	char *err_reason;
	bool aborted;
	u8 *msg;

	/* BOLT #2:
	 * The sending node:
	 * - if is the *opener*:
	 *   - MUST send at least one `tx_add_output`,  which contains the
	 *   channel's funding output */
	if (state->our_role == TX_INITIATOR)
		add_funding_output(tx_state, state, total);
	else
		/* if accepter, set to an invalid number, 1 (odd is invalid) */
		tx_state->funding_serial = 1;

	/* Add all of our inputs/outputs to the changeset */
	init_changeset(tx_state, tx_state->psbt);

	if (state->our_role == TX_INITIATOR) {
		/* Send our first message; opener initiates */
		if (!send_next(state, tx_state, &tx_state->psbt, &aborted)) {
			if (!aborted)
				open_abort(state, "Peer error, has no tx updates.");
			return;
		}
	}

	if (!run_tx_interactive(state, tx_state,
				&tx_state->psbt,
				state->our_role)) {
		return;
	}

	if (state->require_confirmed_inputs[LOCAL]) {
		err_reason = validate_inputs(state, tx_state,
					     state->our_role == TX_INITIATOR ?
					     TX_ACCEPTER : TX_INITIATOR);
		if (err_reason) {
			open_abort(state, "%s", err_reason);
			return;
		}
	}

	/* Is this an eligible RBF (at least one overlapping input) */
	msg = towire_dualopend_rbf_validate(NULL, tx_state->psbt);
	wire_sync_write(REQ_FD, take(msg));
	msg = wire_sync_read(tmpctx, REQ_FD);

	while (state->developer && fromwire_dualopend_dev_memleak(msg)) {
		handle_dev_memleak(state, msg);
		msg = wire_sync_read(tmpctx, REQ_FD);
	}