mirror of
https://github.com/XRPLF/rippled.git
synced 2026-08-22 14:50:54 +00:00
d34aa37b3c
Co-authored-by: Timur Yalymov <36795566+tyalymov@users.noreply.github.com> Co-authored-by: Cursor <cursoragent@cursor.com> Co-authored-by: Vito Tumas <5780819+Tapanito@users.noreply.github.com> Co-authored-by: Ayaz Salikhov <mathbunnyru@users.noreply.github.com>
58 lines
1.8 KiB
C++
58 lines
1.8 KiB
C++
#include <xrpl/server/Vacuum.h>
|
|
|
|
#include <xrpl/beast/utility/Journal.h>
|
|
#include <xrpl/beast/utility/instrumentation.h>
|
|
#include <xrpl/rdb/DBInit.h>
|
|
#include <xrpl/rdb/DatabaseCon.h>
|
|
|
|
#include <soci/into.h>
|
|
|
|
#include <cstdint>
|
|
#include <filesystem>
|
|
#include <iostream>
|
|
#include <memory>
|
|
|
|
namespace xrpl {
|
|
|
|
bool
|
|
doVacuumDB(DatabaseCon::Setup const& setup, beast::Journal j)
|
|
{
|
|
std::filesystem::path const dbPath = setup.dataDir / kTxDbName;
|
|
|
|
uintmax_t const dbSize = std::filesystem::file_size(dbPath);
|
|
XRPL_ASSERT(dbSize != static_cast<uintmax_t>(-1), "xrpl::doVacuumDB : file_size succeeded");
|
|
|
|
if (auto available = std::filesystem::space(dbPath.parent_path()).available; available < dbSize)
|
|
{
|
|
std::cerr << "The database filesystem must have at least as "
|
|
"much free space as the size of "
|
|
<< dbPath.string() << ", which is " << dbSize << " bytes. Only " << available
|
|
<< " bytes are available.\n";
|
|
return false;
|
|
}
|
|
|
|
auto txnDB = std::make_unique<DatabaseCon>(setup, kTxDbName, setup.txPragma, kTxDbInit, j);
|
|
auto& session = txnDB->getSession();
|
|
std::uint32_t pageSize = 0;
|
|
|
|
// Only the most trivial databases will fit in memory on typical
|
|
// (recommended) hardware. Force temp files to be written to disk
|
|
// regardless of the config settings.
|
|
session << commonDbPragmaTemp("file");
|
|
session << "PRAGMA page_size;", soci::into(pageSize);
|
|
|
|
std::cout << "VACUUM beginning. page_size: " << pageSize << std::endl;
|
|
|
|
session << "VACUUM;";
|
|
XRPL_ASSERT(setup.globalPragma, "xrpl::doVacuumDB : non-null global pragma");
|
|
for (auto const& p : *setup.globalPragma)
|
|
session << p;
|
|
session << "PRAGMA page_size;", soci::into(pageSize);
|
|
|
|
std::cout << "VACUUM finished. page_size: " << pageSize << std::endl;
|
|
|
|
return true;
|
|
}
|
|
|
|
} // namespace xrpl
|