X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=pv%2Fdata%2Fanalogsnapshot.cpp;h=4907d7954a186af7c6d7b5f0c2c8447714edc32a;hb=df5396800830d41a83a837b95b0f3787571905cf;hp=bec65065631aa19239a1f27f18f3b6287521f3a5;hpb=9320072da54c5f1614779512d8c8d3bac6743419;p=pulseview.git diff --git a/pv/data/analogsnapshot.cpp b/pv/data/analogsnapshot.cpp index bec6506..4907d79 100644 --- a/pv/data/analogsnapshot.cpp +++ b/pv/data/analogsnapshot.cpp @@ -31,8 +31,12 @@ #include "analogsnapshot.h" -using namespace boost; -using namespace std; +using boost::lock_guard; +using boost::recursive_mutex; +using std::max; +using std::max_element; +using std::min; +using std::min_element; namespace pv { namespace data { @@ -43,12 +47,11 @@ const float AnalogSnapshot::LogEnvelopeScaleFactor = logf(EnvelopeScaleFactor); const uint64_t AnalogSnapshot::EnvelopeDataUnit = 64*1024; // bytes -AnalogSnapshot::AnalogSnapshot(const sr_datafeed_analog &analog) : +AnalogSnapshot::AnalogSnapshot() : Snapshot(sizeof(float)) { lock_guard lock(_mutex); memset(_envelope_levels, 0, sizeof(_envelope_levels)); - append_payload(analog); } AnalogSnapshot::~AnalogSnapshot() @@ -58,11 +61,24 @@ AnalogSnapshot::~AnalogSnapshot() 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();