X-Git-Url: http://git.code-monkey.de/?a=blobdiff_plain;f=pv%2Fdata%2Fdecoderstack.h;h=c50f3859962d020847ce9166727c1066feaa0bff;hb=8dbbc7f0b9ea59d0f0d62225772f8a56eee125f5;hp=2eeaf1c76fa4c1cba4718c8e627c05e1bb0e7afa;hpb=8bd26d8b9c831b509ee3241ea4dac6f50c023622;p=pulseview.git diff --git a/pv/data/decoderstack.h b/pv/data/decoderstack.h index 2eeaf1c..c50f385 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 { @@ -75,13 +78,13 @@ private: static const unsigned int DecodeNotifyPeriod; public: - DecoderStack(pv::SigSession &_session, + DecoderStack(pv::SigSession &session_, const srd_decoder *const decoder); 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,18 +118,18 @@ 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: - pv::SigSession &_session; + pv::SigSession &session_; /** * This mutex prevents more than one decode operation occuring @@ -134,29 +137,30 @@ 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; - int64_t _sample_count; - bool _frame_complete; + mutable std::mutex input_mutex_; + mutable std::condition_variable input_cond_; + int64_t sample_count_; + bool frame_complete_; - mutable boost::mutex _output_mutex; - int64_t _samples_decoded; + mutable std::mutex output_mutex_; + int64_t samples_decoded_; - std::map _rows; + std::map rows_; - std::map, decode::Row> _class_rows; + std::map, decode::Row> class_rows_; - QString _error_message; + QString error_message_; - boost::thread _decode_thread; + std::thread decode_thread_; + std::atomic interrupt_; - friend class DecoderStackTest::TwoDecoderStack; + friend struct DecoderStackTest::TwoDecoderStack; }; } // namespace data