Reading block files, undo records and pruning metadata

1251        m_blockfiles_indexed = false;
1252        // If we're reindexing in prune mode, wipe away unusable block files and all undo data files
1253        if (m_prune_mode) {
1254            CleanupBlockRevFiles();
1255        }
1256    }
1257}
1258
1259class ImportingNow
1260{
1261    std::atomic<bool>& m_importing;
1262
1263public:
1264    ImportingNow(std::atomic<bool>& importing) : m_importing{importing}
1265    {
1266        assert(m_importing == false);
1267        m_importing = true;
1268    }
1269    ~ImportingNow()
1270    {
1271        assert(m_importing == true);
1272        m_importing = false;
1273    }
1274};
1275
1276void ImportBlocks(ChainstateManager& chainman, std::span<const fs::path> import_paths)
1277{
1278    ImportingNow imp{chainman.m_blockman.m_importing};
1279
1280    // -reindex
1281    if (!chainman.m_blockman.m_blockfiles_indexed) {
1282        int total_files{0};
1283        while (fs::exists(chainman.m_blockman.GetBlockPosFilename(FlatFilePos(total_files, 0)))) {
1284            total_files++;
1285        }
1286
1287        // Map of disk positions for blocks with unknown parent (only used for reindex);
1288        // parent hash -> child disk position, multiple children can have the same parent.
1289        std::multimap<uint256, FlatFilePos> blocks_with_unknown_parent;
1290
1291        for (int nFile{0}; nFile < total_files; ++nFile) {
1292            FlatFilePos pos(nFile, 0);
1293            AutoFile file{chainman.m_blockman.OpenBlockFile(pos, /*fReadOnly=*/true)};
1294            if (file.IsNull()) {
1295                break; // This error is logged in OpenBlockFile
1296            }
1297            LogInfo("Reindexing block file blk%05u.dat (%d%% complete)...", (unsigned int)nFile, nFile * 100 / total_files);
1298            chainman.LoadExternalBlockFile(file, &pos, &blocks_with_unknown_parent);
1299            if (chainman.m_interrupt) {
1300                LogInfo("Interrupt requested. Exit reindexing.");
1301                return;
1302            }
1303        }
1304        WITH_LOCK(::cs_main, chainman.m_blockman.m_block_tree_db->WriteReindexing(false));
1305        chainman.m_blockman.m_blockfiles_indexed = true;
1306        LogInfo("Reindexing finished");
1307        // To avoid ending up in a situation without genesis block, re-try initializing (no-op if reindexing worked):
1308        (void)chainman.LoadGenesisBlock();
1309    }
1310
1311    // -loadblock=
1312    for (const fs::path& path : import_paths) {
1313        AutoFile file{fsbridge::fopen(path, "rb")};
1314        if (!file.IsNull()) {
1315            LogInfo("Importing blocks file %s...", fs::PathToString(path));
1316            chainman.LoadExternalBlockFile(file);
1317            if (chainman.m_interrupt) {
1318                LogInfo("Interrupt requested. Exit block importing.");
1319                return;
1320            }
1321        } else {
1322            LogWarning("Could not open blocks file %s", fs::PathToString(path));
1323        }
1324    }
1325
1326    // scan for better chains in the block chain database, that are not yet connected in the active best chain
1327    if (auto result = chainman.ActivateBestChains(); !result) {
1328        chainman.GetNotifications().fatalError(util::ErrorString(result));
1329    }
1330    // End scope of ImportingNow
1331}
1332
1333std::ostream& operator<<(std::ostream& os, const BlockfileType& type) {
1334    switch(type) {
1335        case BlockfileType::NORMAL: os << "normal"; break;
1336        case BlockfileType::ASSUMED: os << "assumed"; break;
1337        default: os.setstate(std::ios_base::failbit);
1338    }
1339    return os;
1340}
1341
1342std::ostream& operator<<(std::ostream& os, const BlockfileCursor& cursor) {
1343    os << strprintf("BlockfileCursor(file_num=%d, undo_height=%d)", cursor.file_num, cursor.undo_height);
1344    return os;
1345}
1346} // namespace node
1347