TheCloud/dwarfs
1
0
Fork 0
mirror of https://github.com/mhx/dwarfs.git synced 2025-09-16 15:58:06 -04:00
Code Issues Packages Projects Releases Wiki Activity

feat(dwarfsck): readv() before context switch to speed up --checksum

Browse Source
This commit is contained in:
Marcus Holland-Moritz 2024-04-27 08:58:27 +02:00
parent 0548454f64
commit 1ff2878e23
1 changed files with 13 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/dwarfsck_main.cpp
View File

@ -110,23 +110,24 @@ void do_checksum(logger& lgr, filesystem_v2& fs, iolayer const& iol,
fs.walk_data_order([&](auto const& de) {
auto iv = de.inode();
if (iv.is_regular_file()) {
wg.add_job([&, de, iv] {
file_stat st;
file_stat st;
if (fs.getattr(de.inode(), &st) != 0) {
LOG_ERROR << "failed to get attributes for inode " << iv.inode_num();
return;
}
if (fs.getattr(de.inode(), &st) != 0) {
LOG_ERROR << "failed to get attributes for inode " << iv.inode_num();
return;
}
auto ranges = fs.readv(iv.inode_num(), st.size);
auto ranges = fs.readv(iv.inode_num(), st.size);
if (!ranges) {
LOG_ERROR << "failed to read inode " << iv.inode_num() << ": "
<< std::strerror(-ranges.error());
return;
}
if (!ranges) {
LOG_ERROR << "failed to read inode " << iv.inode_num() << ": "
<< std::strerror(-ranges.error());
return;
}
wg.add_job([&, de, iv, ranges = std::move(ranges)]() mutable {
checksum cs(algo);
for (auto& fut : ranges.value()) {