X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsigsession.h;h=b2dc467612655e59e1e189f78e813832f9b6bac4;hp=8da89d09b3fd6d0cde07fea0fde589d90e779902;hb=3a6fe0818affcb40b2821eab3f633e536377dd81;hpb=5b7cf66c34d7beeef055b06b95d72f9d7a3de680 diff --git a/pv/sigsession.h b/pv/sigsession.h index 8da89d09..b2dc4676 100644 --- a/pv/sigsession.h +++ b/pv/sigsession.h @@ -21,6 +21,7 @@ #ifndef PULSEVIEW_PV_SIGSESSION_H #define PULSEVIEW_PV_SIGSESSION_H +#include #include #include @@ -29,15 +30,18 @@ #include #include +#include -extern "C" { #include -} namespace pv { -class LogicData; -class LogicDataSnapshot; +namespace data { +class Analog; +class AnalogSnapshot; +class Logic; +class LogicSnapshot; +} namespace view { class Signal; @@ -58,44 +62,66 @@ public: ~SigSession(); - void load_file(const std::string &name); + void load_file(const std::string &name, + boost::function error_handler); capture_state get_capture_state() const; - void start_capture(struct sr_dev_inst* sdi, uint64_t record_length, - uint64_t sample_rate); + void start_capture(struct sr_dev_inst* sdi, + uint64_t record_length, + boost::function error_handler); void stop_capture(); std::vector< boost::shared_ptr > get_signals(); - boost::shared_ptr get_data(); + boost::shared_ptr get_data(); private: + void set_capture_state(capture_state state); + +private: + void load_thread_proc(const std::string name, + boost::function error_handler); + void sample_thread_proc(struct sr_dev_inst *sdi, - uint64_t record_length, uint64_t sample_rate); + uint64_t record_length, + boost::function error_handler); + + void feed_in_header(const sr_dev_inst *sdi); + + void feed_in_meta(const sr_dev_inst *sdi, + const sr_datafeed_meta &meta); + + void feed_in_logic(const sr_datafeed_logic &logic); + + void feed_in_analog(const sr_datafeed_analog &analog); void data_feed_in(const struct sr_dev_inst *sdi, - struct sr_datafeed_packet *packet); + const struct sr_datafeed_packet *packet); static void data_feed_in_proc(const struct sr_dev_inst *sdi, - struct sr_datafeed_packet *packet); + const struct sr_datafeed_packet *packet); private: - mutable boost::mutex _state_mutex; + mutable boost::mutex _sampling_mutex; capture_state _capture_state; mutable boost::mutex _signals_mutex; std::vector< boost::shared_ptr > _signals; mutable boost::mutex _data_mutex; - boost::shared_ptr _logic_data; - boost::shared_ptr _cur_logic_snapshot; + boost::shared_ptr _logic_data; + boost::shared_ptr _cur_logic_snapshot; + boost::shared_ptr _analog_data; + boost::shared_ptr _cur_analog_snapshot; std::auto_ptr _sampling_thread; signals: + void capture_state_changed(int state); + void signals_changed(); void data_updated();