Function onchain_failed_our_htlc

lightningd/peer_htlcs.c:1607–1696

}

void onchain_failed_our_htlc(const struct channel *channel,
			     const struct htlc_stub *htlc,
			     const char *why,
			     bool should_exist)
{
	struct lightningd *ld = channel->peer->ld;
	struct htlc_out *hout;

	log_debug(channel->log, "onchain_failed_our_htlc");
	hout = find_htlc_out(&ld->htlcs_out, channel, htlc->id);
	if (!hout) {
		/* For penalty transactions, tell onchaind about all possible
		 * HTLCs: they may not all exist any more. */
		if (should_exist)
			log_broken(channel->log, "HTLC id %"PRIu64" not found!",
				   htlc->id);
		/* Immediate corruption sanity check if this happens */
		htable_check(&ld->htlcs_out.raw, "onchain_failed_our_htlc out");
		htable_check(&ld->htlcs_in.raw, "onchain_failed_our_htlc in");
		return;
	}

	/* We can have hout->failonion (which gets set when we process the
	 * received commitment_signed), but not failed hin yet, because the peer
	 * hadn't revoke_and_acked our own commitment without that htlc. */
	if (hout->failonion && hout->in
	    && hout->in->badonion == 0
	    && !hout->in->failonion
	    && !hout->in->preimage) {
		log_debug(channel->log, "HTLC out %"PRIu64" can now fail HTLC upstream!",
			  htlc->id);
		fail_in_htlc(hout->in, hout->failonion);
	}

	/* Don't fail twice (or if already succeeded)! */
	if (hout->failonion || hout->failmsg || hout->preimage) {
		log_debug(channel->log, "HTLC id %"PRIu64" failonion = %p, failmsg = %p, preimage = %p",
			  htlc->id,
			  hout->failonion,
			  hout->failmsg,
			  hout->preimage);
		check_already_failed(channel, hout);
		return;
	}

	hout->failmsg = towire_permanent_channel_failure(hout);

	/* Force state to something which expects a failure, and save to db */
	hout->hstate = RCVD_REMOVE_HTLC;
	htlc_out_check(hout, __func__);

	bool we_filled = false;
	wallet_htlc_update(ld->wallet, hout->dbid, hout->hstate,
			   hout->preimage,
			   max_unsigned(channel->next_index[LOCAL],
					channel->next_index[REMOTE]),
			   0, hout->failonion,
			   hout->failmsg, &we_filled);