X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.cpp;h=c885d37aaeea5edf3cd385712b227b95d55df105;hp=ef1159ee599f8abfbf0a7e6b90d6c100eeef3f44;hb=4b8e787d814febce73b9dee4f823e69f6973dc61;hpb=8a7b603b295dacee7160eba8e577d6666472be9f diff --git a/pv/session.cpp b/pv/session.cpp index ef1159ee..c885d37a 100644 --- a/pv/session.cpp +++ b/pv/session.cpp @@ -144,10 +144,10 @@ void Session::set_device(shared_ptr device) (shared_ptr device, shared_ptr packet) { data_feed_in(device, packet); }); - update_signals(); decode_traces_.clear(); + update_signals(); device_selected(); } @@ -253,8 +253,7 @@ bool Session::add_decoder(srd_decoder *const dec) map > channels; shared_ptr decoder_stack; - try - { + try { lock_guard lock(signals_mutex_); // Create the decoder @@ -270,8 +269,7 @@ 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_) - { + for (shared_ptr s : signals_) { shared_ptr l = dynamic_pointer_cast(s); if (l && QString::fromUtf8(pdch->name). @@ -290,9 +288,7 @@ bool Session::add_decoder(srd_decoder *const dec) new view::DecodeTrace(*this, decoder_stack, decode_traces_.size())); decode_traces_.push_back(d); - } - catch(std::runtime_error e) - { + } catch (std::runtime_error e) { return false; } @@ -313,8 +309,7 @@ vector< shared_ptr > Session::get_decode_signals() const void Session::remove_decode_signal(view::DecodeTrace *signal) { for (auto i = decode_traces_.begin(); i != decode_traces_.end(); i++) - if ((*i).get() == signal) - { + if ((*i).get() == signal) { decode_traces_.erase(i); signals_changed(); return; @@ -454,7 +449,7 @@ void Session::sample_thread_proc(shared_ptr device, try { device_->start(); - } catch(Error e) { + } catch (Error e) { error_handler(e.what()); return; } @@ -466,8 +461,7 @@ void Session::sample_thread_proc(shared_ptr device, set_capture_state(Stopped); // Confirm that SR_DF_END was received - if (cur_logic_segment_) - { + if (cur_logic_segment_) { qDebug("SR_DF_END was not received."); assert(0); } @@ -535,16 +529,14 @@ void Session::feed_in_logic(shared_ptr logic) const size_t sample_count = logic->data_length() / logic->unit_size(); - if (!logic_data_) - { + if (!logic_data_) { // The only reason logic_data_ would not have been created is // if it was not possible to determine the signals when the // device was created. update_signals(); } - if (!cur_logic_segment_) - { + if (!cur_logic_segment_) { // This could be the first packet after a trigger set_capture_state(Running); @@ -559,9 +551,7 @@ void Session::feed_in_logic(shared_ptr logic) // frame_began is DecoderStack, but in future we need to signal // this after both analog and logic sweeps have begun. frame_began(); - } - else - { + } else { // Append to the existing data segment cur_logic_segment_->append_payload(logic); } @@ -579,8 +569,10 @@ void Session::feed_in_analog(shared_ptr analog) const float *data = static_cast(analog->data_pointer()); bool sweep_beginning = false; - for (auto channel : channels) - { + if (signals_.empty()) + update_signals(); + + for (auto channel : channels) { shared_ptr segment; // Try to get the segment of the channel @@ -588,8 +580,7 @@ void Session::feed_in_analog(shared_ptr analog) iterator iter = cur_analog_segments_.find(channel); if (iter != cur_analog_segments_.end()) segment = (*iter).second; - else - { + else { // If no segment was found, this means we havn't // created one yet. i.e. this is the first packet // in the sweep containing this segment.