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

Delay compression progress until we actually start compressing

Browse Source
This commit is contained in:
Marcus Holland-Moritz 2023-08-22 21:25:20 +02:00
parent 6d582cb3dc
commit cee06b28f6
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/dwarfs/filesystem_writer.cpp
View File

@ -358,7 +358,6 @@ filesystem_writer_<LoggerPolicy>::filesystem_writer_(
, metadata_bc_(metadata_bc) , metadata_bc_(metadata_bc)
, options_(options) , options_(options)
, LOG_PROXY_INIT(lgr) , LOG_PROXY_INIT(lgr)
, pctx_{prog.create_context<compression_progress>()}
, flush_(false) , flush_(false)
, writer_thread_(&filesystem_writer_::writer_thread, this) { , writer_thread_(&filesystem_writer_::writer_thread, this) {
if (header_) { if (header_) {
@ -486,6 +485,10 @@ uint32_t filesystem_writer_<LoggerPolicy>::write_section(
{ {
std::unique_lock lock(mx_); std::unique_lock lock(mx_);
if (!pctx_) {
pctx_ = prog_.create_context<compression_progress>();
}
while (mem_used() > options_.max_queue_size) { while (mem_used() > options_.max_queue_size) {
cond_.wait(lock); cond_.wait(lock);
} }