X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=pv%2Fdata%2Fanalogsnapshot.cpp;h=9e9b5a0ffeb8bb3ce0c8b6adb3e5289b9213c4d6;hb=7df04abc1537c26d9f2e2733d6c17a31e0cd7f2e;hp=36fad7f73477d9da08d9ddb475ab85c882a720a1;hpb=819f4c25391a9c74d3d2f528d462142d5c4aad4d;p=pulseview.git diff --git a/pv/data/analogsnapshot.cpp b/pv/data/analogsnapshot.cpp index 36fad7f7..9e9b5a0f 100644 --- a/pv/data/analogsnapshot.cpp +++ b/pv/data/analogsnapshot.cpp @@ -27,12 +27,10 @@ #include -#include - #include "analogsnapshot.h" -using boost::lock_guard; -using boost::recursive_mutex; +using std::lock_guard; +using std::recursive_mutex; using std::max; using std::max_element; using std::min; @@ -47,26 +45,40 @@ const float AnalogSnapshot::LogEnvelopeScaleFactor = logf(EnvelopeScaleFactor); const uint64_t AnalogSnapshot::EnvelopeDataUnit = 64*1024; // bytes -AnalogSnapshot::AnalogSnapshot(const sr_datafeed_analog &analog) : +AnalogSnapshot::AnalogSnapshot(const uint64_t expected_num_samples) : Snapshot(sizeof(float)) { + set_capacity(expected_num_samples); + lock_guard lock(_mutex); memset(_envelope_levels, 0, sizeof(_envelope_levels)); - append_payload(analog); } AnalogSnapshot::~AnalogSnapshot() { lock_guard lock(_mutex); - BOOST_FOREACH(Envelope &e, _envelope_levels) + for (Envelope &e : _envelope_levels) free(e.samples); } -void AnalogSnapshot::append_payload( - const sr_datafeed_analog &analog) +void AnalogSnapshot::append_interleaved_samples(const float *data, + size_t sample_count, size_t stride) { + assert(_unit_size == sizeof(float)); + lock_guard lock(_mutex); - append_data(analog.data, analog.num_samples); + + _data = realloc(_data, (_sample_count + sample_count) * sizeof(float)); + + float *dst = (float*)_data + _sample_count; + const float *dst_end = dst + sample_count; + while (dst != dst_end) + { + *dst++ = *data; + data += stride; + } + + _sample_count += sample_count; // Generate the first mip-map from the data append_payload_to_envelope_levels();