bronku/file_sorting
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

run tracking

Browse source
This commit is contained in:
bronku 2025-11-17 08:32:12 +01:00
parent 918c1cba78
commit 8b93786157
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/merge_sorter.cpp
View file

@ -19,9 +19,9 @@ size_t MergeSorter::create_initial_runs(const std::string& input_file)
auto output = std::span<const Record>(chunk.data(), records_read); auto output = std::span<const Record>(chunk.data(), records_read);
writer.write_chunk(output); writer.write_chunk(output);
disk_reads_ += reader.total_reads() - disk_reads_; disk_writes_ += writer.total_writes();
disk_writes_ += writer.total_writes() - disk_writes_;
} }
disk_reads_ += reader.total_reads();
return run_count; return run_count;
} }
@ -41,6 +41,7 @@ MergeSorter::MergeSorter(size_t buffer_rows, size_t buffer_cols, const std::stri
bool MergeSorter::sort_file(const std::string& input_file, const std::string& output_file) bool MergeSorter::sort_file(const std::string& input_file, const std::string& output_file)
{ {
create_initial_runs(input_file); create_initial_runs(input_file);
std::cout << "created inital runs, disk reads: " << disk_reads_ << ", disk writes: " << disk_writes_ << '\n';
std::cout << output_file << '\n'; std::cout << output_file << '\n';
return true; return true;
} }