VE7UWU/sdrangel
1
0
Fork 0
mirror of https://github.com/f4exb/sdrangel.git synced 2025-02-03 09:44:01 -05:00
Code Issues Projects Releases Wiki Activity

Perseus support (5)

Browse Source
This commit is contained in:
f4exb 2018-02-07 19:56:39 +01:00
parent 65174d7044
commit 1f0f5d2520
2 changed files with 119 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

58
plugins/samplesource/perseus/perseusthread.cpp Normal file
View File

@ -0,0 +1,58 @@
///////////////////////////////////////////////////////////////////////////////////
// Copyright (C) 2018 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 //
// //
// 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 <http://www.gnu.org/licenses/>. //
///////////////////////////////////////////////////////////////////////////////////
#include <QtGlobal>
#include "perseusthread.h"
void PerseusThread::run()
{
m_running = true;
m_startWaiter.wakeAll();
int rc = perseus_start_async_input(m_dev, 6*1024, rx_callback, 0);
if (rc < 0) {
qCritical("PerseusThread::run: failed to start Perseus Rx: %s", perseus_errorstr());
}
else
{
while (m_running) {
sleep(1);
}
}
rc = perseus_stop_async_input(m_dev);
if (rc < 0) {
qCritical("PerseusThread::run: failed to stop Perseus Rx: %s", perseus_errorstr());
} else {
qDebug("PerseusThread::run: stopped Perseus Rx");
}
m_running = false;
}
void PerseusThread::callback(const uint8_t* buf, qint32 len)
{
}
int PerseusThread::rx_callback(void *buf, int buf_size, void *extra)
{
qint32 nbIAndQ = buf_size / 3; // 3 bytes per I or Q
m_this->callback((uint8_t*) buf, nbIAndQ);
}

61
plugins/samplesource/perseus/perseusthread.h Normal file
View File

@ -0,0 +1,61 @@
///////////////////////////////////////////////////////////////////////////////////
// Copyright (C) 2018 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 //
// //
// 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 <http://www.gnu.org/licenses/>. //
///////////////////////////////////////////////////////////////////////////////////
#ifndef PLUGINS_SAMPLESOURCE_PERSEUS_PERSEUSTHREAD_H_
#define PLUGINS_SAMPLESOURCE_PERSEUS_PERSEUSTHREAD_H_
#include <QThread>
#include <QMutex>
#include <QWaitCondition>
#include "perseus-sdr.h"
//#define PERSEUS_NBSAMPLES = 1024 // Number of I/Q samples in each callback from Perseus
//#define PERSEUS_BLOCKSIZE = 6*PERSEUS_NBSAMPLES // Perseus sends 2*3 bytes samples
class PerseusThread : public QThread {
Q_OBJECT
public:
PerseusThread(perseus_descr* dev, SampleSinkFifo* sampleFifo, QObject* parent = 0);
~PerseusThread();
void startWork();
void stopWork();
void setSamplerate(uint32_t samplerate);
void setLog2Decimation(unsigned int log2_decim);
private:
QMutex m_startWaitMutex;
QWaitCondition m_startWaiter;
bool m_running;
perseus_descr* m_dev;
qint32 m_buf[2*1024];
SampleVector m_convertBuffer;
SampleSinkFifo* m_sampleFifo;
int m_samplerate;
unsigned int m_log2Decim;
static PerseusThread *m_this;
Decimators m_decimators;
void run();
void callback(const uint8_t* buf, qint32 len); // inner call back
static int rx_callback(void *buf, int buf_size, void *extra); // call back from Perseus
};
#endif /* PLUGINS_SAMPLESOURCE_PERSEUS_PERSEUSTHREAD_H_ */