X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.cpp;h=3c5bcc426cd750fcca98ab1a56c9b97c70a86009;hp=b53360fcd9508bbbc559978181a33cfe88ecad71;hb=f4e57597347e47a4ea58fbdc7b0a22e07f1c0ede;hpb=3a21afa6a5dfc06c17f127960bb0038fd322f213 diff --git a/pv/session.cpp b/pv/session.cpp index b53360fc..3c5bcc42 100644 --- a/pv/session.cpp +++ b/pv/session.cpp @@ -99,6 +99,7 @@ using Glib::Variant; namespace pv { Session::Session(DeviceManager &device_manager, QString name) : device_manager_(device_manager), + default_name_(name), name_(name), capture_state_(Stopped), cur_samplerate_(0) @@ -148,7 +149,12 @@ void Session::set_name(QString name) name_changed(); } -std::shared_ptr Session::main_view() const +const std::list< std::shared_ptr > Session::views() const +{ + return views_; +} + +std::shared_ptr Session::main_view() const { return main_view_; } @@ -237,7 +243,7 @@ void Session::save_settings(QSettings &settings) const main_view_->save_settings(settings); settings.endGroup(); - for (shared_ptr view : views_) { + for (shared_ptr view : views_) { if (view != main_view_) { settings.beginGroup("view" + QString::number(views++)); view->save_settings(settings); @@ -295,10 +301,11 @@ void Session::restore_settings(QSettings &settings) device = std::make_shared(device_manager_.context(), filename.toStdString()); set_device(device); - set_name(filename); // TODO Perform error handling start_capture([](QString infoMessage) { (void)infoMessage; }); + + set_name(QFileInfo(filename).fileName()); } } @@ -331,7 +338,7 @@ void Session::restore_settings(QSettings &settings) settings.beginGroup("view" + QString::number(i)); if (i > 0) { - view::ViewType type = (view::ViewType)settings.value("type").toInt(); + views::ViewType type = (views::ViewType)settings.value("type").toInt(); add_view(name_, type, this); views_.back()->restore_settings(settings); } else @@ -359,10 +366,10 @@ void Session::set_device(shared_ptr device) name_changed(); // Remove all stored data - for (std::shared_ptr view : views_) { + for (std::shared_ptr view : views_) { view->clear_signals(); #ifdef ENABLE_DECODE - view->clear_decode_traces(); + view->clear_decode_signals(); #endif } for (const shared_ptr d : all_signal_data_) @@ -465,18 +472,20 @@ void Session::stop_capture() sampling_thread_.join(); } -void Session::register_view(std::shared_ptr view) +void Session::register_view(std::shared_ptr view) { if (views_.empty()) { main_view_ = view; } views_.push_back(view); + + update_signals(); } -void Session::deregister_view(std::shared_ptr view) +void Session::deregister_view(std::shared_ptr view) { - views_.remove_if([&](std::shared_ptr v) { + views_.remove_if([&](std::shared_ptr v) { return v == view; }); if (views_.empty()) { @@ -487,9 +496,9 @@ void Session::deregister_view(std::shared_ptr view) } } -bool Session::has_view(std::shared_ptr view) +bool Session::has_view(std::shared_ptr view) { - for (std::shared_ptr v : views_) + for (std::shared_ptr v : views_) if (v == view) return true; @@ -560,8 +569,8 @@ bool Session::add_decoder(srd_decoder *const dec) signalbase->set_decoder_stack(decoder_stack); signalbases_.insert(signalbase); - for (std::shared_ptr view : views_) - view->add_decode_trace(signalbase); + for (std::shared_ptr view : views_) + view->add_decode_signal(signalbase); } catch (std::runtime_error e) { return false; } @@ -576,8 +585,8 @@ bool Session::add_decoder(srd_decoder *const dec) void Session::remove_decode_signal(shared_ptr signalbase) { - for (std::shared_ptr view : views_) - view->remove_decode_trace(signalbase); + for (std::shared_ptr view : views_) + view->remove_decode_signal(signalbase); } #endif @@ -600,10 +609,10 @@ void Session::update_signals() if (!device_) { signalbases_.clear(); logic_data_.reset(); - for (std::shared_ptr view : views_) { + for (std::shared_ptr view : views_) { view->clear_signals(); #ifdef ENABLE_DECODE - view->clear_decode_traces(); + view->clear_decode_signals(); #endif } return; @@ -615,10 +624,10 @@ void Session::update_signals() if (!sr_dev) { signalbases_.clear(); logic_data_.reset(); - for (std::shared_ptr view : views_) { + for (std::shared_ptr view : views_) { view->clear_signals(); #ifdef ENABLE_DECODE - view->clear_decode_traces(); + view->clear_decode_signals(); #endif } return; @@ -646,69 +655,76 @@ void Session::update_signals() } // 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; - shared_ptr signal; - - // Find the channel in the old signals - const auto iter = std::find_if( - prev_sigs.cbegin(), prev_sigs.cend(), - [&](const shared_ptr &s) { - return s->base()->channel() == channel; - }); - if (iter != prev_sigs.end()) { - // Copy the signal from the old set to the new - signal = *iter; - } else { - // 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_); + for (std::shared_ptr viewbase : views_) { + views::TraceView::View *trace_view = + qobject_cast(viewbase.get()); + + if (trace_view) { + unordered_set< shared_ptr > + prev_sigs(trace_view->signals()); + trace_view->clear_signals(); + + for (auto channel : sr_dev->channels()) { + shared_ptr signalbase; + shared_ptr signal; + + // Find the channel in the old signals + const auto iter = std::find_if( + prev_sigs.cbegin(), prev_sigs.cend(), + [&](const shared_ptr &s) { + return s->base()->channel() == channel; + }); + if (iter != prev_sigs.end()) { + // Copy the signal from the old set to the new + signal = *iter; + trace_view->add_signal(signal); + } else { + // 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 views::TraceView::LogicSignal(*this, + device_, signalbase)); + trace_view->add_signal(signal); + break; + + case SR_CHANNEL_ANALOG: + { + 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 views::TraceView::AnalogSignal( + *this, signalbase)); + trace_view->add_signal(signal); + break; } - signal = shared_ptr( - new view::LogicSignal(*this, - device_, signalbase)); - view->add_signal(signal); - break; - - case SR_CHANNEL_ANALOG: - { - 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); + default: + assert(0); + break; } - - signal = shared_ptr( - new view::AnalogSignal( - *this, signalbase)); - view->add_signal(signal); - break; - } - - default: - assert(0); - break; } } }