mirror/SDR-DAB_Qt-DAB
1
0
Fork 0
mirror of https://github.com/JvanKatwijk/qt-dab.git synced 2025-10-06 00:02:40 +02:00
Code Issues Releases Wiki Activity

handling error handling in lime

Browse Source
This commit is contained in:
Jan
2025-08-26 18:30:29 +02:00
parent 21ffd6b7b8
commit 90f89c5615
4 changed files with 211 additions and 73 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
qt-dab-6.9.pro
View File

@@ -19,12 +19,12 @@ unix {
#QMAKE_CFLAGS += -O3 -ffast-math -g
#QMAKE_CXXFLAGS += -O3 -ffast-math -g
#QMAKE_LFLAGS += -O3 -ffast-math -g
#QMAKE_CXXFLAGS += -ffast-math -flto
#QMAKE_CFLAGS += -ffast-math -flto
#QMAKE_LFLAGS += -ffast-math -flto
QMAKE_CFLAGS += -g -fsanitize=address
QMAKE_CXXFLAGS += -g -fsanitize=address
QMAKE_LFLAGS += -g -fsanitize=address
QMAKE_CXXFLAGS += -ffast-math -flto
QMAKE_CFLAGS += -ffast-math -flto
QMAKE_LFLAGS += -ffast-math -flto
#QMAKE_CFLAGS += -g -fsanitize=address
#QMAKE_CXXFLAGS += -g -fsanitize=address
#QMAKE_LFLAGS += -g -fsanitize=address
}
#QMAKE_CFLAGS += -pg

224
sources/devices/lime-handler/lime-handler.cpp
View File

@@ -78,8 +78,12 @@ lms_info_str_t limedevices [10];
libraryLoaded = true;
// From here we have a library available
int ndevs = LMS_GetDeviceList (limedevices);
if (ndevs == 0) { // no devices found
if (ndevs == 0) // no devices found
throw (device_exception ("No lime device found"));
else
if (ndevs < 0) {
const char *error = LMS_GetLastErrorMessage ();
throw (device_exception (error));
}
for (int i = 0; i < ndevs; i ++)
@@ -87,42 +91,54 @@ lms_info_str_t limedevices [10];
int res = LMS_Open (&theDevice, nullptr, nullptr);
if (res < 0) { // some error
throw (device_exception ("failed to open device"));
const char * error = LMS_GetLastErrorMessage ();
throw (device_exception (error));
}
nameOfDevice -> setText (limedevices [0]);
res = LMS_Init (theDevice);
if (res < 0) { // some error
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (&theDevice);
throw (device_exception ("failed to initialize device"));
throw (device_exception (error));
}
res = LMS_GetNumChannels (theDevice, LMS_CH_RX);
if (res < 0) { // some error
LMS_Close (&theDevice);
if (res == 0) { // no channels
throw (device_exception ("could not set number of channels"));
LMS_Close (&theDevice);
}
if (res < 0) { // some error
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (&theDevice);
throw (device_exception (error));
}
fprintf (stderr, "device %s supports %d channels\n",
limedevices [0], res);
res = LMS_EnableChannel (theDevice, LMS_CH_RX, 0, true);
if (res < 0) { // some error
if (res != 0) { // some error
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception ("could not enable channels"));
throw (device_exception (error));
}
res = LMS_SetSampleRate (theDevice, 2048000.0, 1);
if (res < 0) {
if (res != 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception ("could not set samplerate"));
throw (device_exception (error));
}
float_type host_Hz, rf_Hz;
res = LMS_GetSampleRate (theDevice, LMS_CH_RX, 0,
&host_Hz, &rf_Hz);
if (res != 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception (error));
}
fprintf (stderr, "samplerate = %f %f\n", (float)host_Hz, (float)rf_Hz);
res = LMS_GetAntennaList (theDevice, LMS_CH_RX, 0, antennas);
for (int i = 0; i < res; i ++)
antennaList -> addItem (QString (antennas [i]));
@@ -142,43 +158,63 @@ lms_info_str_t limedevices [10];
// default antenna setting
res = LMS_SetAntenna (theDevice, LMS_CH_RX, 0,
antennaList -> currentIndex());
antennaList -> currentIndex ());
if (res != 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception (error));
}
// default frequency
res = LMS_SetLOFrequency (theDevice, LMS_CH_RX,
0, 220000000.0);
if (res < 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception ("could not set LO frequency"));
throw (device_exception (error));
}
//
lms_range_t range;
res = LMS_GetLPFBWRange (theDevice, LMS_CH_RX, &range);
if (res < 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception ("could not get BW range"));
throw (device_exception (error));
}
double bandWidth = 1536000;
fprintf (stderr, "range %f - %f\n",
(float)range. min, (float)range. max);
float BW = 1536000;
if (BW < range. min)
BW = range. min + 100;
fprintf (stderr, "BW set to %f\n", BW);
res = LMS_SetLPFBW (theDevice, LMS_CH_RX, 0, BW);
if (bandWidth < range. min)
bandWidth = range. min + 100;
res = LMS_SetLPFBW (theDevice, LMS_CH_RX,
0, bandWidth);
if (res < 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception ("could not set bandwidth"));
throw (device_exception (error));
}
//
// we use a value too high to get the maximum gain in dB
LMS_SetGaindB (theDevice, LMS_CH_RX, 0, 100);
uint32_t gaindB;
res = LMS_GetGaindB (theDevice, LMS_CH_RX, 0, &gaindB);
gainSelector -> setMaximum (gaindB);
//
res = LMS_SetGFIRLPF (theDevice, LMS_CH_RX,
0, true, bandWidth);
if (res < 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception (error));
}
res = LMS_GetLPFBW (theDevice, LMS_CH_RX, 0, &bandWidth);
fprintf (stderr, "BW set to %f\n", (float)bandWidth);
int gaindB = 73;
gainSelector -> setMaximum (gaindB);
bandWidth = 2500000;;
// Calibrating
LMS_Calibrate (theDevice, LMS_CH_RX, 0, 2500000.0, 0);
LMS_Calibrate (theDevice, LMS_CH_RX, 0, bandWidth, 0);
if (res < 0) {
const char * error = LMS_GetLastErrorMessage ();
LMS_Close (theDevice);
throw (device_exception (error));
}
k = value_i (limeSettings, LIME_SETTINGS, "gain", 50);
gainSelector -> setValue (k);
@@ -219,14 +255,28 @@ lms_info_str_t limedevices [10];
void limeHandler::setGain (int gaindB) {
float_type gg;
LMS_SetGaindB (theDevice, LMS_CH_RX, 0, gaindB);
LMS_GetNormalizedGain (theDevice, LMS_CH_RX, 0, &gg);
store (limeSettings, LIME_SETTINGS, "gain", gaindB);
actualGain -> display (gg);
int errorCode = LMS_SetGaindB (theDevice, LMS_CH_RX, 0, gaindB);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
}
errorCode = LMS_GetNormalizedGain (theDevice, LMS_CH_RX, 0, &gg);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
}
else {
store (limeSettings, LIME_SETTINGS, "gain", gaindB);
actualGain -> display (gg);
}
}
void limeHandler::setAntenna (int ind) {
(void)LMS_SetAntenna (theDevice, LMS_CH_RX, 0, ind);
int errorCode = LMS_SetAntenna (theDevice, LMS_CH_RX, 0, ind);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
}
}
void limeHandler::set_filter (int c) {
@@ -236,40 +286,57 @@ void limeHandler::set_filter (int c) {
}
bool limeHandler::restartReader (int32_t freq, int samplesSkipped) {
int res;
int errorCode;
fprintf (stderr, "Restart called, Running %d\n",
isRunning () ? 1 : 0);
(void)samplesSkipped;
if (isRunning())
return true;
frequencyLabel -> setText (QString::number (freq / 1000) + " kHz");
lastFrequency = freq;
errorCode = LMS_SetLOFrequency (theDevice, LMS_CH_RX, 0, freq);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
return false;
}
double actualFreq;
errorCode = LMS_GetLOFrequency (theDevice, LMS_CH_RX, 0, &actualFreq);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
return false;
}
frequencyLabel -> setText (QString::number ((int)actualFreq / 1000) + " kHz");
lastFrequency = actualFreq;
if (save_gainSettings) {
update_gainSettings (freq / MHz (1));
update_gainSettings (actualFreq / MHz (1));
setGain (gainSelector -> value ());
}
LMS_SetLOFrequency (theDevice, LMS_CH_RX, 0, freq);
fprintf (stderr, "Freq set to %d\n", freq);
stream. isTx = false;
stream. channel = 0;
stream. fifoSize = FIFO_SIZE;
stream. throughputVsLatency = 0.1; // ???
stream. dataFmt = lms_stream_t::LMS_FMT_I12; // 12 bit ints
res = LMS_SetupStream (theDevice, &stream);
if (res < 0)
return false;
res = LMS_StartStream (&stream);
if (res < 0)
return false;
fprintf (stderr, "starting a stream\n");
errorCode = LMS_SetupStream (theDevice, &stream);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
return false;
}
errorCode = LMS_StartStream (&stream);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
return false;
}
start ();
return true;
}
void limeHandler::stopReader () {
int errorCode;
close_xmlDump ();
if (!isRunning())
return;
@@ -279,8 +346,18 @@ void limeHandler::stopReader () {
running. store (false);
while (isRunning())
usleep (200);
(void)LMS_StopStream (&stream);
(void)LMS_DestroyStream (theDevice, &stream);
errorCode = LMS_StopStream (&stream);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
return;
}
errorCode = LMS_DestroyStream (theDevice, &stream);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
return;
}
}
int limeHandler::getSamples (std::complex<float> *V, int32_t size) {
@@ -328,7 +405,7 @@ void limeHandler::showErrors (int underrun, int overrun) {
}
void limeHandler::run() {
int res;
int samples;
lms_stream_status_t streamStatus;
int underruns = 0;
int overruns = 0;
@@ -336,18 +413,29 @@ int amountRead = 0;
running. store (true);
while (running. load()) {
res = LMS_RecvStream (&stream, localBuffer,
samples = LMS_RecvStream (&stream, localBuffer,
FIFO_SIZE, &meta, 1000);
if (res > 0) {
_I_Buffer. putDataIntoBuffer (localBuffer, res);
amountRead += res;
res = LMS_GetStreamStatus (&stream, &streamStatus);
underruns += streamStatus. underrun;
overruns += streamStatus. overrun;
if (samples < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
continue;
}
if (amountRead > 4 * 2048000) {
_I_Buffer. putDataIntoBuffer (localBuffer, samples);
amountRead += samples;
int errorCode = LMS_GetStreamStatus (&stream, &streamStatus);
if (errorCode < 0) {
const char *error = LMS_GetLastErrorMessage ();
fprintf (stderr, "%s\n", error);
continue;
}
underruns += streamStatus. underrun;
overruns += streamStatus. overrun;
if (amountRead > 2048000) {
amountRead = 0;
showErrors (underruns, overruns);
underrunDisplay -> display (underruns);
overrunDisplay -> display (overruns);
fifoDisplay -> display ((int)streamStatus. fifoFilledCount);
underruns = 0;
overruns = 0;
}
@@ -482,6 +570,12 @@ bool limeHandler::load_limeFunctions() {
fprintf (stderr, "could not find LMS_GetLPFBW\n");
return false;
}
this -> LMS_SetGFIRLPF = (pfn_LMS_SetGFIRLPF)
library_p -> resolve ("LMS_SetGFIRLPF");
if (this -> LMS_SetGFIRLPF == nullptr) {
fprintf (stderr, "could not find LMS_SetGFIRLPF\n");
return false;
}
this -> LMS_Calibrate = (pfn_LMS_Calibrate)
library_p -> resolve ("LMS_Calibrate");
if (this -> LMS_Calibrate == nullptr) {
@@ -524,6 +618,12 @@ bool limeHandler::load_limeFunctions() {
fprintf (stderr, "could not find LMS_GetStreamStatus\n");
return false;
}
this -> LMS_GetLastErrorMessage = (pfn_LMS_GetLastErrorMessage)
library_p -> resolve ("LMS_GetLastErrorMessage");
if (this -> LMS_GetLastErrorMessage == nullptr) {
fprintf (stderr, "could not find LMS_GetLastErrorMessage\n");
return false;
}
return true;
}

6
sources/devices/lime-handler/lime-handler.h
View File

@@ -84,6 +84,9 @@ typedef int (*pfn_LMS_SetLPFBW)(lms_device_t *device, bool dir_tx,
size_t chan, float_type bandwidth);
typedef int (*pfn_LMS_GetLPFBW)(lms_device_t *device, bool dir_tx,
size_t chan, float_type *bandwidth);
typedef int (*pfn_LMS_SetGFIRLPF)(lms_device_t *device, bool dir_tx,
size_t chan, bool enabled,
float_type bandwidth);
typedef int (*pfn_LMS_Calibrate)(lms_device_t *device, bool dir_tx,
size_t chan, double bw, unsigned flags);
typedef int (*pfn_LMS_SetupStream)(lms_device_t *device,
@@ -98,6 +101,7 @@ typedef int (*pfn_LMS_RecvStream)(lms_stream_t *stream, void *samples,
unsigned timeout_ms);
typedef int (*pfn_LMS_GetStreamStatus)(lms_stream_t *stream,
lms_stream_status_t* status);
typedef const char * (*pfn_LMS_GetLastErrorMessage)();
//
/////////////////////////////////////////////////////////////////////////
@@ -166,6 +170,7 @@ public:
pfn_LMS_GetLPFBWRange LMS_GetLPFBWRange;
pfn_LMS_SetLPFBW LMS_SetLPFBW;
pfn_LMS_GetLPFBW LMS_GetLPFBW;
pfn_LMS_SetGFIRLPF LMS_SetGFIRLPF;
pfn_LMS_Calibrate LMS_Calibrate;
pfn_LMS_SetupStream LMS_SetupStream;
@@ -174,6 +179,7 @@ public:
pfn_LMS_StopStream LMS_StopStream;
pfn_LMS_RecvStream LMS_RecvStream;
pfn_LMS_GetStreamStatus LMS_GetStreamStatus;
pfn_LMS_GetLastErrorMessage LMS_GetLastErrorMessage;
signals:
void new_gainValue (int);
private slots:

42
sources/devices/lime-handler/lime-widget.h
View File

@@ -1,3 +1,27 @@
#
/*
* Copyright (C) 2014 .. 2023
* Jan van Katwijk (J.vanKatwijk@gmail.com)
* Lazy Chair Computing
*
* This file is part of Qt-DAB
*
* Qt-DAB 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; either version 2 of the License, or
* (at your option) any later version.
*
* Qt-DAB 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 for more details.
*
* You should have received a copy of the GNU General Public License
* along with Qt-DAB; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/
#pragma once
#include <QLabel>
@@ -21,6 +45,8 @@ public:
QLabel *underrunLabel;
QLCDNumber *overrunDisplay;
QLabel *overrunLabel;
QLCDNumber *fifoDisplay;
QLabel *fifoLabel;
QPushButton *dumpButton;
QCheckBox *filterSelector;
QSpinBox *filterDepth;
@@ -42,6 +68,8 @@ void setupUi (QFrame *qw) {
underrunLabel = new QLabel ("underruns");
overrunDisplay = new QLCDNumber ();
overrunLabel = new QLabel ("overruns");
fifoDisplay = new QLCDNumber ();
fifoLabel = new QLabel ("fifo");
dumpButton = new QPushButton ();
filterSelector = new QCheckBox ("filter");
filterDepth = new QSpinBox ();
@@ -54,6 +82,8 @@ void setupUi (QFrame *qw) {
underrunDisplay -> setSegmentStyle (QLCDNumber::Flat);
overrunDisplay -> setFrameShape (QFrame::NoFrame);
overrunDisplay -> setSegmentStyle (QLCDNumber::Flat);
fifoDisplay -> setFrameShape (QFrame::NoFrame);
fifoDisplay -> setSegmentStyle (QLCDNumber::Flat);
QHBoxLayout *line2 = new QHBoxLayout ();
line2 -> addWidget (gainSelector);
@@ -67,13 +97,15 @@ void setupUi (QFrame *qw) {
line3 -> addWidget (frequencyLabel);
QHBoxLayout *line4 = new QHBoxLayout ();
line4 -> addWidget (underrunDisplay);
line4 -> addWidget (underrunLabel);
line4 -> addWidget (filterSelector);
line4 -> addWidget (underrunDisplay);
line4 -> addWidget (overrunLabel);
line4 -> addWidget (overrunDisplay);
QHBoxLayout *line5 = new QHBoxLayout ();
line5 -> addWidget (overrunDisplay);
line5 -> addWidget (overrunLabel);
line5 -> addWidget (fifoLabel);
line5 -> addWidget (fifoDisplay);
line5 -> addWidget (filterSelector);
line5 -> addWidget (filterDepth);
QHBoxLayout *line1 = new QHBoxLayout ();