X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=pv%2Fsession.cpp;h=da9c0e9bb4af998abf3a3303eb525536245b3ba9;hb=48257a69ffad409c9893605d99cd6e15161dff4f;hp=e6fb52fd7dd0d589342ed877ee573cbb572a4755;hpb=35750e4dc619d538f105ed024f3a72b630108234;p=pulseview.git diff --git a/pv/session.cpp b/pv/session.cpp index e6fb52f..da9c0e9 100644 --- a/pv/session.cpp +++ b/pv/session.cpp @@ -222,6 +222,25 @@ set< shared_ptr > Session::get_data() const return data; } +double Session::get_samplerate() const +{ + double samplerate = 0.0; + + for (const shared_ptr d : get_data()) { + assert(d); + const vector< shared_ptr > segments = + d->segments(); + for (const shared_ptr &s : segments) + samplerate = std::max(samplerate, s->samplerate()); + } + + // If there is no sample rate given we use samples as unit + if (samplerate == 0.0) + samplerate = 1.0; + + return samplerate; +} + const unordered_set< shared_ptr > Session::signals() const { shared_lock lock(signals_mutex_); @@ -473,6 +492,27 @@ void Session::feed_in_meta(shared_ptr meta) signals_changed(); } +void Session::feed_in_trigger() +{ + // The channel containing most samples should be most accurate + uint64_t sample_count = 0; + + for (const shared_ptr d : get_data()) { + assert(d); + uint64_t temp_count = 0; + + const vector< shared_ptr > segments = + d->segments(); + for (const shared_ptr &s : segments) + temp_count += s->get_sample_count(); + + if (temp_count > sample_count) + sample_count = temp_count; + } + + trigger_event(sample_count / get_samplerate()); +} + void Session::feed_in_frame_begin() { if (cur_logic_segment_ || !cur_analog_segments_.empty()) @@ -597,6 +637,10 @@ void Session::data_feed_in(shared_ptr device, feed_in_meta(dynamic_pointer_cast(packet->payload())); break; + case SR_DF_TRIGGER: + feed_in_trigger(); + break; + case SR_DF_FRAME_BEGIN: feed_in_frame_begin(); break;