X-Git-Url: http://git.code-monkey.de/?p=pulseview.git;a=blobdiff_plain;f=pv%2Fsession.hpp;h=4c6c73e37483e60f3b72ace3fd68b6a26befd8e0;hp=90dd82374675d768dd1d68a3c94e2ba5cc9e276e;hb=bf0edd2b0cbb5f4bd5d69b0f00bcea7d037e2287;hpb=8524a597c3625c49cb42436c25fd9b06d9b5b06a diff --git a/pv/session.hpp b/pv/session.hpp index 90dd823..4c6c73e 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; @@ -62,6 +64,7 @@ class Analog; class AnalogSegment; class Logic; class LogicSegment; +class SignalBase; class SignalData; } @@ -112,11 +115,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 @@ -133,19 +134,18 @@ private: void update_signals(); - std::shared_ptr signal_from_channel( + 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,12 +161,15 @@ 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 > signalbases_; + std::set< std::shared_ptr > all_signal_data_; + mutable std::recursive_mutex data_mutex_; std::shared_ptr logic_data_; uint64_t cur_samplerate_; @@ -176,12 +179,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();