/////////////////////////////////////////////////////////////////////////////////// // Copyright (C) 2012 maintech GmbH, Otto-Hahn-Str. 15, 97204 Hoechberg, Germany // // written by Christian Daniel // // Copyright (C) 2014 John Greb // // Copyright (C) 2015-2016, 2018-2020 Edouard Griffiths, F4EXB // // // // This program is free software; you can redistribute it and/or modify // // it under the terms of the GNU General Public License as published by // // the Free Software Foundation as version 3 of the License, or // // (at your option) any later version. // // // // This program is distributed in the hope that it will be useful, // // but WITHOUT ANY WARRANTY; without even the implied warranty of // // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // // GNU General Public License V3 for more details. // // // // You should have received a copy of the GNU General Public License // // along with this program. If not, see . // /////////////////////////////////////////////////////////////////////////////////// #ifndef INCLUDE_SIGMFFILEINPUTWORK_H #define INCLUDE_SIGMFFILEINPUTWORK_H #include #include #include #include #include #include #include "dsp/inthalfbandfilter.h" #include "util/message.h" #define FILESOURCE_THROTTLE_MS 50 class SampleSinkFifo; class MessageQueue; class SigMFFileCapture; class SigMFFileMetaInfo; class SigMFConverterInterface; class SigMFFileInputWorker : public QObject { Q_OBJECT public: class MsgReportEOF : public Message { MESSAGE_CLASS_DECLARATION public: static MsgReportEOF* create() { return new MsgReportEOF(); } private: MsgReportEOF() : Message() { } }; class MsgReportTrackChange : public Message { MESSAGE_CLASS_DECLARATION public: int getTrackIndex() const { return m_trackIndex; } static MsgReportTrackChange* create(int trackIndex) { return new MsgReportTrackChange(trackIndex); } private: int m_trackIndex; MsgReportTrackChange(int trackIndex) : Message(), m_trackIndex(trackIndex) { } }; SigMFFileInputWorker(std::ifstream *samplesStream, SampleSinkFifo* sampleFifo, const QTimer& timer, MessageQueue *fileInputMessageQueue, QObject* parent = NULL); ~SigMFFileInputWorker(); void startWork(); void stopWork(); void setBuffers(std::size_t chunksize); bool isRunning() const { return m_running; } quint64 getSamplesCount() const { return m_samplesCount; } void setSamplesCount(uint64_t samplesCount) { m_samplesCount = samplesCount; } void setTotalSamples(uint64_t totalSamples) { m_totalSamples = totalSamples; } void setMetaInformation(const SigMFFileMetaInfo *metaInfo, const QList *captures); void setAccelerationFactor(int accelerationFactor); void setTrackIndex(int trackIndex); private: volatile bool m_running; const SigMFFileMetaInfo *m_metaInfo; const QList *m_captures; int m_currentTrackIndex; std::ifstream* m_ifstream; quint8 *m_fileBuf; quint8 *m_convertBuf; std::size_t m_bufsize; qint64 m_chunksize; SampleSinkFifo* m_sampleFifo; uint64_t m_samplesCount; uint64_t m_totalSamples; const QTimer& m_timer; MessageQueue *m_fileInputMessageQueue; int m_samplerate; //!< File I/Q stream original sample rate int m_accelerationFactor; quint64 m_samplesize; //!< File effective sample size in bits (I or Q). Ex: 16, 24. quint64 m_samplebytes; //!< Number of bytes used to store a I or Q sample. Ex: 2. 4. qint64 m_throttlems; QElapsedTimer m_elapsedTimer; bool m_throttleToggle; SigMFConverterInterface *m_sigMFConverter; void run(); //void decimate1(SampleVector::iterator* it, const qint16* buf, qint32 len); void setSampleRate(); void setConverter(); void writeToSampleFifo(const quint8* buf, qint32 nbBytes); void writeToSampleFifoBAK(const quint8* buf, qint32 nbBytes); private slots: void tick(); }; #endif // INCLUDE_SIGMFFILEINPUTWORK_H