X-Git-Url: https://sigrok.org/gitweb/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.hpp;h=e113cf4fdb77711d33a4aac0b45cff49521e88ce;hp=59060a591fdfd0d743ad83780dbcd066cdefbc01;hb=3b353d67bba8fc2076d03e93fed6483572600fa9;hpb=b48daed65bff5da5fddc6db11377b8730220865f diff --git a/pv/session.hpp b/pv/session.hpp index 59060a59..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 @@ -137,13 +137,14 @@ private: std::shared_ptr channel) const; 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); @@ -159,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_; @@ -174,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();