X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsigsession.h;h=b2dc467612655e59e1e189f78e813832f9b6bac4;hp=b4f07db4394397579e8d429bf9d9ca3d763e88b5;hb=785fd8d138e5866ade499c02ea405b8852fee113;hpb=6ac96c2e0ef986da9c9ebea50906cb717aa382ba diff --git a/pv/sigsession.h b/pv/sigsession.h index b4f07db4..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,43 +62,60 @@ 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;