X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.hpp;h=e113cf4fdb77711d33a4aac0b45cff49521e88ce;hp=90dd82374675d768dd1d68a3c94e2ba5cc9e276e;hb=2b05d3110a0a50ce93c8c887a2dc00c1375e92fa;hpb=8524a597c3625c49cb42436c25fd9b06d9b5b06a diff --git a/pv/session.hpp b/pv/session.hpp index 90dd8237..e113cf4f 100644 --- a/pv/session.hpp +++ b/pv/session.hpp @@ -31,15 +31,17 @@ #include #ifdef _WIN32 -// Windows: Avoid namespace pollution by thread.hpp (which includes windows.h). +// Windows: Avoid boost/thread namespace pollution (which includes windows.h). #define NOGDI #define NORESOURCE #endif -#include +#include #include #include +#include "util.hpp" + struct srd_decoder; struct srd_channel; @@ -112,11 +114,9 @@ public: void stop_capture(); - std::set< std::shared_ptr > get_data() const; - - boost::shared_mutex& signals_mutex() const; + double get_samplerate() const; - const std::unordered_set< std::shared_ptr >& + const std::unordered_set< std::shared_ptr > signals() const; #ifdef ENABLE_DECODE @@ -136,16 +136,15 @@ private: std::shared_ptr signal_from_channel( std::shared_ptr channel) const; - void read_sample_rate(std::shared_ptr device); - private: - void sample_thread_proc(std::shared_ptr device, - std::function error_handler); + void sample_thread_proc(std::function error_handler); void feed_in_header(); void feed_in_meta(std::shared_ptr meta); + void feed_in_trigger(); + void feed_in_frame_begin(); void feed_in_logic(std::shared_ptr logic); @@ -161,11 +160,12 @@ private: std::vector< std::shared_ptr > decode_traces_; - mutable std::mutex sampling_mutex_; + mutable std::mutex sampling_mutex_; //!< Protects access to capture_state_. capture_state capture_state_; mutable boost::shared_mutex signals_mutex_; std::unordered_set< std::shared_ptr > signals_; + std::set< std::shared_ptr > all_signal_data_; mutable std::recursive_mutex data_mutex_; std::shared_ptr logic_data_; @@ -176,12 +176,16 @@ private: std::thread sampling_thread_; + bool out_of_memory_; + Q_SIGNALS: void capture_state_changed(int state); void device_selected(); void signals_changed(); + void trigger_event(util::Timestamp location); + void frame_began(); void data_received();