Function wait_for_resolved

onchaind/onchaind.c:1645–1712

BOLT #5: * * A node: * - once it has broadcast a funding transaction OR sent a commitment signature * for a commitment transaction that contains an HTLC output: * - until all outputs are *irrevocably resolved*: * - MUST monitor the blockchain for transactions that spend any output that * is NOT *irrevocably resolved*. * - MUST *resolve* all outputs, as specified below. *

 *  reorganizations.
 */
static void wait_for_resolved(struct tracked_output **outs)
{
	billboard_update(outs);

	while (num_not_irrevocably_resolved(outs) != 0) {
		const u8 *msg;
		enum onchaind_wire mtype;

		if (tal_count(queued_msgs)) {
			msg = tal_steal(outs, queued_msgs[0]);
			tal_arr_remove(&queued_msgs, 0);
		} else
			msg = wire_sync_read(outs, REQ_FD);

		mtype = fromwire_peektype(msg);
		status_debug("Got new message %s", onchaind_wire_name(mtype));

		switch (mtype) {
		case WIRE_ONCHAIND_DEPTH:
			handle_onchaind_depth(&outs, msg);
			goto handled;
		case WIRE_ONCHAIND_SPENT:
			handle_onchaind_spent(&outs, msg);
			goto handled;
		case WIRE_ONCHAIND_KNOWN_PREIMAGE:
			handle_onchaind_known_preimage(&outs, msg);
			goto handled;
		case WIRE_ONCHAIND_DEV_MEMLEAK:
			handle_dev_memleak(&outs, msg);
			goto handled;

		/* Unexpected messages */
		case WIRE_ONCHAIND_INIT:
		case WIRE_ONCHAIND_HTLCS:
		case WIRE_ONCHAIND_SPEND_CREATED:

		/* We send these, not receive! */
		case WIRE_ONCHAIND_INIT_REPLY:
		case WIRE_ONCHAIND_SPENT_REPLY:
		case WIRE_ONCHAIND_EXTRACTED_PREIMAGE:
		case WIRE_ONCHAIND_MISSING_HTLC_OUTPUT:
		case WIRE_ONCHAIND_HTLC_TIMEOUT:
		case WIRE_ONCHAIND_ALL_IRREVOCABLY_RESOLVED:
		case WIRE_ONCHAIND_ADD_UTXO:
		case WIRE_ONCHAIND_DEV_MEMLEAK_REPLY:
		case WIRE_ONCHAIND_ANNOTATE_TXOUT:
		case WIRE_ONCHAIND_ANNOTATE_TXIN:
		case WIRE_ONCHAIND_NOTIFY_COIN_MVT:
		case WIRE_ONCHAIND_NOTIFY_PENALTY_ADJ:
		case WIRE_ONCHAIND_SPEND_TO_US:
		case WIRE_ONCHAIND_SPEND_PENALTY:
		case WIRE_ONCHAIND_SPEND_HTLC_SUCCESS:
		case WIRE_ONCHAIND_SPEND_HTLC_TIMEOUT:
		case WIRE_ONCHAIND_SPEND_FULFILL:
		case WIRE_ONCHAIND_SPEND_HTLC_EXPIRED:
			break;
		}
		master_badmsg(-1, msg);