X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.cpp;h=74cb82dc99aae5b847ca5660bc56d953e931d168;hp=9d00a51032c649455b15eceab0f7dfdead57e335;hb=d290e89f9b28f90b898a57c9f5e288602367cb3d;hpb=cbd2a2de848f957507096785d3be1cc97d30df9a diff --git a/pv/session.cpp b/pv/session.cpp index 9d00a510..74cb82dc 100644 --- a/pv/session.cpp +++ b/pv/session.cpp @@ -48,6 +48,8 @@ #include "view/analogsignal.hpp" #include "view/decodetrace.hpp" #include "view/logicsignal.hpp" +#include "view/signal.hpp" +#include "view/view.hpp" #include #include @@ -142,13 +144,16 @@ void Session::set_device(shared_ptr device) device_.reset(); // Remove all stored data - signals_.clear(); - { - shared_lock lock(signals_mutex_); - for (const shared_ptr d : all_signal_data_) - d->clear(); + for (std::shared_ptr view : views_) { + view->clear_signals(); +#ifdef ENABLE_DECODE + view->clear_decode_traces(); +#endif } + for (const shared_ptr d : all_signal_data_) + d->clear(); all_signal_data_.clear(); + signalbases_.clear(); cur_logic_segment_.reset(); for (auto entry : cur_analog_segments_) { @@ -157,7 +162,6 @@ void Session::set_device(shared_ptr device) } logic_data_.reset(); - decode_traces_.clear(); signals_changed(); @@ -224,11 +228,8 @@ void Session::start_capture(function error_handler) } // Clear signal data - { - shared_lock lock(signals_mutex_); - for (const shared_ptr d : all_signal_data_) - d->clear(); - } + for (const shared_ptr d : all_signal_data_) + d->clear(); // Begin the session sampling_thread_ = std::thread( @@ -245,19 +246,26 @@ void Session::stop_capture() sampling_thread_.join(); } +void Session::register_view(std::shared_ptr view) +{ + views_.insert(view); +} + +void Session::deregister_view(std::shared_ptr view) +{ + views_.erase(view); +} + double Session::get_samplerate() const { double samplerate = 0.0; - { - shared_lock lock(signals_mutex_); - for (const shared_ptr d : all_signal_data_) { - assert(d); - const vector< shared_ptr > segments = - d->segments(); - for (const shared_ptr &s : segments) - samplerate = std::max(samplerate, s->samplerate()); - } + for (const shared_ptr d : all_signal_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) @@ -266,21 +274,19 @@ double Session::get_samplerate() const return samplerate; } -const unordered_set< shared_ptr > Session::signals() const +const std::unordered_set< std::shared_ptr > + Session::signalbases() const { - shared_lock lock(signals_mutex_); - return signals_; + return signalbases_; } #ifdef ENABLE_DECODE bool Session::add_decoder(srd_decoder *const dec) { - map > channels; + map > channels; shared_ptr decoder_stack; try { - lock_guard lock(signals_mutex_); - // Create the decoder decoder_stack = shared_ptr( new data::DecoderStack(*this, dec)); @@ -294,13 +300,12 @@ bool Session::add_decoder(srd_decoder *const dec) // Auto select the initial channels for (const srd_channel *pdch : all_channels) - for (shared_ptr s : signals_) { - shared_ptr l = - dynamic_pointer_cast(s); - if (l && QString::fromUtf8(pdch->name). - toLower().contains( - s->base()->name().toLower())) - channels[pdch] = l; + for (shared_ptr b : signalbases_) { + if (b->type() == ChannelType::LOGIC) { + if (QString::fromUtf8(pdch->name).toLower(). + contains(b->name().toLower())) + channels[pdch] = b; + } } assert(decoder_stack); @@ -312,10 +317,10 @@ bool Session::add_decoder(srd_decoder *const dec) shared_ptr signalbase = shared_ptr(new data::SignalBase(nullptr)); - shared_ptr d( - new view::DecodeTrace(*this, signalbase, decoder_stack, - decode_traces_.size())); - decode_traces_.push_back(d); + signalbase->set_decoder_stack(decoder_stack); + + for (std::shared_ptr view : views_) + view->add_decode_trace(signalbase); } catch (std::runtime_error e) { return false; } @@ -328,20 +333,10 @@ bool Session::add_decoder(srd_decoder *const dec) return true; } -vector< shared_ptr > Session::get_decode_signals() const +void Session::remove_decode_signal(shared_ptr signalbase) { - shared_lock lock(signals_mutex_); - return decode_traces_; -} - -void Session::remove_decode_signal(view::DecodeTrace *signal) -{ - for (auto i = decode_traces_.begin(); i != decode_traces_.end(); i++) - if ((*i).get() == signal) { - decode_traces_.erase(i); - signals_changed(); - return; - } + for (std::shared_ptr view : views_) + view->remove_decode_trace(signalbase); } #endif @@ -362,8 +357,14 @@ void Session::set_capture_state(capture_state state) void Session::update_signals() { if (!device_) { - signals_.clear(); + signalbases_.clear(); logic_data_.reset(); + for (std::shared_ptr view : views_) { + view->clear_signals(); +#ifdef ENABLE_DECODE + view->clear_decode_traces(); +#endif + } return; } @@ -371,8 +372,14 @@ void Session::update_signals() const shared_ptr sr_dev = device_->device(); if (!sr_dev) { - signals_.clear(); + signalbases_.clear(); logic_data_.reset(); + for (std::shared_ptr view : views_) { + view->clear_signals(); +#ifdef ENABLE_DECODE + view->clear_decode_traces(); +#endif + } return; } @@ -397,12 +404,10 @@ void Session::update_signals() } } - // Make the Signals list - { - unique_lock lock(signals_mutex_); - - unordered_set< shared_ptr > prev_sigs(signals_); - signals_.clear(); + // Make the signals list + for (std::shared_ptr view : views_) { + unordered_set< shared_ptr > prev_sigs(view->signals()); + view->clear_signals(); for (auto channel : sr_dev->channels()) { shared_ptr signalbase; @@ -417,34 +422,46 @@ void Session::update_signals() if (iter != prev_sigs.end()) { // Copy the signal from the old set to the new signal = *iter; - auto logic_signal = dynamic_pointer_cast< - view::LogicSignal>(signal); - if (logic_signal) - logic_signal->set_logic_data( - logic_data_); } else { - // Create a new signal - signalbase = shared_ptr( - new data::SignalBase(channel)); + // Find the signalbase for this channel if possible + signalbase.reset(); + for (const shared_ptr b : signalbases_) + if (b->channel() == channel) + signalbase = b; switch(channel->type()->id()) { case SR_CHANNEL_LOGIC: + if (!signalbase) { + signalbase = shared_ptr( + new data::SignalBase(channel)); + signalbases_.insert(signalbase); + + all_signal_data_.insert(logic_data_); + signalbase->set_data(logic_data_); + } + signal = shared_ptr( new view::LogicSignal(*this, - device_, signalbase, logic_data_)); - all_signal_data_.insert(logic_data_); - signalbases_.insert(signalbase); + device_, signalbase)); + view->add_signal(signal); break; case SR_CHANNEL_ANALOG: { - shared_ptr data(new data::Analog()); - signalbase->set_data(data); + if (!signalbase) { + signalbase = shared_ptr( + new data::SignalBase(channel)); + signalbases_.insert(signalbase); + + shared_ptr data(new data::Analog()); + all_signal_data_.insert(data); + signalbase->set_data(data); + } + signal = shared_ptr( new view::AnalogSignal( *this, signalbase)); - all_signal_data_.insert(data); - signalbases_.insert(signalbase); + view->add_signal(signal); break; } @@ -453,9 +470,6 @@ void Session::update_signals() break; } } - - assert(signal); - signals_.insert(signal); } } @@ -539,7 +553,6 @@ void Session::feed_in_trigger() uint64_t sample_count = 0; { - shared_lock lock(signals_mutex_); for (const shared_ptr d : all_signal_data_) { assert(d); uint64_t temp_count = 0; @@ -609,7 +622,7 @@ void Session::feed_in_analog(shared_ptr analog) const float *data = static_cast(analog->data_pointer()); bool sweep_beginning = false; - if (signals_.empty()) + if (signalbases_.empty()) update_signals(); for (auto channel : channels) {