X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fdata%2Fdecodesignal.hpp;h=0e0911521b09973ed2d28fd1ca72efa1f139b0df;hp=57887f1ec7609c5f66702db71481991f13c77644;hb=8e15445ccd6994348eb74b24b5324d26c9be0cce;hpb=a3ebd5561086f4fef6570b3ab5be0a5592724731 diff --git a/pv/data/decodesignal.hpp b/pv/data/decodesignal.hpp index 57887f1e..0e091152 100644 --- a/pv/data/decodesignal.hpp +++ b/pv/data/decodesignal.hpp @@ -40,7 +40,6 @@ using std::condition_variable; using std::map; using std::mutex; using std::pair; -using std::unordered_set; using std::vector; using std::shared_ptr; @@ -79,7 +78,6 @@ private: static const double DecodeMargin; static const double DecodeThreshold; static const int64_t DecodeChunkLength; - static const unsigned int DecodeNotifyPeriod; public: DecodeSignal(pv::Session &session); @@ -88,7 +86,7 @@ public: bool is_decode_signal() const; const vector< shared_ptr >& decoder_stack() const; - void stack_decoder(srd_decoder *decoder); + void stack_decoder(const srd_decoder *decoder); void remove_decoder(int index); bool toggle_decoder_visibility(int index); @@ -97,7 +95,7 @@ public: QString error_message() const; const vector get_channels() const; - void auto_assign_signals(); + void auto_assign_signals(const shared_ptr dec); void assign_signal(const uint16_t channel_id, const SignalBase *signal); int get_assigned_signal_count() const; @@ -129,13 +127,6 @@ public: virtual void restore_settings(QSettings &settings); - /** - * Helper function for static annotation_callback(), - * must be public so the function can access it. - * Don't use from outside this class. - */ - uint64_t inc_annotation_count(); - private: void update_channel_list(); @@ -160,10 +151,12 @@ private: Q_SIGNALS: void new_annotations(); + void decode_finished(); void channels_updated(); private Q_SLOTS: void on_capture_state_changed(int state); + void on_data_cleared(); void on_data_received(); private: @@ -180,20 +173,12 @@ private: pv::util::Timestamp start_time_; double samplerate_; - int64_t annotation_count_, samples_decoded_; + int64_t samples_decoded_; vector< shared_ptr > stack_; map rows_; map, decode::Row> class_rows_; - /** - * This mutex prevents more than one thread from accessing - * libsigrokdecode concurrently. - * @todo A proper solution should be implemented to allow multiple - * decode operations in parallel. - */ - static mutex global_srd_mutex_; - mutable mutex input_mutex_, output_mutex_, logic_mux_mutex_; mutable condition_variable decode_input_cond_, logic_mux_cond_; bool frame_complete_;