VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2024-12-23 01:55:48 -05:00
Code Issues Projects Releases Wiki Activity

Merge pull request #1413 from pinkavaj/pi-qmutex-depr-fix

Browse Source 
Replace deprecated QMutex(Recursive) with QRecursiveMutex
This commit is contained in:
Edouard Griffiths 2022-09-18 07:42:55 +02:00 committed by GitHub
commit c97a6a7af1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
234 changed files with 310 additions and 432 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
logging/logger.cpp
View File

@ -7,6 +7,7 @@
#include <stdio.h>
#include <stdlib.h>
#include <QMutex>
#include <QRecursiveMutex>
#include <QDateTime>
#include <QThread>
#include <QObject>
@ -19,7 +20,7 @@ Logger* Logger::defaultLogger=0;
QThreadStorage<QHash<QString,QString>*> Logger::logVars;
QMutex Logger::mutex;
QRecursiveMutex Logger::mutex;
Logger::Logger(QObject* parent)
@ -43,8 +44,8 @@ Logger::Logger(const QString msgFormat, const QString timestampFormat, const QtM
void Logger::msgHandler(const QtMsgType type, const QString &message, const QString &file, const QString &function, const int line)
{
static QMutex recursiveMutex(QMutex::Recursive);
static QMutex nonRecursiveMutex(QMutex::NonRecursive);
static QRecursiveMutex recursiveMutex;
static QMutex nonRecursiveMutex;
// Prevent multiple threads from calling this method simultaneoulsy.
// But allow recursive calls, which is required to prevent a deadlock

4
logging/logger.h
View File

@ -10,7 +10,7 @@
#include <QThreadStorage>
#include <QHash>
#include <QStringList>
#include <QMutex>
#include <QRecursiveMutex>
#include <QObject>
#include "logglobal.h"
#include "logmessage.h"
@ -139,7 +139,7 @@ protected:
int bufferSize;
/** Used to synchronize access of concurrent threads */
static QMutex mutex;
static QRecursiveMutex mutex;
/**
Decorate and write a log message to stderr. Override this method

5
plugins/channelmimo/beamsteeringcwmod/beamsteeringcwmodbaseband.cpp
View File

@ -27,8 +27,7 @@
MESSAGE_CLASS_DEFINITION(BeamSteeringCWModBaseband::MsgConfigureBeamSteeringCWModBaseband, Message)
MESSAGE_CLASS_DEFINITION(BeamSteeringCWModBaseband::MsgSignalNotification, Message)
BeamSteeringCWModBaseband::BeamSteeringCWModBaseband() :
m_mutex(QMutex::Recursive)
BeamSteeringCWModBaseband::BeamSteeringCWModBaseband()
{
m_sampleMOFifo.init(2, SampleMOFifo::getSizePolicy(48000));
m_vbegin.resize(2);
@ -244,4 +243,4 @@ void BeamSteeringCWModBaseband::applySettings(const BeamSteeringCWModSettings& s
}
m_settings = settings;
}
}

4
plugins/channelmimo/beamsteeringcwmod/beamsteeringcwmodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_BEAMSTEERINGCWMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplemofifo.h"
#include "util/message.h"
@ -93,7 +93,7 @@ private:
UpChannelizer *m_channelizers[2];
BeamSteeringCWModStreamSource m_streamSources[2];
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
QMutex m_mutex;
QRecursiveMutex m_mutex;
unsigned int m_lastStream;
private slots:

3
plugins/channelmimo/doa2/doa2baseband.cpp
View File

@ -42,8 +42,7 @@ DOA2Baseband::DOA2Baseband(int fftSize) :
m_magThreshold(0.0f),
m_fftAvg(1),
m_fftAvgCount(0),
m_scopeSink(nullptr),
m_mutex(QMutex::Recursive)
m_scopeSink(nullptr)
{
m_sampleMIFifo.init(2, 96000 * 8);
m_vbegin.resize(2);

4
plugins/channelmimo/doa2/doa2baseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_DOA2BASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplemififo.h"
#include "util/messagequeue.h"
@ -137,7 +137,7 @@ private:
DownChannelizer *m_channelizers[2];
ScopeVis *m_scopeSink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
QMutex m_mutex;
QRecursiveMutex m_mutex;
unsigned int m_lastStream;
private slots:

3
plugins/channelmimo/interferometer/interferometerbaseband.cpp
View File

@ -33,8 +33,7 @@ MESSAGE_CLASS_DEFINITION(InterferometerBaseband::MsgConfigureCorrelation, Messag
InterferometerBaseband::InterferometerBaseband(int fftSize) :
m_correlator(fftSize),
m_spectrumSink(nullptr),
m_scopeSink(nullptr),
m_mutex(QMutex::Recursive)
m_scopeSink(nullptr)
{
m_sampleMIFifo.init(2, 96000 * 8);
m_vbegin.resize(2);

4
plugins/channelmimo/interferometer/interferometerbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_INTERFEROMETERBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplemififo.h"
#include "util/messagequeue.h"
@ -126,7 +126,7 @@ private:
BasebandSampleSink *m_spectrumSink;
ScopeVis *m_scopeSink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
QMutex m_mutex;
QRecursiveMutex m_mutex;
unsigned int m_lastStream;
private slots:

3
plugins/channelrx/chanalyzer/chanalyzerbaseband.cpp
View File

@ -26,8 +26,7 @@
MESSAGE_CLASS_DEFINITION(ChannelAnalyzerBaseband::MsgConfigureChannelAnalyzerBaseband, Message)
ChannelAnalyzerBaseband::ChannelAnalyzerBaseband() :
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("ChannelAnalyzerBaseband::ChannelAnalyzerBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/chanalyzer/chanalyzerbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_CHANNELANALYZERBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -81,7 +81,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
ChannelAnalyzerSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const ChannelAnalyzerSettings& settings, bool force = false);

3
plugins/channelrx/demodadsb/adsbdemodbaseband.cpp
View File

@ -27,8 +27,7 @@
MESSAGE_CLASS_DEFINITION(ADSBDemodBaseband::MsgConfigureADSBDemodBaseband, Message)
ADSBDemodBaseband::ADSBDemodBaseband() :
m_mutex(QMutex::Recursive)
ADSBDemodBaseband::ADSBDemodBaseband()
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(8000000));
m_channelizer = new DownChannelizer(&m_sink);

4
plugins/channelrx/demodadsb/adsbdemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_ADSBDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -77,7 +77,7 @@ private:
ADSBDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
ADSBDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const ADSBDemodSettings& settings, bool force = false);

3
plugins/channelrx/demodadsb/adsbdemodworker.cpp
View File

@ -80,8 +80,7 @@ void ADSBBeastServer::discardClient()
}
ADSBDemodWorker::ADSBDemodWorker() :
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
connect(&m_heartbeatTimer, SIGNAL(timeout()), this, SLOT(heartbeat()));
connect(&m_socket, SIGNAL(readyRead()),this, SLOT(recv()));

2
plugins/channelrx/demodadsb/adsbdemodworker.h
View File

@ -92,7 +92,7 @@ private:
MessageQueue m_inputMessageQueue;
ADSBDemodSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
QTimer m_heartbeatTimer;
QTcpSocket m_socket;
QFile m_logFile;

3
plugins/channelrx/demodais/aisdemodbaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(AISDemodBaseband::MsgConfigureAISDemodBaseband, Message
AISDemodBaseband::AISDemodBaseband(AISDemod *aisDemod) :
m_sink(aisDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("AISDemodBaseband::AISDemodBaseband");

4
plugins/channelrx/demodais/aisdemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_AISDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -87,7 +87,7 @@ private:
AISDemodSettings m_settings;
ScopeVis m_scopeSink;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(AISDemodSink *sink);

3
plugins/channelrx/demodam/amdemodbaseband.cpp
View File

@ -26,8 +26,7 @@
MESSAGE_CLASS_DEFINITION(AMDemodBaseband::MsgConfigureAMDemodBaseband, Message)
AMDemodBaseband::AMDemodBaseband() :
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("AMDemodBaseband::AMDemodBaseband");

4
plugins/channelrx/demodam/amdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_AMDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -85,7 +85,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
AMDemodSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const AMDemodSettings& settings, bool force = false);

3
plugins/channelrx/demodapt/aptdemodbaseband.cpp
View File

@ -29,8 +29,7 @@ MESSAGE_CLASS_DEFINITION(APTDemodBaseband::MsgConfigureAPTDemodBaseband, Message
APTDemodBaseband::APTDemodBaseband(APTDemod *packetDemod) :
m_sink(packetDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("APTDemodBaseband::APTDemodBaseband");

4
plugins/channelrx/demodapt/aptdemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_APTDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -81,7 +81,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
APTDemodSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(APTDemodSink *sink);

3
plugins/channelrx/demodapt/aptdemodimageworker.cpp
View File

@ -38,8 +38,7 @@ APTDemodImageWorker::APTDemodImageWorker(APTDemod *aptDemod) :
m_messageQueueToGUI(nullptr),
m_aptDemod(aptDemod),
m_sgp4(nullptr),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
for (int y = 0; y < APT_MAX_HEIGHT; y++)
{

4
plugins/channelrx/demodapt/aptdemodimageworker.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_APTDEMODIMAGEWORKER_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include <QImage>
#include <apt.h>
@ -137,7 +137,7 @@ private:
QList<QImage> m_palettes;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const APTDemodSettings& settings, bool force = false);

3
plugins/channelrx/demodatv/atvdemodbaseband.cpp
View File

@ -26,8 +26,7 @@
MESSAGE_CLASS_DEFINITION(ATVDemodBaseband::MsgConfigureATVDemodBaseband, Message)
ATVDemodBaseband::ATVDemodBaseband() :
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("ATVDemodBaseband::ATVDemodBaseband");
m_sink.setScopeSink(&m_scopeSink);

4
plugins/channelrx/demodatv/atvdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_ATVDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -82,7 +82,7 @@ private:
ATVDemodSettings m_settings;
ScopeVis m_scopeSink;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const ATVDemodSettings& settings, bool force = false);

1
plugins/channelrx/demodbfm/bfmdemodbaseband.cpp
View File

@ -28,7 +28,6 @@
MESSAGE_CLASS_DEFINITION(BFMDemodBaseband::MsgConfigureBFMDemodBaseband, Message)
BFMDemodBaseband::BFMDemodBaseband() :
m_mutex(QMutex::Recursive),
m_messageQueueToGUI(nullptr),
m_spectrumVis(nullptr)
{

4
plugins/channelrx/demodbfm/bfmdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_BFMDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -90,7 +90,7 @@ private:
BFMDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
BFMDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
MessageQueue *m_messageQueueToGUI;
SpectrumVis *m_spectrumVis;

3
plugins/channelrx/demodchirpchat/chirpchatdemodbaseband.cpp
View File

@ -25,8 +25,7 @@
MESSAGE_CLASS_DEFINITION(ChirpChatDemodBaseband::MsgConfigureChirpChatDemodBaseband, Message)
ChirpChatDemodBaseband::ChirpChatDemodBaseband() :
m_mutex(QMutex::Recursive)
ChirpChatDemodBaseband::ChirpChatDemodBaseband()
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));
m_channelizer = new DownChannelizer(&m_sink);

4
plugins/channelrx/demodchirpchat/chirpchatdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_CHIRPCHATDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -76,7 +76,7 @@ private:
ChirpChatDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
ChirpChatDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const ChirpChatDemodSettings& settings, bool force = false);

3
plugins/channelrx/demoddab/dabdemodbaseband.cpp
View File

@ -29,8 +29,7 @@ MESSAGE_CLASS_DEFINITION(DABDemodBaseband::MsgConfigureDABDemodBaseband, Message
DABDemodBaseband::DABDemodBaseband(DABDemod *packetDemod) :
m_sink(packetDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("DABDemodBaseband::DABDemodBaseband");

4
plugins/channelrx/demoddab/dabdemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_DABDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -85,7 +85,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
DABDemodSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const DABDemodSettings& settings, bool force = false);

3
plugins/channelrx/demoddatv/datvdemodbaseband.cpp
View File

@ -26,8 +26,7 @@
MESSAGE_CLASS_DEFINITION(DATVDemodBaseband::MsgConfigureDATVDemodBaseband, Message)
DATVDemodBaseband::DATVDemodBaseband() :
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("DATVDemodBaseband::DATVDemodBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/demoddatv/datvdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_DATVDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -101,7 +101,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
DATVDemodSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const DATVDemodSettings& settings, bool force = false);

3
plugins/channelrx/demoddatv/datvdemodsink.cpp
View File

@ -46,8 +46,7 @@ DATVDemodSink::DATVDemodSink() :
m_modcodCodeRate(-1),
m_enmModulation(DATVDemodSettings::BPSK /*DATV_FM1*/),
m_channelSampleRate(1024000),
m_messageQueueToGUI(nullptr),
m_mutex(QMutex::Recursive)
m_messageQueueToGUI(nullptr)
{
//*************** DATV PARAMETERS ***************
m_blnInitialized=false;

4
plugins/channelrx/demoddatv/datvdemodsink.h
View File

@ -18,7 +18,7 @@
#ifndef INCLUDE_DATVDEMODSINK_H
#define INCLUDE_DATVDEMODSINK_H
#include <QMutex>
#include <QRecursiveMutex>
//LeanSDR
#include "leansdr/framework.h"
@ -345,7 +345,7 @@ private:
MovingAverageUtil<double, double, 32> m_objMagSqAverage;
MessageQueue *m_messageQueueToGUI;
QMutex m_mutex;
QRecursiveMutex m_mutex;
static const unsigned int m_rfFilterFftLength;
};

3
plugins/channelrx/demoddatv/datvideostream.cpp
View File

@ -19,8 +19,7 @@
#include "datvideostream.h"
#include <stdio.h>
DATVideostream::DATVideostream():
m_mutex(QMutex::NonRecursive)
DATVideostream::DATVideostream()
{
cleanUp();
m_totalReceived = 0;

1
plugins/channelrx/demoddsd/dsddemod.cpp
View File

@ -58,7 +58,6 @@ const int DSDDemod::m_udpBlockSize = 512;
DSDDemod::DSDDemod(DeviceAPI *deviceAPI) :
ChannelAPI(m_channelIdURI, ChannelAPI::StreamSingleSink),
m_deviceAPI(deviceAPI),
m_mutex(QMutex::Recursive),
m_running(false),
m_basebandSampleRate(0)
{

4
plugins/channelrx/demoddsd/dsddemod.h
View File

@ -22,7 +22,7 @@
#include <vector>
#include <QNetworkRequest>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/basebandsamplesink.h"
#include "channel/channelapi.h"
@ -171,7 +171,7 @@ private:
DeviceAPI *m_deviceAPI;
QThread *m_thread;
DSDDemodBaseband *m_basebandSink;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool m_running;
DSDDemodSettings m_settings;
int m_basebandSampleRate; //!< stored from device message used when starting baseband sink

3
plugins/channelrx/demoddsd/dsddemodbaseband.cpp
View File

@ -25,8 +25,7 @@
MESSAGE_CLASS_DEFINITION(DSDDemodBaseband::MsgConfigureDSDDemodBaseband, Message)
DSDDemodBaseband::DSDDemodBaseband() :
m_channelizer(&m_sink),
m_mutex(QMutex::Recursive)
m_channelizer(&m_sink)
{
qDebug("DSDDemodBaseband::DSDDemodBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/demoddsd/dsddemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_DSDDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/downchannelizer.h"
@ -85,7 +85,7 @@ private:
DSDDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
DSDDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const DSDDemodSettings& settings, bool force = false);

1
plugins/channelrx/demodfreedv/freedvdemodbaseband.cpp
View File

@ -27,7 +27,6 @@ MESSAGE_CLASS_DEFINITION(FreeDVDemodBaseband::MsgConfigureFreeDVDemodBaseband, M
MESSAGE_CLASS_DEFINITION(FreeDVDemodBaseband::MsgResyncFreeDVDemod, Message)
FreeDVDemodBaseband::FreeDVDemodBaseband() :
m_mutex(QMutex::Recursive),
m_messageQueueToGUI(nullptr)
{
qDebug("FreeDVDemodBaseband::FreeDVDemodBaseband");

4
plugins/channelrx/demodfreedv/freedvdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_FREEDVDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -107,7 +107,7 @@ private:
FreeDVDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
FreeDVDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
MessageQueue *m_messageQueueToGUI;
MessageQueue *getMessageQueueToGUI() { return m_messageQueueToGUI; }

3
plugins/channelrx/demodfreedv/freedvdemodsink.cpp
View File

@ -150,8 +150,7 @@ FreeDVDemodSink::FreeDVDemodSink() :
m_iModem(0),
m_speechOut(nullptr),
m_modIn(nullptr),
m_levelInNbSamples(480), // 10ms @ 48 kS/s
m_mutex(QMutex::Recursive)
m_levelInNbSamples(480) // 10ms @ 48 kS/s
{
m_audioBuffer.resize(1<<14);
m_audioBufferFill = 0;

4
plugins/channelrx/demodfreedv/freedvdemodsink.h
View File

@ -21,7 +21,7 @@
#include <vector>
#include <QTimer>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/channelsamplesink.h"
#include "dsp/ncof.h"
@ -200,7 +200,7 @@ private:
int m_levelInNbSamples;
Real m_rmsLevel;
Real m_peakLevel;
QMutex m_mutex;
QRecursiveMutex m_mutex;
static const unsigned int m_ssbFftLen;
static const float m_agcTarget;

3
plugins/channelrx/demodm17/m17demodbaseband.cpp
View File

@ -25,8 +25,7 @@
MESSAGE_CLASS_DEFINITION(M17DemodBaseband::MsgConfigureM17DemodBaseband, Message)
M17DemodBaseband::M17DemodBaseband() :
m_mutex(QMutex::Recursive)
M17DemodBaseband::M17DemodBaseband()
{
qDebug("M17DemodBaseband::M17DemodBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/demodm17/m17demodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_M17DEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -129,7 +129,7 @@ private:
M17DemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
M17DemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const M17DemodSettings& settings, const QList<QString>& settingsKeys, bool force = false);

3
plugins/channelrx/demodnfm/dcsdetector.cpp
View File

@ -28,8 +28,7 @@ DCSDetector::DCSDetector() :
m_low(0.0f),
m_mid(0.0f),
m_prevSample(0.0f),
m_dcsWord(0),
m_mutex(QMutex::Recursive)
m_dcsWord(0)
{
setBitrate(134.3);
setEqWindow(23);

4
plugins/channelrx/demodnfm/dcsdetector.h
View File

@ -18,7 +18,7 @@
#ifndef INCLUDE_DSP_DCSDETECTOR_H_
#define INCLUDE_DSP_DCSDETECTOR_H_
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/dsptypes.h"
#include "util/golay2312.h"
@ -49,7 +49,7 @@ private:
float m_prevSample;
unsigned int m_dcsWord; //!< 23 bit DCS code word
Golay2312 m_golay2312;
QMutex m_mutex;
QRecursiveMutex m_mutex;
};
#endif // INCLUDE_DSP_DCSDETECTOR_H_

3
plugins/channelrx/demodnfm/nfmdemodbaseband.cpp
View File

@ -25,8 +25,7 @@
MESSAGE_CLASS_DEFINITION(NFMDemodBaseband::MsgConfigureNFMDemodBaseband, Message)
NFMDemodBaseband::NFMDemodBaseband() :
m_channelizer(&m_sink),
m_mutex(QMutex::Recursive)
m_channelizer(&m_sink)
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/demodnfm/nfmdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_NFMDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/downchannelizer.h"
@ -80,7 +80,7 @@ private:
NFMDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
NFMDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const NFMDemodSettings& settings, bool force = false);

3
plugins/channelrx/demodpacket/packetdemodbaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(PacketDemodBaseband::MsgConfigurePacketDemodBaseband, M
PacketDemodBaseband::PacketDemodBaseband(PacketDemod *packetDemod) :
m_sink(packetDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("PacketDemodBaseband::PacketDemodBaseband");

4
plugins/channelrx/demodpacket/packetdemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_PACKETDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -84,7 +84,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
PacketDemodSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(PacketDemodSink *sink);

3
plugins/channelrx/demodpager/pagerdemodbaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(PagerDemodBaseband::MsgConfigurePagerDemodBaseband, Mes
PagerDemodBaseband::PagerDemodBaseband(PagerDemod *pagerDemod) :
m_sink(pagerDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("PagerDemodBaseband::PagerDemodBaseband");

4
plugins/channelrx/demodpager/pagerdemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_PAGERDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -88,7 +88,7 @@ private:
PagerDemodSettings m_settings;
ScopeVis m_scopeSink;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(PagerDemodSink *sink);

3
plugins/channelrx/demodradiosonde/radiosondedemodbaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(RadiosondeDemodBaseband::MsgConfigureRadiosondeDemodBas
RadiosondeDemodBaseband::RadiosondeDemodBaseband(RadiosondeDemod *radiosondeDemod) :
m_sink(radiosondeDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("RadiosondeDemodBaseband::RadiosondeDemodBaseband");

4
plugins/channelrx/demodradiosonde/radiosondedemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_RADIOSONDEDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -87,7 +87,7 @@ private:
RadiosondeDemodSettings m_settings;
ScopeVis m_scopeSink;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(RadiosondeDemodSink *sink);

1
plugins/channelrx/demodssb/ssbdemod.cpp
View File

@ -52,7 +52,6 @@ const char* const SSBDemod::m_channelId = "SSBDemod";
SSBDemod::SSBDemod(DeviceAPI *deviceAPI) :
ChannelAPI(m_channelIdURI, ChannelAPI::StreamSingleSink),
m_deviceAPI(deviceAPI),
m_mutex(QMutex::Recursive),
m_running(false),
m_spectrumVis(SDR_RX_SCALEF),
m_basebandSampleRate(0)

4
plugins/channelrx/demodssb/ssbdemod.h
View File

@ -21,7 +21,7 @@
#include <vector>
#include <QMutex>
#include <QRecursiveMutex>
#include <QNetworkRequest>
#include "dsp/basebandsamplesink.h"
@ -143,7 +143,7 @@ private:
DeviceAPI *m_deviceAPI;
QThread *m_thread;
SSBDemodBaseband* m_basebandSink;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool m_running;
SSBDemodSettings m_settings;
SpectrumVis m_spectrumVis;

3
plugins/channelrx/demodssb/ssbdemodbaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(SSBDemodBaseband::MsgConfigureSSBDemodBaseband, Message
SSBDemodBaseband::SSBDemodBaseband() :
m_channelizer(&m_sink),
m_messageQueueToGUI(nullptr),
m_spectrumVis(nullptr),
m_mutex(QMutex::Recursive)
m_spectrumVis(nullptr)
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/demodssb/ssbdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_SSBDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/downchannelizer.h"
@ -85,7 +85,7 @@ private:
int m_channelSampleRate;
MessageQueue *m_messageQueueToGUI;
SpectrumVis *m_spectrumVis;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const SSBDemodSettings& settings, bool force = false);

3
plugins/channelrx/demodvor/vordemodbaseband.cpp
View File

@ -29,8 +29,7 @@ MESSAGE_CLASS_DEFINITION(VORDemodBaseband::MsgConfigureVORDemodBaseband, Message
VORDemodBaseband::VORDemodBaseband() :
m_messageQueueToGUI(nullptr),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("VORDemodBaseband::VORDemodBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/demodvor/vordemodbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_VORDEMODSCBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -82,7 +82,7 @@ private:
VORDemodSettings m_settings;
MessageQueue *m_messageQueueToGUI;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const VORDemodSettings& settings, bool force = false);

1
plugins/channelrx/demodvormc/vordemodmcbaseband.cpp
View File

@ -29,7 +29,6 @@ MESSAGE_CLASS_DEFINITION(VORDemodMCBaseband::MsgConfigureVORDemodBaseband, Messa
VORDemodMCBaseband::VORDemodMCBaseband() :
m_running(false),
m_mutex(QMutex::Recursive),
m_messageQueueToGUI(nullptr),
m_basebandSampleRate(0)
{

4
plugins/channelrx/demodvormc/vordemodmcbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_VORDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -120,7 +120,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
VORDemodMCSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
MessageQueue *m_messageQueueToGUI;
int m_basebandSampleRate;
int m_centerFrequency;

3
plugins/channelrx/demodwfm/wfmdemodbaseband.cpp
View File

@ -25,8 +25,7 @@
MESSAGE_CLASS_DEFINITION(WFMDemodBaseband::MsgConfigureWFMDemodBaseband, Message)
WFMDemodBaseband::WFMDemodBaseband() :
m_mutex(QMutex::Recursive)
WFMDemodBaseband::WFMDemodBaseband()
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));
m_channelizer = new DownChannelizer(&m_sink);

4
plugins/channelrx/demodwfm/wfmdemodbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_WFMDEMODBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -81,7 +81,7 @@ private:
WFMDemodSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
WFMDemodSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const WFMDemodSettings& settings, bool force = false);

1
plugins/channelrx/filesink/filesink.cpp
View File

@ -54,7 +54,6 @@ const char* const FileSink::m_channelId = "FileSink";
FileSink::FileSink(DeviceAPI *deviceAPI) :
ChannelAPI(m_channelIdURI, ChannelAPI::StreamSingleSink),
m_deviceAPI(deviceAPI),
m_mutex(QMutex::Recursive),
m_running(false),
m_spectrumVis(SDR_RX_SCALEF),
m_centerFrequency(0),

4
plugins/channelrx/filesink/filesink.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_FILESINK_H_
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include <QNetworkRequest>
#include "dsp/basebandsamplesink.h"
@ -161,7 +161,7 @@ private:
DeviceAPI *m_deviceAPI;
QThread *m_thread;
FileSinkBaseband *m_basebandSink;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool m_running;
FileSinkSettings m_settings;
SpectrumVis m_spectrumVis;

3
plugins/channelrx/filesink/filesinkbaseband.cpp
View File

@ -33,8 +33,7 @@ FileSinkBaseband::FileSinkBaseband() :
m_channelizer(&m_sink),
m_specMax(0),
m_squelchLevel(0),
m_squelchOpen(false),
m_mutex(QMutex::Recursive)
m_squelchOpen(false)
{
qDebug("FileSinkBaseband::FileSinkBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/filesink/filesinkbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_FILESINKBASEBAND_H_
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/downchannelizer.h"
@ -113,7 +113,7 @@ private:
float m_squelchLevel;
bool m_squelchOpen;
int64_t m_centerFrequency;
QMutex m_mutex;
QRecursiveMutex m_mutex;
QTimer *m_timer;
void stopWork();

3
plugins/channelrx/freqtracker/freqtrackerbaseband.cpp
View File

@ -26,8 +26,7 @@
MESSAGE_CLASS_DEFINITION(FreqTrackerBaseband::MsgConfigureFreqTrackerBaseband, Message)
FreqTrackerBaseband::FreqTrackerBaseband() :
m_mutex(QMutex::Recursive)
FreqTrackerBaseband::FreqTrackerBaseband()
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));
m_channelizer = new DownChannelizer(&m_sink);

4
plugins/channelrx/freqtracker/freqtrackerbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_FREQTRACKERBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -84,7 +84,7 @@ private:
FreqTrackerSettings m_settings;
unsigned int m_basebandSampleRate;
SpectrumVis *m_spectrumVis;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const FreqTrackerSettings& settings, bool force = false);

3
plugins/channelrx/localsink/localsinkbaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(LocalSinkBaseband::MsgConfigureLocalSinkWork, Message)
MESSAGE_CLASS_DEFINITION(LocalSinkBaseband::MsgConfigureLocalDeviceSampleSource, Message)
LocalSinkBaseband::LocalSinkBaseband() :
m_localSampleSource(nullptr),
m_mutex(QMutex::Recursive)
m_localSampleSource(nullptr)
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));
m_channelizer = new DownChannelizer(&m_sink);

4
plugins/channelrx/localsink/localsinkbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_LOCALSINKBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -114,7 +114,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
LocalSinkSettings m_settings;
DeviceSampleSource *m_localSampleSource;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const LocalSinkSettings& settings, bool force = false);

3
plugins/channelrx/noisefigure/noisefigurebaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(NoiseFigureBaseband::MsgConfigureNoiseFigureBaseband, M
NoiseFigureBaseband::NoiseFigureBaseband(NoiseFigure *aisDemod) :
m_sink(aisDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("NoiseFigureBaseband::NoiseFigureBaseband");

4
plugins/channelrx/noisefigure/noisefigurebaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_NOISEFIGUREBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -85,7 +85,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
NoiseFigureSettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(NoiseFigureSink *sink);

3
plugins/channelrx/radioastronomy/radioastronomybaseband.cpp
View File

@ -29,8 +29,7 @@ MESSAGE_CLASS_DEFINITION(RadioAstronomyBaseband::MsgConfigureRadioAstronomyBaseb
RadioAstronomyBaseband::RadioAstronomyBaseband(RadioAstronomy *aisDemod) :
m_sink(aisDemod),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("RadioAstronomyBaseband::RadioAstronomyBaseband");

4
plugins/channelrx/radioastronomy/radioastronomybaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_RADIOASTRONOMYBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -84,7 +84,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
RadioAstronomySettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void calculateOffset(RadioAstronomySink *sink);

1
plugins/channelrx/radioastronomy/radioastronomyworker.cpp
View File

@ -30,7 +30,6 @@ RadioAstronomyWorker::RadioAstronomyWorker(RadioAstronomy* radioAstronomy) :
m_msgQueueToChannel(nullptr),
m_msgQueueToGUI(nullptr),
m_running(false),
m_mutex(QMutex::Recursive),
m_sensorTimer(this)
{
connect(&m_sensorTimer, SIGNAL(timeout()), this, SLOT(measureSensors()));

2
plugins/channelrx/radioastronomy/radioastronomyworker.h
View File

@ -75,7 +75,7 @@ private:
MessageQueue *m_msgQueueToGUI;
RadioAstronomySettings m_settings;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
VISA m_visa;
ViSession m_session[RADIOASTRONOMY_SENSORS];

3
plugins/channelrx/radioclock/radioclockbaseband.cpp
View File

@ -29,8 +29,7 @@ MESSAGE_CLASS_DEFINITION(RadioClockBaseband::MsgConfigureRadioClockBaseband, Mes
RadioClockBaseband::RadioClockBaseband(RadioClock *radioClock) :
m_sink(radioClock),
m_running(false),
m_mutex(QMutex::Recursive)
m_running(false)
{
qDebug("RadioClockBaseband::RadioClockBaseband");

4
plugins/channelrx/radioclock/radioclockbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_RADIOCLOCKBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/scopevis.h"
@ -87,7 +87,7 @@ private:
RadioClockSettings m_settings;
ScopeVis m_scopeSink;
bool m_running;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const RadioClockSettings& settings, bool force = false);

3
plugins/channelrx/remotesink/remotesinkbaseband.cpp
View File

@ -25,8 +25,7 @@
MESSAGE_CLASS_DEFINITION(RemoteSinkBaseband::MsgConfigureRemoteSinkBaseband, Message)
RemoteSinkBaseband::RemoteSinkBaseband() :
m_mutex(QMutex::Recursive)
RemoteSinkBaseband::RemoteSinkBaseband()
{
qDebug("RemoteSinkBaseband::RemoteSinkBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/remotesink/remotesinkbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_REMOTESINKBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -82,7 +82,7 @@ private:
RemoteSinkSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
RemoteSinkSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const RemoteSinkSettings& settings, bool force = false);

3
plugins/channelrx/remotetcpsink/remotetcpsinkbaseband.cpp
View File

@ -25,8 +25,7 @@
#include "remotetcpsinkbaseband.h"
#include "remotetcpsink.h"
RemoteTCPSinkBaseband::RemoteTCPSinkBaseband() :
m_mutex(QMutex::Recursive)
RemoteTCPSinkBaseband::RemoteTCPSinkBaseband()
{
qDebug("RemoteTCPSinkBaseband::RemoteTCPSinkBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/remotetcpsink/remotetcpsinkbaseband.h
View File

@ -20,7 +20,7 @@
#define INCLUDE_REMOTETCPSINKBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -60,7 +60,7 @@ private:
RemoteTCPSinkSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
RemoteTCPSinkSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const RemoteTCPSinkSettings& settings, bool force = false, bool remoteChange = false);

1
plugins/channelrx/remotetcpsink/remotetcpsinksink.cpp
View File

@ -36,7 +36,6 @@ RemoteTCPSinkSink::RemoteTCPSinkSink() :
m_channelFrequencyOffset(0),
m_channelSampleRate(48000),
m_linearGain(1.0f),
m_mutex(QMutex::Recursive),
m_server(nullptr)
{
qDebug("RemoteTCPSinkSink::RemoteTCPSinkSink");

2
plugins/channelrx/remotetcpsink/remotetcpsinksink.h
View File

@ -75,7 +75,7 @@ private:
uint32_t m_channelIndex;
float m_linearGain;
QMutex m_mutex;
QRecursiveMutex m_mutex;
QTcpServer *m_server;
QList<QTcpSocket *> m_clients;

1
plugins/channelrx/sigmffilesink/sigmffilesink.cpp
View File

@ -54,7 +54,6 @@ const char* const SigMFFileSink::m_channelId = "SigMFFileSink";
SigMFFileSink::SigMFFileSink(DeviceAPI *deviceAPI) :
ChannelAPI(m_channelIdURI, ChannelAPI::StreamSingleSink),
m_deviceAPI(deviceAPI),
m_mutex(QMutex::Recursive),
m_running(false),
m_spectrumVis(SDR_RX_SCALEF),
m_centerFrequency(0),

4
plugins/channelrx/sigmffilesink/sigmffilesink.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_SIGMFFILESINK_H_
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include <QNetworkRequest>
#include "dsp/basebandsamplesink.h"
@ -161,7 +161,7 @@ private:
DeviceAPI *m_deviceAPI;
QThread *m_thread;
SigMFFileSinkBaseband *m_basebandSink;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool m_running;
SigMFFileSinkSettings m_settings;
SpectrumVis m_spectrumVis;

3
plugins/channelrx/sigmffilesink/sigmffilesinkbaseband.cpp
View File

@ -33,8 +33,7 @@ SigMFFileSinkBaseband::SigMFFileSinkBaseband() :
m_channelizer(&m_sink),
m_specMax(0),
m_squelchLevel(0),
m_squelchOpen(false),
m_mutex(QMutex::Recursive)
m_squelchOpen(false)
{
qDebug("SigMFFileSinkBaseband::SigMFFileSinkBaseband");
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));

4
plugins/channelrx/sigmffilesink/sigmffilesinkbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_SIFMFFILESINKBASEBAND_H_
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "dsp/downchannelizer.h"
@ -113,7 +113,7 @@ private:
float m_squelchLevel;
bool m_squelchOpen;
int64_t m_centerFrequency;
QMutex m_mutex;
QRecursiveMutex m_mutex;
QTimer *m_timer;
void stopWork();

3
plugins/channelrx/udpsink/udpsinkbaseband.cpp
View File

@ -26,8 +26,7 @@
MESSAGE_CLASS_DEFINITION(UDPSinkBaseband::MsgConfigureUDPSinkBaseband, Message)
MESSAGE_CLASS_DEFINITION(UDPSinkBaseband::MsgEnableSpectrum, Message)
UDPSinkBaseband::UDPSinkBaseband() :
m_mutex(QMutex::Recursive)
UDPSinkBaseband::UDPSinkBaseband()
{
m_sampleFifo.setSize(SampleSinkFifo::getSizePolicy(48000));
m_channelizer = new DownChannelizer(&m_sink);

4
plugins/channelrx/udpsink/udpsinkbaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_UDPSINKBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesinkfifo.h"
#include "util/message.h"
@ -97,7 +97,7 @@ private:
UDPSinkSink m_sink;
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
UDPSinkSettings m_settings;
QMutex m_mutex;
QRecursiveMutex m_mutex;
bool handleMessage(const Message& cmd);
void applySettings(const UDPSinkSettings& settings, bool force = false);

1
plugins/channeltx/filesource/filesource.cpp
View File

@ -53,7 +53,6 @@ const char* const FileSource::m_channelId ="FileSource";
FileSource::FileSource(DeviceAPI *deviceAPI) :
ChannelAPI(m_channelIdURI, ChannelAPI::StreamSingleSource),
m_deviceAPI(deviceAPI),
m_settingsMutex(QMutex::Recursive),
m_frequencyOffset(0),
m_basebandSampleRate(0),
m_linearGain(0.0)

2
plugins/channeltx/filesource/filesource.h
View File

@ -228,7 +228,7 @@ private:
FileSourceSettings m_settings;
SampleVector m_sampleBuffer;
QMutex m_settingsMutex;
QRecursiveMutex m_settingsMutex;
uint64_t m_frequencyOffset;
uint32_t m_basebandSampleRate;
double m_linearGain;

5
plugins/channeltx/filesource/filesourcebaseband.cpp
View File

@ -31,8 +31,7 @@ MESSAGE_CLASS_DEFINITION(FileSourceBaseband::MsgConfigureFileSourceSeek, Message
FileSourceBaseband::FileSourceBaseband() :
m_avg(0.0),
m_peak(0.0),
m_nbSamples(1),
m_mutex(QMutex::Recursive)
m_nbSamples(1)
{
m_sampleFifo.resize(SampleSourceFifo::getSizePolicy(48000));
m_channelizer = new UpChannelizer(&m_source);
@ -216,4 +215,4 @@ int FileSourceBaseband::getChannelSampleRate() const
quint64 FileSourceBaseband::getSamplesCount() const
{
return m_source.getSamplesCount();
}
}

4
plugins/channeltx/filesource/filesourcebaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_FILESOURCEBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesourcefifo.h"
#include "util/message.h"
@ -147,7 +147,7 @@ private:
double m_avg;
double m_peak;
int m_nbSamples;
QMutex m_mutex;
QRecursiveMutex m_mutex;
void processFifo(SampleVector& data, unsigned int iBegin, unsigned int iEnd);
bool handleMessage(const Message& cmd);

3
plugins/channeltx/localsource/localsourcebaseband.cpp
View File

@ -28,8 +28,7 @@ MESSAGE_CLASS_DEFINITION(LocalSourceBaseband::MsgConfigureLocalSourceWork, Messa
MESSAGE_CLASS_DEFINITION(LocalSourceBaseband::MsgConfigureLocalDeviceSampleSink, Message)
LocalSourceBaseband::LocalSourceBaseband() :
m_localSampleSink(nullptr),
m_mutex(QMutex::Recursive)
m_localSampleSink(nullptr)
{
m_sampleFifo.resize(SampleSourceFifo::getSizePolicy(48000));
m_channelizer = new UpChannelizer(&m_source);

4
plugins/channeltx/localsource/localsourcebaseband.h
View File

@ -19,7 +19,7 @@
#define INCLUDE_LOCALSOURCEBASEBAND_H
#include <QObject>
#include <QMutex>
#include <QRecursiveMutex>
#include "dsp/samplesourcefifo.h"
#include "util/message.h"
@ -113,7 +113,7 @@ private:
MessageQueue m_inputMessageQueue; //!< Queue for asynchronous inbound communication
LocalSourceSettings m_settings;
DeviceSampleSink *m_localSampleSink;
QMutex m_mutex;
QRecursiveMutex m_mutex;
void processFifo(SampleVector& data, unsigned int iBegin, unsigned int iEnd);
bool handleMessage(const Message& cmd);

3
plugins/channeltx/mod802.15.4/ieee_802_15_4_mod.cpp
View File

@ -57,8 +57,7 @@ const char* const IEEE_802_15_4_Mod::m_channelId = "IEEE_802_15_4_Mod";
IEEE_802_15_4_Mod::IEEE_802_15_4_Mod(DeviceAPI *deviceAPI) :
ChannelAPI(m_channelIdURI, ChannelAPI::StreamSingleSource),
m_deviceAPI(deviceAPI),
m_spectrumVis(SDR_TX_SCALEF),
m_settingsMutex(QMutex::Recursive)
m_spectrumVis(SDR_TX_SCALEF)
{
setObjectName(m_channelId);

Some files were not shown because too many files have changed in this diff Show More