Function htlcs_notify_new_block

lightningd/peer_htlcs.c:2918–3015

}

void htlcs_notify_new_block(struct lightningd *ld)
{
	bool removed;
	u32 height = get_block_height(ld->topology);

	/* BOLT #2:
	 *
	 *   - if an HTLC which it offered is in either node's current
	 *   commitment transaction, AND is past this timeout deadline:
	 *     - SHOULD send an `error` to the receiving peer (if connected).
	 *     - MUST fail the channel.
	 */
	/* FIXME: use db to look this up in one go (earliest deadline per-peer) */
	do {
		struct htlc_out *hout;
		struct htlc_out_map_iter outi;

		removed = false;

		for (hout = htlc_out_map_first(ld->htlcs_out, &outi);
		     hout;
		     hout = htlc_out_map_next(ld->htlcs_out, &outi)) {
			/* Not timed out yet? */
			if (height < htlc_out_deadline(hout))
				continue;

			/* Channel dying already? */
			if (!channel_state_can_add_htlc(hout->key.channel->state)) {
				consider_failing_incoming(ld, height, hout);
				continue;
			}

			/* Peer already failed, or we hit it? */
			if (hout->key.channel->error)
				continue;

			channel_fail_permanent(hout->key.channel,
					       REASON_PROTOCOL,
					       "Offered HTLC %"PRIu64
					       " %s cltv %u hit deadline",
					       hout->key.id,
					       htlc_state_name(hout->hstate),
					       hout->cltv_expiry);
			removed = true;
		}
	/* Iteration while removing is safe, but can skip entries! */
	} while (removed);


	/* BOLT #2:
	 *
	 *   - for each HTLC it is attempting to fulfill:
	 *     - MUST estimate a fulfillment deadline.
	 *...
	 *   - if an HTLC it has fulfilled is in either node's current commitment
	 *   transaction, AND is past this fulfillment deadline:
	 *     - SHOULD send an `error` to the offering peer (if connected).
	 *     - MUST fail the channel.