Function wallet_channel_close

wallet/wallet.c:3084–3186

}

void wallet_channel_close(struct wallet *w,
			  const struct channel *chan)
{
	/* We keep the entry in the channel_configs table, since that might
	 * help us debug some issues, and it is rather limited in size.  We
	 * also keep shachains: it's limited and we can use it for sending
	 * reestablish messages with enough information for nodes with lost
	 * dbs to recover. */
	struct db_stmt *stmt;
	u64 new_move_id;
	u64 htlcs;

	/* The channel_htlcs table is quite large, and deleting it can take a
	 * while.  So we do that on next restart by calling
	 * wallet_delete_old_htlcs.  But update delete count in case anyone
	 * is watching. */
	stmt = db_prepare_v2(w->db, SQL("SELECT COUNT(*) FROM channel_htlcs "
					"WHERE channel_id=?"));
	db_bind_u64(stmt, chan->dbid);
	db_query_prepared(stmt);
	db_step(stmt);

	htlcs = db_col_u64(stmt, "COUNT(*)");
	if (htlcs != 0)
		htlcs_index_deleted(w->ld, chan, htlcs);
	tal_free(stmt);

	/* Delete entries from `htlc_sigs` */
	stmt = db_prepare_v2(w->db, SQL("DELETE FROM htlc_sigs "
					"WHERE channelid=?"));
	db_bind_u64(stmt, chan->dbid);
	db_exec_prepared_v2(take(stmt));

	/* Delete entries from `htlc_sigs` */
	stmt = db_prepare_v2(w->db, SQL("DELETE FROM channeltxs "
					"WHERE channel_id=?"));
	db_bind_u64(stmt, chan->dbid);
	db_exec_prepared_v2(take(stmt));

	/* Delete any entries from 'inflights' */
	stmt = db_prepare_v2(w->db,
			     SQL("DELETE FROM channel_funding_inflights "
				 " WHERE channel_id=?"));
	db_bind_u64(stmt, chan->dbid);
	db_exec_prepared_v2(take(stmt));

	/* Delete transaction annotations */
	stmt = db_prepare_v2(w->db, SQL("DELETE FROM transaction_annotations "
					"WHERE channel=?"));
	db_bind_u64(stmt, chan->dbid);
	db_exec_prepared_v2(take(stmt));

	/* Delete feerates */
	stmt = db_prepare_v2(w->db, SQL("DELETE FROM channel_feerates "
					"WHERE channel_id=?"));
	db_bind_u64(stmt, chan->dbid);
	db_exec_prepared_v2(take(stmt));