Function map_catchup

common/gossmap.c:815–937

Returns false only if must_be_clean is true. */

/* Returns false only if must_be_clean is true. */
static bool map_catchup(struct gossmap *map,
			void (*dyingcb)(struct short_channel_id scid,
					u32 blockheight,
					u64 offset,
					void *cb_arg),
			void *cb_arg,
			bool must_be_clean,
			bool *changed)
{
	size_t reclen, num_bad_cupdates = 0;

	*changed = false;

	for (; map->map_end + sizeof(struct gossip_hdr) < map->map_size;
	     map->map_end += reclen) {
		struct gossip_hdr ghdr;
		u64 off;
		u16 msglen, type, flags;

		map_copy(map, map->map_end, &ghdr, sizeof(ghdr));
		msglen = be16_to_cpu(ghdr.len);
		reclen = msglen + sizeof(ghdr);

		flags = be16_to_cpu(ghdr.flags);

		/* Not finished, this can happen. */
		if (!(flags & GOSSIP_STORE_COMPLETED_BIT))
			break;

		if (flags & GOSSIP_STORE_DELETED_BIT) {
			map->num_dead++;
			continue;
		}

		/* Partial write, should not happen with completed records. */
		if (map->map_end + reclen > map->map_size)
			break;

		/* FIXME: In corruption, we can see zeroes here: don't crash. */
		if (msglen < sizeof(be16)) {
			map->logcb(map->cbarg,
				   LOG_BROKEN,
				   "Truncated gossmap record @%"PRIu64
				   "/%"PRIu64" (len %zu): waiting%s",
				   map->map_end, map->map_size, msglen,
				   gossmap_has_mmap(map) ? " and disabling mmap" : "");
			gossmap_disable_mmap(map);
			if (must_be_clean)
				return false;
 			break;
		}

		off = map->map_end + sizeof(ghdr);
		type = map_be16(map, off);

		if (!csum_matches(map, off,
				  be32_to_cpu(ghdr.timestamp),
				  msglen,