X-Git-Url: https://sigrok.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=pv%2Fsigsession.h;h=fa2c7af413db55b174ad78ffa85593f409e69975;hb=d64d159628c795e1413127aafd83ec1bc9ace91c;hp=259356eef263b655a50c83ddb2da9604ac19cfa2;hpb=bc5c1a99be1dbbad5263ce9852f38b5c31ce1c4a;p=pulseview.git diff --git a/pv/sigsession.h b/pv/sigsession.h index 259356ee..fa2c7af4 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,45 +62,75 @@ public: ~SigSession(); - void load_file(const std::string &name); + /** + * Gets device instance that will be used in the next capture session. + */ + struct sr_dev_inst* get_device() const; + + /** + * Sets device instance that will be used in the next capture session. + */ + void set_device(struct sr_dev_inst *sdi); + + 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(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); + 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, const struct sr_datafeed_packet *packet); static void data_feed_in_proc(const struct sr_dev_inst *sdi, - const struct sr_datafeed_packet *packet); + const struct sr_datafeed_packet *packet, void *cb_data); private: - mutable boost::mutex _state_mutex; + + /** + * The device instance that will be used in the next capture session. + */ + struct sr_dev_inst *_sdi; + + 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;