2015-09-09 07:13:24 +00:00
///////////////////////////////////////////////////////////////////////////////////
// Copyright (C) 2015 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 <string.h>
# include <errno.h>
# include <QDebug>
2018-05-25 23:43:28 +00:00
# include <QList>
2015-09-09 07:13:24 +00:00
2017-12-14 17:15:27 +00:00
# include "SWGDeviceSettings.h"
# include "SWGDeviceState.h"
2018-05-25 23:43:28 +00:00
# include "SWGDeviceReport.h"
# include "SWGAirspyReport.h"
2017-12-14 17:15:27 +00:00
2015-09-09 07:13:24 +00:00
# include "airspygui.h"
# include "airspyinput.h"
2018-01-10 23:17:06 +00:00
# include "airspyplugin.h"
2016-10-10 23:17:55 +00:00
# include <device/devicesourceapi.h>
2017-09-04 20:24:32 +00:00
# include <dsp/filerecord.h>
2015-09-09 07:13:24 +00:00
# include "dsp/dspcommands.h"
2015-09-27 10:50:38 +00:00
# include "dsp/dspengine.h"
2015-09-30 11:53:09 +00:00
# include "airspysettings.h"
2015-09-09 07:13:24 +00:00
# include "airspythread.h"
MESSAGE_CLASS_DEFINITION ( AirspyInput : : MsgConfigureAirspy , Message )
2017-12-14 17:02:49 +00:00
MESSAGE_CLASS_DEFINITION ( AirspyInput : : MsgStartStop , Message )
2017-09-04 20:24:32 +00:00
MESSAGE_CLASS_DEFINITION ( AirspyInput : : MsgFileRecord , Message )
2017-09-25 21:07:29 +00:00
const qint64 AirspyInput : : loLowLimitFreq = 24000000L ;
const qint64 AirspyInput : : loHighLimitFreq = 1900000000L ;
2015-09-09 07:13:24 +00:00
2016-10-10 23:17:55 +00:00
AirspyInput : : AirspyInput ( DeviceSourceAPI * deviceAPI ) :
2016-05-16 00:14:36 +00:00
m_deviceAPI ( deviceAPI ) ,
2015-09-09 07:13:24 +00:00
m_settings ( ) ,
m_dev ( 0 ) ,
m_airspyThread ( 0 ) ,
2017-04-13 06:29:51 +00:00
m_deviceDescription ( " Airspy " ) ,
m_running ( false )
2015-09-09 07:13:24 +00:00
{
2017-04-13 06:29:51 +00:00
openDevice ( ) ;
2018-05-08 09:03:09 +00:00
m_fileSink = new FileRecord ( QString ( " test_%1.sdriq " ) . arg ( m_deviceAPI - > getDeviceUID ( ) ) ) ;
2017-09-04 20:24:32 +00:00
m_deviceAPI - > addSink ( m_fileSink ) ;
2015-09-09 07:13:24 +00:00
}
AirspyInput : : ~ AirspyInput ( )
{
2017-04-13 06:29:51 +00:00
if ( m_running ) stop ( ) ;
2017-09-04 20:24:32 +00:00
m_deviceAPI - > removeSink ( m_fileSink ) ;
delete m_fileSink ;
2017-04-13 06:29:51 +00:00
closeDevice ( ) ;
2015-09-09 07:13:24 +00:00
}
2017-09-15 00:32:30 +00:00
void AirspyInput : : destroy ( )
{
delete this ;
}
2017-04-13 06:29:51 +00:00
bool AirspyInput : : openDevice ( )
2015-09-09 07:13:24 +00:00
{
2017-04-13 06:29:51 +00:00
if ( m_dev ! = 0 )
{
closeDevice ( ) ;
}
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
airspy_error rc ;
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
rc = ( airspy_error ) airspy_init ( ) ;
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
if ( rc ! = AIRSPY_SUCCESS )
{
qCritical ( " AirspyInput::start: failed to initiate Airspy library %s " , airspy_error_name ( rc ) ) ;
}
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
if ( ! m_sampleFifo . setSize ( 1 < < 19 ) )
{
qCritical ( " AirspyInput::start: could not allocate SampleFifo " ) ;
return false ;
}
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
int device = m_deviceAPI - > getSampleSourceSequence ( ) ;
if ( ( m_dev = open_airspy_from_sequence ( device ) ) = = 0 )
{
qCritical ( " AirspyInput::start: could not open Airspy #%d " , device ) ;
return false ;
}
2015-09-09 07:13:24 +00:00
2015-09-11 01:02:02 +00:00
# ifdef LIBAIRSPY_DYN_RATES
2017-04-13 06:29:51 +00:00
uint32_t nbSampleRates ;
uint32_t * sampleRates ;
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
airspy_get_samplerates ( m_dev , & nbSampleRates , 0 ) ;
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
sampleRates = new uint32_t [ nbSampleRates ] ;
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
airspy_get_samplerates ( m_dev , sampleRates , nbSampleRates ) ;
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
if ( nbSampleRates = = 0 )
{
qCritical ( " AirspyInput::start: could not obtain Airspy sample rates " ) ;
return false ;
}
else
{
qDebug ( " AirspyInput::start: %d sample rates " , nbSampleRates ) ;
}
2015-09-10 03:53:37 +00:00
2017-04-13 06:29:51 +00:00
m_sampleRates . clear ( ) ;
2015-09-11 01:02:02 +00:00
2017-05-25 18:13:34 +00:00
for ( unsigned int i = 0 ; i < nbSampleRates ; i + + )
2017-04-13 06:29:51 +00:00
{
m_sampleRates . push_back ( sampleRates [ i ] ) ;
qDebug ( " AirspyInput::start: sampleRates[%d] = %u Hz " , i , sampleRates [ i ] ) ;
}
2015-09-09 07:13:24 +00:00
2017-04-13 06:29:51 +00:00
delete [ ] sampleRates ;
2015-09-24 00:50:24 +00:00
# else
2017-04-13 06:29:51 +00:00
qDebug ( " AirspyInput::start: detault rates " ) ;
m_sampleRates . clear ( ) ;
m_sampleRates . push_back ( 10000000 ) ;
m_sampleRates . push_back ( 2500000 ) ;
2015-09-09 07:13:24 +00:00
# endif
2017-04-13 06:29:51 +00:00
// MsgReportAirspy *message = MsgReportAirspy::create(m_sampleRates);
// getOutputMessageQueueToGUI()->push(message);
2015-09-11 01:02:02 +00:00
2017-04-13 06:29:51 +00:00
rc = ( airspy_error ) airspy_set_sample_type ( m_dev , AIRSPY_SAMPLE_INT16_IQ ) ;
2015-09-10 03:53:37 +00:00
2017-04-13 06:29:51 +00:00
if ( rc ! = AIRSPY_SUCCESS )
{
qCritical ( " AirspyInput::start: could not set sample type to INT16_IQ " ) ;
return false ;
}
return true ;
}
2017-12-25 08:10:19 +00:00
void AirspyInput : : init ( )
{
applySettings ( m_settings , true ) ;
}
2017-04-14 01:40:45 +00:00
bool AirspyInput : : start ( )
2017-04-13 06:29:51 +00:00
{
QMutexLocker mutexLocker ( & m_mutex ) ;
if ( ! m_dev ) {
return false ;
}
2018-02-24 09:29:27 +00:00
if ( m_running ) { stop ( ) ; }
2015-09-09 07:13:24 +00:00
2018-02-24 09:29:27 +00:00
m_airspyThread = new AirspyThread ( m_dev , & m_sampleFifo ) ;
2017-04-13 18:29:05 +00:00
m_airspyThread - > setSamplerate ( m_sampleRates [ m_settings . m_devSampleRateIndex ] ) ;
m_airspyThread - > setLog2Decimation ( m_settings . m_log2Decim ) ;
m_airspyThread - > setFcPos ( ( int ) m_settings . m_fcPos ) ;
2015-09-09 07:13:24 +00:00
m_airspyThread - > startWork ( ) ;
mutexLocker . unlock ( ) ;
2015-09-11 01:02:02 +00:00
applySettings ( m_settings , true ) ;
2015-09-09 07:13:24 +00:00
qDebug ( " AirspyInput::startInput: started " ) ;
2017-04-13 06:29:51 +00:00
m_running = true ;
2015-09-09 07:13:24 +00:00
return true ;
}
2017-04-13 06:29:51 +00:00
void AirspyInput : : closeDevice ( )
{
if ( m_dev ! = 0 )
{
airspy_stop_rx ( m_dev ) ;
airspy_close ( m_dev ) ;
m_dev = 0 ;
}
m_deviceDescription . clear ( ) ;
airspy_exit ( ) ;
}
2015-09-09 07:13:24 +00:00
void AirspyInput : : stop ( )
{
2015-09-11 01:02:02 +00:00
qDebug ( " AirspyInput::stop " ) ;
2015-09-09 07:13:24 +00:00
QMutexLocker mutexLocker ( & m_mutex ) ;
2017-04-13 06:29:51 +00:00
if ( m_airspyThread ! = 0 )
2015-09-09 07:13:24 +00:00
{
m_airspyThread - > stopWork ( ) ;
delete m_airspyThread ;
m_airspyThread = 0 ;
}
2017-04-13 06:29:51 +00:00
m_running = false ;
2015-09-09 07:13:24 +00:00
}
2017-12-28 02:21:48 +00:00
QByteArray AirspyInput : : serialize ( ) const
{
return m_settings . serialize ( ) ;
}
bool AirspyInput : : deserialize ( const QByteArray & data )
{
bool success = true ;
if ( ! m_settings . deserialize ( data ) )
{
m_settings . resetToDefaults ( ) ;
success = false ;
}
MsgConfigureAirspy * message = MsgConfigureAirspy : : create ( m_settings , true ) ;
m_inputMessageQueue . push ( message ) ;
if ( m_guiMessageQueue )
{
MsgConfigureAirspy * messageToGUI = MsgConfigureAirspy : : create ( m_settings , true ) ;
m_guiMessageQueue - > push ( messageToGUI ) ;
}
return success ;
}
2015-09-09 07:13:24 +00:00
const QString & AirspyInput : : getDeviceDescription ( ) const
{
return m_deviceDescription ;
}
int AirspyInput : : getSampleRate ( ) const
{
2015-09-10 03:53:37 +00:00
int rate = m_sampleRates [ m_settings . m_devSampleRateIndex ] ;
2015-09-09 07:13:24 +00:00
return ( rate / ( 1 < < m_settings . m_log2Decim ) ) ;
}
quint64 AirspyInput : : getCenterFrequency ( ) const
{
return m_settings . m_centerFrequency ;
}
2017-12-28 02:21:48 +00:00
void AirspyInput : : setCenterFrequency ( qint64 centerFrequency )
{
AirspySettings settings = m_settings ;
settings . m_centerFrequency = centerFrequency ;
MsgConfigureAirspy * message = MsgConfigureAirspy : : create ( settings , false ) ;
m_inputMessageQueue . push ( message ) ;
if ( m_guiMessageQueue )
{
MsgConfigureAirspy * messageToGUI = MsgConfigureAirspy : : create ( settings , false ) ;
m_guiMessageQueue - > push ( messageToGUI ) ;
}
}
2015-09-09 07:13:24 +00:00
bool AirspyInput : : handleMessage ( const Message & message )
{
if ( MsgConfigureAirspy : : match ( message ) )
{
MsgConfigureAirspy & conf = ( MsgConfigureAirspy & ) message ;
qDebug ( ) < < " AirspyInput::handleMessage: MsgConfigureAirspy " ;
2017-10-14 04:30:48 +00:00
bool success = applySettings ( conf . getSettings ( ) , conf . getForce ( ) ) ;
2015-09-11 01:02:02 +00:00
if ( ! success )
2015-09-09 07:13:24 +00:00
{
2018-01-10 23:17:06 +00:00
qDebug ( " AirspyInput::handleMessage: Airspy config error " ) ;
2015-09-09 07:13:24 +00:00
}
return true ;
}
2017-12-14 17:02:49 +00:00
else if ( MsgStartStop : : match ( message ) )
{
MsgStartStop & cmd = ( MsgStartStop & ) message ;
qDebug ( ) < < " AirspyInput::handleMessage: MsgStartStop: " < < ( cmd . getStartStop ( ) ? " start " : " stop " ) ;
if ( cmd . getStartStop ( ) )
{
if ( m_deviceAPI - > initAcquisition ( ) )
{
m_deviceAPI - > startAcquisition ( ) ;
}
}
else
{
m_deviceAPI - > stopAcquisition ( ) ;
}
return true ;
}
2017-09-04 20:24:32 +00:00
else if ( MsgFileRecord : : match ( message ) )
{
MsgFileRecord & conf = ( MsgFileRecord & ) message ;
2017-09-04 20:45:07 +00:00
qDebug ( ) < < " AirspyInput::handleMessage: MsgFileRecord: " < < conf . getStartStop ( ) ;
2017-09-04 20:24:32 +00:00
2018-05-09 15:39:48 +00:00
if ( conf . getStartStop ( ) )
{
if ( m_settings . m_fileRecordName . size ( ) ! = 0 ) {
m_fileSink - > setFileName ( m_settings . m_fileRecordName ) ;
} else {
2018-05-11 07:08:20 +00:00
m_fileSink - > genUniqueFileName ( m_deviceAPI - > getDeviceUID ( ) ) ;
2018-05-09 15:39:48 +00:00
}
2017-09-04 20:24:32 +00:00
m_fileSink - > startRecording ( ) ;
2018-05-09 15:39:48 +00:00
}
else
{
2017-09-04 20:24:32 +00:00
m_fileSink - > stopRecording ( ) ;
}
return true ;
}
2015-09-09 07:13:24 +00:00
else
{
return false ;
}
}
2017-12-28 02:21:48 +00:00
void AirspyInput : : setDeviceCenterFrequency ( quint64 freq_hz )
2015-09-10 03:53:37 +00:00
{
2015-09-27 16:32:19 +00:00
qint64 df = ( ( qint64 ) freq_hz * m_settings . m_LOppmTenths ) / 10000000LL ;
freq_hz + = df ;
2015-09-10 03:53:37 +00:00
airspy_error rc = ( airspy_error ) airspy_set_freq ( m_dev , static_cast < uint32_t > ( freq_hz ) ) ;
if ( rc ! = AIRSPY_SUCCESS )
{
2017-12-28 02:21:48 +00:00
qWarning ( " AirspyInput::setDeviceCenterFrequency: could not frequency to %llu Hz " , freq_hz ) ;
2015-09-10 03:53:37 +00:00
}
else
{
2018-01-10 23:17:06 +00:00
qDebug ( " AirspyInput::setDeviceCenterFrequency: frequency set to %llu Hz " , freq_hz ) ;
2015-09-10 03:53:37 +00:00
}
}
2015-09-30 11:23:20 +00:00
bool AirspyInput : : applySettings ( const AirspySettings & settings , bool force )
2015-09-09 07:13:24 +00:00
{
2015-09-11 01:02:02 +00:00
QMutexLocker mutexLocker ( & m_mutex ) ;
2015-09-09 07:13:24 +00:00
bool forwardChange = false ;
2017-05-25 18:13:34 +00:00
airspy_error rc = AIRSPY_ERROR_OTHER ;
2015-09-09 07:13:24 +00:00
2015-09-11 01:02:02 +00:00
qDebug ( ) < < " AirspyInput::applySettings " ;
2015-09-09 07:13:24 +00:00
2018-01-10 23:17:06 +00:00
if ( ( m_settings . m_dcBlock ! = settings . m_dcBlock ) | |
( m_settings . m_iqCorrection ! = settings . m_iqCorrection ) | | force )
{
2015-09-30 11:23:20 +00:00
m_settings . m_dcBlock = settings . m_dcBlock ;
m_settings . m_iqCorrection = settings . m_iqCorrection ;
2016-05-16 00:14:36 +00:00
m_deviceAPI - > configureCorrections ( m_settings . m_dcBlock , m_settings . m_iqCorrection ) ;
2015-09-30 11:23:20 +00:00
}
2015-09-10 03:53:37 +00:00
if ( ( m_settings . m_devSampleRateIndex ! = settings . m_devSampleRateIndex ) | | force )
{
2015-09-11 01:02:02 +00:00
forwardChange = true ;
2015-09-10 03:53:37 +00:00
if ( settings . m_devSampleRateIndex < m_sampleRates . size ( ) )
{
m_settings . m_devSampleRateIndex = settings . m_devSampleRateIndex ;
}
else
{
2015-09-11 01:02:02 +00:00
m_settings . m_devSampleRateIndex = m_sampleRates . size ( ) - 1 ;
2015-09-10 03:53:37 +00:00
}
if ( m_dev ! = 0 )
{
2015-09-11 01:02:02 +00:00
rc = ( airspy_error ) airspy_set_samplerate ( m_dev , static_cast < airspy_samplerate_t > ( m_settings . m_devSampleRateIndex ) ) ;
2015-09-10 03:53:37 +00:00
if ( rc ! = AIRSPY_SUCCESS )
{
qCritical ( " AirspyInput::applySettings: could not set sample rate index %u (%d S/s): %s " , m_settings . m_devSampleRateIndex , m_sampleRates [ m_settings . m_devSampleRateIndex ] , airspy_error_name ( rc ) ) ;
}
2017-04-13 18:29:05 +00:00
else if ( m_airspyThread ! = 0 )
2015-09-10 03:53:37 +00:00
{
qDebug ( " AirspyInput::applySettings: sample rate set to index: %u (%d S/s) " , m_settings . m_devSampleRateIndex , m_sampleRates [ m_settings . m_devSampleRateIndex ] ) ;
m_airspyThread - > setSamplerate ( m_sampleRates [ m_settings . m_devSampleRateIndex ] ) ;
}
}
}
if ( ( m_settings . m_log2Decim ! = settings . m_log2Decim ) | | force )
{
forwardChange = true ;
2017-04-13 18:29:05 +00:00
if ( m_airspyThread ! = 0 )
2015-09-10 03:53:37 +00:00
{
2018-01-20 02:28:30 +00:00
m_airspyThread - > setLog2Decimation ( settings . m_log2Decim ) ;
qDebug ( ) < < " AirspyInput: set decimation to " < < ( 1 < < settings . m_log2Decim ) ;
2015-09-10 03:53:37 +00:00
}
}
2018-01-20 02:28:30 +00:00
if ( ( m_settings . m_centerFrequency ! = settings . m_centerFrequency )
| | ( m_settings . m_LOppmTenths ! = settings . m_LOppmTenths )
| | ( m_settings . m_fcPos ! = settings . m_fcPos )
| | ( m_settings . m_log2Decim ! = settings . m_log2Decim )
| | ( m_settings . m_transverterMode ! = settings . m_transverterMode )
| | ( m_settings . m_transverterDeltaFrequency ! = settings . m_transverterDeltaFrequency ) | | force )
2015-09-10 03:53:37 +00:00
{
2018-05-10 12:51:05 +00:00
qint64 deviceCenterFrequency = DeviceSampleSource : : calculateDeviceCenterFrequency (
settings . m_centerFrequency ,
settings . m_transverterDeltaFrequency ,
settings . m_log2Decim ,
( DeviceSampleSource : : fcPos_t ) settings . m_fcPos ,
m_sampleRates [ m_settings . m_devSampleRateIndex ] ,
settings . m_transverterMode ) ;
2017-09-25 21:07:29 +00:00
m_settings . m_centerFrequency = settings . m_centerFrequency ;
2018-01-20 02:28:30 +00:00
m_settings . m_log2Decim = settings . m_log2Decim ;
2017-09-25 21:07:29 +00:00
m_settings . m_transverterMode = settings . m_transverterMode ;
m_settings . m_transverterDeltaFrequency = settings . m_transverterDeltaFrequency ;
2017-09-25 21:16:29 +00:00
m_settings . m_LOppmTenths = settings . m_LOppmTenths ;
2017-09-25 21:07:29 +00:00
2018-05-10 12:51:05 +00:00
if ( m_dev ! = 0 ) {
2017-12-28 02:21:48 +00:00
setDeviceCenterFrequency ( deviceCenterFrequency ) ;
2015-09-10 03:53:37 +00:00
}
forwardChange = true ;
}
2015-10-01 04:34:08 +00:00
if ( ( m_settings . m_fcPos ! = settings . m_fcPos ) | | force )
{
m_settings . m_fcPos = settings . m_fcPos ;
2017-04-13 18:29:05 +00:00
if ( m_airspyThread ! = 0 )
2015-10-01 04:34:08 +00:00
{
m_airspyThread - > setFcPos ( ( int ) m_settings . m_fcPos ) ;
qDebug ( ) < < " AirspyInput: set fc pos (enum) to " < < ( int ) m_settings . m_fcPos ;
}
}
2015-09-09 07:13:24 +00:00
if ( ( m_settings . m_lnaGain ! = settings . m_lnaGain ) | | force )
{
m_settings . m_lnaGain = settings . m_lnaGain ;
if ( m_dev ! = 0 )
{
2015-09-10 03:53:37 +00:00
rc = ( airspy_error ) airspy_set_lna_gain ( m_dev , m_settings . m_lnaGain ) ;
2015-09-09 07:13:24 +00:00
if ( rc ! = AIRSPY_SUCCESS )
{
qDebug ( " AirspyInput::applySettings: airspy_set_lna_gain failed: %s " , airspy_error_name ( rc ) ) ;
}
else
{
qDebug ( ) < < " AirspyInput:applySettings: LNA gain set to " < < m_settings . m_lnaGain ;
}
}
}
2015-12-09 00:49:46 +00:00
if ( ( m_settings . m_lnaAGC ! = settings . m_lnaAGC ) | | force )
{
m_settings . m_lnaAGC = settings . m_lnaAGC ;
if ( m_dev ! = 0 )
{
rc = ( airspy_error ) airspy_set_lna_agc ( m_dev , ( m_settings . m_lnaAGC ? 1 : 0 ) ) ;
}
if ( rc ! = AIRSPY_SUCCESS )
{
qDebug ( " AirspyInput::applySettings: airspy_set_lna_agc failed: %s " , airspy_error_name ( rc ) ) ;
}
else
{
qDebug ( ) < < " AirspyInput:applySettings: LNA AGC set to " < < m_settings . m_lnaAGC ;
}
}
2015-09-09 07:13:24 +00:00
if ( ( m_settings . m_mixerGain ! = settings . m_mixerGain ) | | force )
{
m_settings . m_mixerGain = settings . m_mixerGain ;
if ( m_dev ! = 0 )
{
2015-09-10 03:53:37 +00:00
rc = ( airspy_error ) airspy_set_mixer_gain ( m_dev , m_settings . m_mixerGain ) ;
2015-09-09 07:13:24 +00:00
if ( rc ! = AIRSPY_SUCCESS )
{
qDebug ( " AirspyInput::applySettings: airspy_set_mixer_gain failed: %s " , airspy_error_name ( rc ) ) ;
}
else
{
qDebug ( ) < < " AirspyInput:applySettings: mixer gain set to " < < m_settings . m_mixerGain ;
}
}
}
2015-12-09 00:49:46 +00:00
if ( ( m_settings . m_mixerAGC ! = settings . m_mixerAGC ) | | force )
{
m_settings . m_mixerAGC = settings . m_mixerAGC ;
if ( m_dev ! = 0 )
{
rc = ( airspy_error ) airspy_set_mixer_agc ( m_dev , ( m_settings . m_mixerAGC ? 1 : 0 ) ) ;
}
if ( rc ! = AIRSPY_SUCCESS )
{
qDebug ( " AirspyInput::applySettings: airspy_set_mixer_agc failed: %s " , airspy_error_name ( rc ) ) ;
}
else
{
qDebug ( ) < < " AirspyInput:applySettings: Mixer AGC set to " < < m_settings . m_mixerAGC ;
}
}
2015-09-09 07:13:24 +00:00
if ( ( m_settings . m_vgaGain ! = settings . m_vgaGain ) | | force )
{
m_settings . m_vgaGain = settings . m_vgaGain ;
if ( m_dev ! = 0 )
{
2015-09-10 03:53:37 +00:00
rc = ( airspy_error ) airspy_set_vga_gain ( m_dev , m_settings . m_vgaGain ) ;
2015-09-09 07:13:24 +00:00
if ( rc ! = AIRSPY_SUCCESS )
{
qDebug ( " AirspyInput::applySettings: airspy_set_vga_gain failed: %s " , airspy_error_name ( rc ) ) ;
}
else
{
qDebug ( ) < < " AirspyInput:applySettings: VGA gain set to " < < m_settings . m_vgaGain ;
}
}
}
2015-09-10 03:53:37 +00:00
if ( ( m_settings . m_biasT ! = settings . m_biasT ) | | force )
2015-09-09 07:13:24 +00:00
{
2015-09-10 03:53:37 +00:00
m_settings . m_biasT = settings . m_biasT ;
2015-09-09 07:13:24 +00:00
if ( m_dev ! = 0 )
{
2015-09-10 03:53:37 +00:00
rc = ( airspy_error ) airspy_set_rf_bias ( m_dev , ( m_settings . m_biasT ? 1 : 0 ) ) ;
2015-09-09 07:13:24 +00:00
2015-09-10 03:53:37 +00:00
if ( rc ! = AIRSPY_SUCCESS )
2015-09-09 07:13:24 +00:00
{
2015-09-10 03:53:37 +00:00
qDebug ( " AirspyInput::applySettings: airspy_set_rf_bias failed: %s " , airspy_error_name ( rc ) ) ;
2015-09-09 07:13:24 +00:00
}
else
{
2015-09-10 03:53:37 +00:00
qDebug ( ) < < " AirspyInput:applySettings: bias tee set to " < < m_settings . m_biasT ;
2015-09-09 07:13:24 +00:00
}
}
}
if ( forwardChange )
{
2017-09-25 21:07:29 +00:00
int sampleRate = m_sampleRates [ m_settings . m_devSampleRateIndex ] / ( 1 < < m_settings . m_log2Decim ) ;
2015-09-09 07:13:24 +00:00
DSPSignalNotification * notif = new DSPSignalNotification ( sampleRate , m_settings . m_centerFrequency ) ;
2017-09-04 20:24:32 +00:00
m_fileSink - > handleMessage ( * notif ) ; // forward to file sink
2017-09-13 21:40:06 +00:00
m_deviceAPI - > getDeviceEngineInputMessageQueue ( ) - > push ( notif ) ;
2015-09-09 07:13:24 +00:00
}
return true ;
}
struct airspy_device * AirspyInput : : open_airspy_from_sequence ( int sequence )
{
2017-05-25 18:13:34 +00:00
struct airspy_device * devinfo ;
airspy_error rc = AIRSPY_ERROR_OTHER ;
2015-09-09 07:13:24 +00:00
2018-01-10 23:17:06 +00:00
for ( int i = 0 ; i < AirspyPlugin : : m_maxDevices ; i + + )
2015-09-09 07:13:24 +00:00
{
2015-09-11 01:02:02 +00:00
rc = ( airspy_error ) airspy_open ( & devinfo ) ;
2015-09-09 07:13:24 +00:00
2015-09-10 03:53:37 +00:00
if ( rc = = AIRSPY_SUCCESS )
2015-09-09 07:13:24 +00:00
{
2018-01-10 23:17:06 +00:00
if ( i = = sequence ) {
2015-09-10 03:53:37 +00:00
return devinfo ;
2018-01-10 23:17:06 +00:00
} else {
airspy_close ( devinfo ) ;
2015-09-10 03:53:37 +00:00
}
2015-09-09 07:13:24 +00:00
}
else
{
2015-09-11 01:02:02 +00:00
break ;
2015-09-09 07:13:24 +00:00
}
}
return 0 ;
}
2017-12-14 17:15:27 +00:00
int AirspyInput : : webapiRunGet (
SWGSDRangel : : SWGDeviceState & response ,
QString & errorMessage __attribute__ ( ( unused ) ) )
{
m_deviceAPI - > getDeviceEngineStateStr ( * response . getState ( ) ) ;
return 200 ;
}
int AirspyInput : : webapiRun (
bool run ,
SWGSDRangel : : SWGDeviceState & response ,
QString & errorMessage __attribute__ ( ( unused ) ) )
{
2017-12-14 22:29:12 +00:00
m_deviceAPI - > getDeviceEngineStateStr ( * response . getState ( ) ) ;
2017-12-14 17:15:27 +00:00
MsgStartStop * message = MsgStartStop : : create ( run ) ;
m_inputMessageQueue . push ( message ) ;
if ( m_guiMessageQueue ) // forward to GUI if any
{
MsgStartStop * msgToGUI = MsgStartStop : : create ( run ) ;
m_guiMessageQueue - > push ( msgToGUI ) ;
}
return 200 ;
}
2018-05-25 17:28:57 +00:00
int AirspyInput : : webapiSettingsGet (
SWGSDRangel : : SWGDeviceSettings & response ,
QString & errorMessage __attribute__ ( ( unused ) ) )
{
response . setAirspySettings ( new SWGSDRangel : : SWGAirspySettings ( ) ) ;
response . getAirspySettings ( ) - > init ( ) ;
webapiFormatDeviceSettings ( response , m_settings ) ;
return 200 ;
}
int AirspyInput : : webapiSettingsPutPatch (
bool force ,
const QStringList & deviceSettingsKeys ,
SWGSDRangel : : SWGDeviceSettings & response , // query + response
QString & errorMessage __attribute__ ( ( unused ) ) )
{
AirspySettings settings = m_settings ;
if ( deviceSettingsKeys . contains ( " centerFrequency " ) ) {
settings . m_centerFrequency = response . getAirspySettings ( ) - > getCenterFrequency ( ) ;
}
if ( deviceSettingsKeys . contains ( " LOppmTenths " ) ) {
settings . m_LOppmTenths = response . getAirspySettings ( ) - > getLOppmTenths ( ) ;
}
if ( deviceSettingsKeys . contains ( " devSampleRateIndex " ) ) {
settings . m_devSampleRateIndex = response . getAirspySettings ( ) - > getDevSampleRateIndex ( ) ;
}
if ( deviceSettingsKeys . contains ( " lnaGain " ) ) {
settings . m_lnaGain = response . getAirspySettings ( ) - > getLnaGain ( ) ;
}
if ( deviceSettingsKeys . contains ( " mixerGain " ) ) {
settings . m_mixerGain = response . getAirspySettings ( ) - > getMixerGain ( ) ;
}
if ( deviceSettingsKeys . contains ( " vgaGain " ) ) {
settings . m_vgaGain = response . getAirspySettings ( ) - > getVgaGain ( ) ;
}
if ( deviceSettingsKeys . contains ( " vgaGain " ) ) {
settings . m_vgaGain = response . getAirspySettings ( ) - > getVgaGain ( ) ;
}
if ( deviceSettingsKeys . contains ( " lnaAGC " ) ) {
settings . m_lnaAGC = response . getAirspySettings ( ) - > getLnaAgc ( ) ! = 0 ;
}
if ( deviceSettingsKeys . contains ( " mixerAGC " ) ) {
settings . m_mixerAGC = response . getAirspySettings ( ) - > getMixerAgc ( ) ! = 0 ;
}
if ( deviceSettingsKeys . contains ( " log2Decim " ) ) {
settings . m_log2Decim = response . getAirspySettings ( ) - > getLog2Decim ( ) ;
}
if ( deviceSettingsKeys . contains ( " fcPos " ) ) {
2018-05-26 00:01:59 +00:00
int fcPos = response . getAirspySettings ( ) - > getFcPos ( ) ;
fcPos = fcPos < 0 ? 0 : fcPos > 2 ? 2 : fcPos ;
settings . m_fcPos = ( AirspySettings : : fcPos_t ) fcPos ;
2018-05-25 17:28:57 +00:00
}
if ( deviceSettingsKeys . contains ( " biasT " ) ) {
settings . m_biasT = response . getAirspySettings ( ) - > getBiasT ( ) ! = 0 ;
}
if ( deviceSettingsKeys . contains ( " dcBlock " ) ) {
settings . m_dcBlock = response . getAirspySettings ( ) - > getDcBlock ( ) ! = 0 ;
}
if ( deviceSettingsKeys . contains ( " iqCorrection " ) ) {
settings . m_iqCorrection = response . getAirspySettings ( ) - > getIqCorrection ( ) ! = 0 ;
}
if ( deviceSettingsKeys . contains ( " transverterDeltaFrequency " ) ) {
settings . m_transverterDeltaFrequency = response . getAirspySettings ( ) - > getTransverterDeltaFrequency ( ) ;
}
if ( deviceSettingsKeys . contains ( " transverterMode " ) ) {
settings . m_transverterMode = response . getAirspySettings ( ) - > getTransverterMode ( ) ! = 0 ;
}
if ( deviceSettingsKeys . contains ( " fileRecordName " ) ) {
settings . m_fileRecordName = * response . getAirspySettings ( ) - > getFileRecordName ( ) ;
}
MsgConfigureAirspy * msg = MsgConfigureAirspy : : create ( settings , force ) ;
m_inputMessageQueue . push ( msg ) ;
if ( m_guiMessageQueue ) // forward to GUI if any
{
MsgConfigureAirspy * msgToGUI = MsgConfigureAirspy : : create ( settings , force ) ;
m_guiMessageQueue - > push ( msgToGUI ) ;
}
webapiFormatDeviceSettings ( response , settings ) ;
return 200 ;
}
2018-05-25 23:43:28 +00:00
int AirspyInput : : webapiReportGet (
SWGSDRangel : : SWGDeviceReport & response ,
QString & errorMessage __attribute__ ( ( unused ) ) )
{
response . setAirspyReport ( new SWGSDRangel : : SWGAirspyReport ( ) ) ;
response . getAirspyReport ( ) - > init ( ) ;
webapiFormatDeviceReport ( response ) ;
return 200 ;
}
2018-05-25 17:28:57 +00:00
void AirspyInput : : webapiFormatDeviceSettings ( SWGSDRangel : : SWGDeviceSettings & response , const AirspySettings & settings )
{
response . getAirspySettings ( ) - > setCenterFrequency ( settings . m_centerFrequency ) ;
response . getAirspySettings ( ) - > setLOppmTenths ( settings . m_LOppmTenths ) ;
response . getAirspySettings ( ) - > setDevSampleRateIndex ( settings . m_devSampleRateIndex ) ;
response . getAirspySettings ( ) - > setLnaGain ( settings . m_lnaGain ) ;
response . getAirspySettings ( ) - > setMixerGain ( settings . m_mixerGain ) ;
response . getAirspySettings ( ) - > setVgaGain ( settings . m_vgaGain ) ;
response . getAirspySettings ( ) - > setLnaAgc ( settings . m_lnaAGC ? 1 : 0 ) ;
response . getAirspySettings ( ) - > setMixerAgc ( settings . m_mixerAGC ? 1 : 0 ) ;
response . getAirspySettings ( ) - > setLog2Decim ( settings . m_log2Decim ) ;
response . getAirspySettings ( ) - > setFcPos ( ( int ) settings . m_fcPos ) ;
response . getAirspySettings ( ) - > setBiasT ( settings . m_biasT ? 1 : 0 ) ;
response . getAirspySettings ( ) - > setDcBlock ( settings . m_dcBlock ? 1 : 0 ) ;
response . getAirspySettings ( ) - > setIqCorrection ( settings . m_iqCorrection ? 1 : 0 ) ;
response . getAirspySettings ( ) - > setTransverterDeltaFrequency ( settings . m_transverterDeltaFrequency ) ;
response . getAirspySettings ( ) - > setTransverterMode ( settings . m_transverterMode ? 1 : 0 ) ;
if ( response . getAirspySettings ( ) - > getFileRecordName ( ) ) {
* response . getAirspySettings ( ) - > getFileRecordName ( ) = settings . m_fileRecordName ;
} else {
response . getAirspySettings ( ) - > setFileRecordName ( new QString ( settings . m_fileRecordName ) ) ;
}
}
2018-05-25 23:43:28 +00:00
void AirspyInput : : webapiFormatDeviceReport ( SWGSDRangel : : SWGDeviceReport & response )
{
response . getAirspyReport ( ) - > setSampleRates ( new QList < SWGSDRangel : : SWGAirspyReport_sampleRates * > ) ;
for ( std : : vector < uint32_t > : : const_iterator it = getSampleRates ( ) . begin ( ) ; it ! = getSampleRates ( ) . end ( ) ; + + it )
{
response . getAirspyReport ( ) - > getSampleRates ( ) - > append ( new SWGSDRangel : : SWGAirspyReport_sampleRates ) ;
response . getAirspyReport ( ) - > getSampleRates ( ) - > back ( ) - > setSampleRate ( * it ) ;
}
}