18 #ifndef PLUGINS_CHANNELTX_REMOTESRC_REMOTESRC_H_ 19 #define PLUGINS_CHANNELTX_REMOTESRC_REMOTESRC_H_ 26 #include <QNetworkRequest> 28 #include "cm256cc/cm256.h" 34 #include "../remotesource/remotesourcesettings.h" 41 class QNetworkAccessManager;
85 m_sampleRate(sampleRate)
137 nbUncorrectableErrors,
172 m_queueSize(queueSize),
173 m_queueLength(queueLength),
174 m_readSamplesCount(readSamplesCount),
175 m_nbCorrectableErrors(nbCorrectableErrors),
176 m_nbUncorrectableErrors(nbUncorrectableErrors),
177 m_nbOriginalBlocks(nbOriginalBlocks),
178 m_nbFECBlocks(nbFECBlocks),
179 m_centerFreq(centerFreq),
180 m_sampleRate(sampleRate)
191 virtual void start();
205 (void) sinkElseSource;
214 QString& errorMessage);
218 const QStringList& channelSettingsKeys,
220 QString& errorMessage);
224 QString& errorMessage);
267 #endif // PLUGINS_CHANNELTX_REMOTESRC_REMOTESRC_H_
uint32_t get_nbOriginalBlocks() const
RemoteSourceThread * m_sourceThread
virtual bool deserialize(const QByteArray &data)
QNetworkAccessManager * m_networkManager
MsgSampleRateNotification(int sampleRate)
uint32_t m_nbCorrectableErrors
count of correctable errors in number of blocks
uint32_t m_nbOriginalBlocks
RemoteDataReadQueue m_dataReadQueue
void webapiReverseSendSettings(QList< QString > &channelSettingsKeys, const RemoteSourceSettings &settings, bool force)
uint32_t m_readSamplesCount
virtual QByteArray serialize() const
void handleDataBlock(RemoteDataBlock *dataBlock)
virtual int getNbSinkStreams() const
uint32_t get_tv_sec() const
void webapiFormatChannelSettings(SWGSDRangel::SWGChannelSettings &response, const RemoteSourceSettings &settings)
void setDataLink(const QString &dataAddress, uint16_t dataPort)
uint32_t get_readSamplesCount() const
virtual void getTitle(QString &title)
void applySettings(const RemoteSourceSettings &settings, bool force=false)
virtual void pullAudio(int nbSamples)
#define MESSAGE_CLASS_DECLARATION
MsgReportStreamData(uint32_t tv_sec, uint32_t tv_usec, uint32_t queueSize, uint32_t queueLength, uint32_t readSamplesCount, uint32_t nbCorrectableErrors, uint32_t nbUncorrectableErrors, uint32_t nbOriginalBlocks, uint32_t nbFECBlocks, uint32_t centerFreq, uint32_t sampleRate)
virtual qint64 getCenterFrequency() const
Applies to a default stream.
ThreadedBasebandSampleSource * m_threadedChannelizer
RemoteDataQueue m_dataQueue
uint32_t m_nbUncorrectableErrors
count of uncorrectable errors in number of blocks
uint32_t get_nbFECBlocks() const
virtual qint64 getStreamCenterFrequency(int streamIndex, bool sinkElseSource) const
int getSampleRate() const
virtual bool handleMessage(const Message &cmd)
Processing of a message. Returns true if message has actually been processed.
static MsgSampleRateNotification * create(int sampleRate)
void printMeta(const QString &header, RemoteMetaDataFEC *metaData)
CM256::cm256_block m_cm256DescriptorBlocks[2 *RemoteNbOrginalBlocks]
CM256 decoder descriptors (block addresses and block indexes)
uint32_t get_queueSize() const
uint32_t get_queueLength() const
uint32_t get_tv_usec() const
static MsgQueryStreamData * create()
uint32_t get_sampleRate() const
uint32_t m_nbCorrectableErrors
RemoteSourceSettings m_settings
uint32_t m_nbUncorrectableErrors
void networkManagerFinished(QNetworkReply *reply)
uint32_t get_nbCorrectableErrors() const
uint32_t get_nbUncorrectableErrors() const
virtual void getIdentifier(QString &id)
static MsgReportStreamData * create(uint32_t tv_sec, uint32_t tv_usec, uint32_t queueSize, uint32_t queueLength, uint32_t readSamplesCount, uint32_t nbCorrectableErrors, uint32_t nbUncorrectableErrors, uint32_t nbOriginalBlocks, uint32_t nbFECBlocks, uint32_t centerFreq, uint32_t sampleRate)
virtual int webapiSettingsGet(SWGSDRangel::SWGChannelSettings &response, QString &errorMessage)
RemoteMetaDataFEC m_currentMeta
virtual int webapiSettingsPutPatch(bool force, const QStringList &channelSettingsKeys, SWGSDRangel::SWGChannelSettings &response, QString &errorMessage)
static const QString m_channelIdURI
virtual void pull(Sample &sample)
uint32_t get_centerFreq() const
UpChannelizer * m_channelizer
static const QString m_channelId
RemoteSource(DeviceAPI *deviceAPI)
virtual int webapiReportGet(SWGSDRangel::SWGChannelReport &response, QString &errorMessage)
uint32_t calculateDataReadQueueSize(int sampleRate)
QNetworkRequest m_networkRequest
void webapiFormatChannelReport(SWGSDRangel::SWGChannelReport &response)
virtual int getNbSourceStreams() const