X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=pv%2Fdata%2Fdecoderstack.h;h=35f76874bc77bfbc40230aa51d956b7380bed7a5;hb=ff30bdbafa900626fdcdf5e282d6eb56e4d4b68a;hp=1badc6b9b34988aafb41265b54d9b5681be64852;hpb=f9abf97e78bc4825d80926b0ebc6cbaef40768b1;p=pulseview.git diff --git a/pv/data/decoderstack.h b/pv/data/decoderstack.h index 1badc6b..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 @@ -42,7 +45,7 @@ struct srd_proto_data; struct srd_session; namespace DecoderStackTest { -class TwoDecoderStack; +struct TwoDecoderStack; } namespace pv { @@ -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< std::shared_ptr > _stack; 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