Function wait_index_bump

lightningd/wait.c:136–179

}

static u64 wait_index_bump(struct lightningd *ld,
			   struct db *db,
			   enum wait_subsystem subsystem,
			   enum wait_index index,
			   u64 num,
			   va_list ap_master)
{
	struct waiter *i, *n;
	u64 *idxval = wait_index_ptr(ld, subsystem, index);

	assert(!add_overflows_u64(*idxval, num));
	(*idxval) += num;

	/* FIXME: We can optimize this!  It's always the max of the fields in
	 * the table, *unless* we delete one.  So we can lazily write this on
	 * delete, and fix it up to MAX() when we startup. */
	db_set_intvar(db,
		      tal_fmt(tmpctx, "last_%s_%s_index",
			      wait_subsystem_name(subsystem),
			      wait_index_name(index)),
		      *idxval);

	list_for_each_safe(&ld->wait_commands, i, n, list) {
		struct json_stream *response;
		va_list ap;

		if (*i->subsystem != subsystem)
			continue;
		if (*i->index != index)
			continue;
		if (*idxval < *i->nextval)
			continue;

		response = json_stream_success(i->cmd);
		va_copy(ap, ap_master);
		json_add_index(i->cmd, response, subsystem, index, *idxval, &ap);
		va_end(ap);
		/* Delete before freeing */
		list_del_from(&ld->wait_commands, &i->list);
		was_pending(command_success(i->cmd, response));
	}

	return *idxval;
}

u64 wait_index_increment(struct lightningd *ld,
			 struct db *db,