From e40b2f294066331dc04598f4b0dccac2bab7c295 Mon Sep 17 00:00:00 2001 From: Marcus Comstedt Date: Sun, 29 Jun 2014 14:09:03 +0200 Subject: [PATCH] Fix compilation on 32-bit systems storesession.h was declaring fields as std::atomic, a type not avaiable on 32-bit systems. However, the values stored in these fields were only used as input to QProgressDialog, which takes int, not uint64_t. So the fields could just as well be std::atomic. Also, added code to scale the progress values down if they would not fit in an int. (This would have been needed even if the fields were to remain as uint64_t.) --- pv/dialogs/storeprogress.cpp | 2 +- pv/storesession.cpp | 20 ++++++++++++++------ pv/storesession.h | 4 ++-- 3 files changed, 17 insertions(+), 9 deletions(-) diff --git a/pv/dialogs/storeprogress.cpp b/pv/dialogs/storeprogress.cpp index ecda1d0..5c2d8bc 100644 --- a/pv/dialogs/storeprogress.cpp +++ b/pv/dialogs/storeprogress.cpp @@ -66,7 +66,7 @@ void StoreProgress::closeEvent(QCloseEvent*) void StoreProgress::on_progress_updated() { - const std::pair p = _session.progress(); + const std::pair p = _session.progress(); assert(p.first <= p.second); if (p.second) { diff --git a/pv/storesession.cpp b/pv/storesession.cpp index 5eaff58..dede6a0 100644 --- a/pv/storesession.cpp +++ b/pv/storesession.cpp @@ -59,7 +59,7 @@ StoreSession::~StoreSession() wait(); } -pair StoreSession::progress() const +pair StoreSession::progress() const { return make_pair(_units_stored.load(), _unit_count.load()); } @@ -150,7 +150,8 @@ void StoreSession::store_proc(shared_ptr snapshot) { assert(snapshot); - uint64_t start_sample = 0; + uint64_t start_sample = 0, sample_count; + unsigned progress_scale = 0; /// TODO: Wrap this in a std::unique_ptr when we transition to C++11 uint8_t *const data = new uint8_t[BlockSize]; @@ -159,16 +160,23 @@ void StoreSession::store_proc(shared_ptr snapshot) const int unit_size = snapshot->unit_size(); assert(unit_size != 0); - _unit_count = snapshot->get_sample_count(); + sample_count = snapshot->get_sample_count(); + + // Qt needs the progress values to fit inside an int. If they would + // not, scale the current and max values down until they do. + while ((sample_count >> progress_scale) > INT_MAX) + progress_scale ++; + + _unit_count = sample_count >> progress_scale; const unsigned int samples_per_block = BlockSize / unit_size; - while (!_interrupt && start_sample < _unit_count) + while (!_interrupt && start_sample < sample_count) { progress_updated(); const uint64_t end_sample = min( - start_sample + samples_per_block, _unit_count.load()); + start_sample + samples_per_block, sample_count); snapshot->get_samples(data, start_sample, end_sample); if(sr_session_append(_file_name.c_str(), data, unit_size, @@ -179,7 +187,7 @@ void StoreSession::store_proc(shared_ptr snapshot) } start_sample = end_sample; - _units_stored = start_sample; + _units_stored = start_sample >> progress_scale; } _unit_count = 0; diff --git a/pv/storesession.h b/pv/storesession.h index 262eddc..ffe1fac 100644 --- a/pv/storesession.h +++ b/pv/storesession.h @@ -51,7 +51,7 @@ public: ~StoreSession(); - std::pair progress() const; + std::pair progress() const; const QString& error() const; @@ -75,7 +75,7 @@ private: std::atomic _interrupt; - std::atomic _units_stored, _unit_count; + std::atomic _units_stored, _unit_count; mutable std::mutex _mutex; QString _error; -- 2.30.2