X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;f=pv%2Fdata%2Fanalogsnapshot.cpp;h=2a14d1ea0a0f37bf7687ca3f2f48f864e1849497;hb=5ad3b48b283738425949145182edc18edf6ea29e;hp=36fad7f73477d9da08d9ddb475ab85c882a720a1;hpb=819f4c25391a9c74d3d2f528d462142d5c4aad4d;p=pulseview.git diff --git a/pv/data/analogsnapshot.cpp b/pv/data/analogsnapshot.cpp index 36fad7f7..2a14d1ea 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.resize((_sample_count + sample_count) * sizeof(float)); + + float *dst = (float*)_data.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(); @@ -84,7 +96,7 @@ const float* AnalogSnapshot::get_samples( lock_guard lock(_mutex); float *const data = new float[end_sample - start_sample]; - memcpy(data, (float*)_data + start_sample, sizeof(float) * + memcpy(data, (float*)_data.data() + start_sample, sizeof(float) * (end_sample - start_sample)); return data; } @@ -144,9 +156,9 @@ void AnalogSnapshot::append_payload_to_envelope_levels() dest_ptr = e0.samples + prev_length; // Iterate through the samples to populate the first level mipmap - const float *const end_src_ptr = (float*)_data + + const float *const end_src_ptr = (float*)_data.data() + e0.length * EnvelopeScaleFactor; - for (const float *src_ptr = (float*)_data + + for (const float *src_ptr = (float*)_data.data() + prev_length * EnvelopeScaleFactor; src_ptr < end_src_ptr; src_ptr += EnvelopeScaleFactor) {