acquisitionworker.h

Go to the documentation of this file.

 
#ifndef ACQUISITIONWORKER_H
#define ACQUISITIONWORKER_H
 
#include <peak/data_stream/peak_data_stream.hpp>
 
#include <QObject>
 
class AcquisitionWorker : public QObject
{
    Q_OBJECT
 
public:
    AcquisitionWorker() = default;
    ~AcquisitionWorker() override = default;
 
    void Start();
    void Stop();
    void Pause();
    void Resume();
    void SetDataStream(std::shared_ptr<peak::core::DataStream>);
    enum WorkerState
    {
        IDLE,
        RUNNING,
        PAUSED
    };
 
    WorkerState currentState();
 
private:
    std::shared_ptr<peak::core::DataStream> m_dataStream;
 
    unsigned int m_frameCounter{};
    unsigned int m_errorCounter{};
 
    WorkerState m_state = IDLE;
 
signals:
    void bufferReceived(std::shared_ptr<peak::core::Buffer> buffer);
    void counterChanged(const unsigned int, const unsigned int);
    void finished();
};
 
Q_DECLARE_METATYPE(std::shared_ptr<peak::core::Buffer>)
 
#endif // ACQUISITIONWORKER_H