Airspy: use transfer->ctx to pass this object address

pull/620/head
f4exb 2020-08-16 10:20:55 +02:00
rodzic e037aa61a2
commit 17afe4fa65
2 zmienionych plików z 5 dodań i 9 usunięć

Wyświetl plik

@ -23,8 +23,6 @@
#include "dsp/samplesinkfifo.h"
AirspyWorker *AirspyWorker::m_this = 0;
AirspyWorker::AirspyWorker(struct airspy_device* dev, SampleSinkFifo* sampleFifo, QObject* parent) :
QObject(parent),
m_running(false),
@ -36,21 +34,19 @@ AirspyWorker::AirspyWorker(struct airspy_device* dev, SampleSinkFifo* sampleFifo
m_fcPos(0),
m_iqOrder(true)
{
m_this = this;
std::fill(m_buf, m_buf + 2*AIRSPY_BLOCKSIZE, 0);
}
AirspyWorker::~AirspyWorker()
{
stopWork();
m_this = 0;
}
bool AirspyWorker::startWork()
{
airspy_error rc;
rc = (airspy_error) airspy_start_rx(m_dev, rx_callback, NULL);
rc = (airspy_error) airspy_start_rx(m_dev, rx_callback, this);
if (rc == AIRSPY_SUCCESS)
{
@ -282,12 +278,13 @@ void AirspyWorker::callbackQI(const qint16* buf, qint32 len)
int AirspyWorker::rx_callback(airspy_transfer_t* transfer)
{
AirspyWorker *worker = (AirspyWorker*) transfer->ctx;
qint32 bytes_to_write = transfer->sample_count * sizeof(qint16);
if (m_this->m_iqOrder) {
m_this->callbackIQ((qint16 *) transfer->samples, bytes_to_write);
if (worker->m_iqOrder) {
worker->callbackIQ((qint16 *) transfer->samples, bytes_to_write);
} else {
m_this->callbackQI((qint16 *) transfer->samples, bytes_to_write);
worker->callbackQI((qint16 *) transfer->samples, bytes_to_write);
}
return 0;

Wyświetl plik

@ -52,7 +52,6 @@ private:
unsigned int m_log2Decim;
int m_fcPos;
bool m_iqOrder;
static AirspyWorker *m_this;
Decimators<qint32, qint16, SDR_RX_SAMP_SZ, 12, true> m_decimatorsIQ;
Decimators<qint32, qint16, SDR_RX_SAMP_SZ, 12, false> m_decimatorsQI;