X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=pv%2Fdata%2Fdecoderstack.h;h=35f76874bc77bfbc40230aa51d956b7380bed7a5;hb=e9213170687cf4afd14e20acdc690ff9381d94ae;hp=2eeaf1c76fa4c1cba4718c8e627c05e1bb0e7afa;hpb=8bd26d8b9c831b509ee3241ea4dac6f50c023622;p=pulseview.git diff --git a/pv/data/decoderstack.h b/pv/data/decoderstack.h index 2eeaf1c..35f7687 100644 --- a/pv/data/decoderstack.h +++ b/pv/data/decoderstack.h @@ -23,11 +23,14 @@ #include "signaldata.h" +#include +#include #include +#include +#include +#include #include -#include -#include #include #include @@ -42,7 +45,7 @@ struct srd_proto_data; struct srd_session; namespace DecoderStackTest { -class TwoDecoderStack; +struct TwoDecoderStack; } namespace pv { @@ -80,8 +83,8 @@ public: virtual ~DecoderStack(); - const std::list< boost::shared_ptr >& stack() const; - void push(boost::shared_ptr decoder); + const std::list< std::shared_ptr >& stack() const; + void push(std::shared_ptr decoder); void remove(int index); int64_t samples_decoded() const; @@ -115,14 +118,14 @@ private: static void annotation_callback(srd_proto_data *pdata, void *decoder); -private slots: +private Q_SLOTS: void on_new_frame(); void on_data_received(); void on_frame_ended(); -signals: +Q_SIGNALS: void new_decode_data(); private: @@ -134,18 +137,18 @@ private: * @todo A proper solution should be implemented to allow multiple * decode operations. */ - static boost::mutex _global_decode_mutex; + static std::mutex _global_decode_mutex; - std::list< boost::shared_ptr > _stack; + std::list< std::shared_ptr > _stack; - boost::shared_ptr _snapshot; + std::shared_ptr _snapshot; - mutable boost::mutex _input_mutex; - mutable boost::condition_variable _input_cond; + mutable std::mutex _input_mutex; + mutable std::condition_variable _input_cond; int64_t _sample_count; bool _frame_complete; - mutable boost::mutex _output_mutex; + mutable std::mutex _output_mutex; int64_t _samples_decoded; std::map _rows; @@ -154,9 +157,10 @@ private: QString _error_message; - boost::thread _decode_thread; + std::thread _decode_thread; + std::atomic _interrupt; - friend class DecoderStackTest::TwoDecoderStack; + friend struct DecoderStackTest::TwoDecoderStack; }; } // namespace data