2017-01-02 21:07:43 -05:00
|
|
|
// Copyright (c) Charles J. Cliffe
|
|
|
|
// SPDX-License-Identifier: GPL-2.0+
|
|
|
|
|
2015-09-13 22:18:29 -04:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include <atomic>
|
2017-05-24 06:24:36 -04:00
|
|
|
#include <memory>
|
2017-02-09 13:12:12 -05:00
|
|
|
#include "ThreadBlockingQueue.h"
|
2015-09-13 22:18:29 -04:00
|
|
|
#include "DemodulatorMgr.h"
|
|
|
|
#include "SDRDeviceInfo.h"
|
2015-10-03 21:35:11 -04:00
|
|
|
#include "AppConfig.h"
|
2015-09-13 22:18:29 -04:00
|
|
|
|
2015-10-03 21:35:11 -04:00
|
|
|
#include <SoapySDR/Version.hpp>
|
|
|
|
#include <SoapySDR/Modules.hpp>
|
|
|
|
#include <SoapySDR/Registry.hpp>
|
|
|
|
#include <SoapySDR/Device.hpp>
|
2015-09-13 22:18:29 -04:00
|
|
|
|
2017-05-19 14:01:07 -04:00
|
|
|
#include <stddef.h>
|
2015-09-13 22:18:29 -04:00
|
|
|
|
2017-05-24 06:24:36 -04:00
|
|
|
class SDRThreadIQData {
|
2015-09-13 22:18:29 -04:00
|
|
|
public:
|
|
|
|
long long frequency;
|
|
|
|
long long sampleRate;
|
2015-09-30 23:45:06 -04:00
|
|
|
bool dcCorrected;
|
2015-10-14 00:54:48 -04:00
|
|
|
int numChannels;
|
|
|
|
std::vector<liquid_float_complex> data;
|
2015-09-13 22:18:29 -04:00
|
|
|
|
|
|
|
SDRThreadIQData() :
|
2015-10-21 16:56:32 -04:00
|
|
|
frequency(0), sampleRate(DEFAULT_SAMPLE_RATE), dcCorrected(true), numChannels(0) {
|
2015-09-13 22:18:29 -04:00
|
|
|
|
|
|
|
}
|
|
|
|
|
2016-01-26 19:20:14 -05:00
|
|
|
SDRThreadIQData(long long bandwidth, long long frequency, std::vector<signed char> * /* data */) :
|
2015-09-13 22:18:29 -04:00
|
|
|
frequency(frequency), sampleRate(bandwidth) {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
2017-05-24 06:24:36 -04:00
|
|
|
virtual ~SDRThreadIQData() {
|
2015-09-13 22:18:29 -04:00
|
|
|
|
|
|
|
}
|
|
|
|
};
|
2017-05-24 06:24:36 -04:00
|
|
|
typedef std::shared_ptr<SDRThreadIQData> SDRThreadIQDataPtr;
|
|
|
|
typedef ThreadBlockingQueue<SDRThreadIQDataPtr> SDRThreadIQDataQueue;
|
2017-08-13 12:49:47 -04:00
|
|
|
typedef std::shared_ptr<SDRThreadIQDataQueue> SDRThreadIQDataQueuePtr;
|
2015-09-13 22:18:29 -04:00
|
|
|
|
|
|
|
class SDRThread : public IOThread {
|
2015-10-03 21:35:11 -04:00
|
|
|
private:
|
2016-07-24 11:59:59 -04:00
|
|
|
bool init();
|
2015-10-03 21:35:11 -04:00
|
|
|
void deinit();
|
2017-08-13 16:14:12 -04:00
|
|
|
|
|
|
|
//returns the SoapyDevice readStream return value,
|
|
|
|
//i.e if >= 0 the numbre of samples read, else if < 0 an error code.
|
|
|
|
int readStream(SDRThreadIQDataQueuePtr iqDataOutQueue);
|
|
|
|
|
2015-10-03 21:35:11 -04:00
|
|
|
void readLoop();
|
|
|
|
|
2015-09-13 22:18:29 -04:00
|
|
|
public:
|
|
|
|
SDRThread();
|
|
|
|
~SDRThread();
|
2017-08-13 16:14:12 -04:00
|
|
|
|
|
|
|
enum SDRThreadState { SDR_THREAD_MESSAGE, SDR_THREAD_INITIALIZED, SDR_THREAD_FAILED};
|
2015-10-03 21:35:11 -04:00
|
|
|
|
2016-06-28 15:04:52 -04:00
|
|
|
virtual void run();
|
2017-08-29 12:48:59 -04:00
|
|
|
virtual void terminate();
|
2015-10-03 21:35:11 -04:00
|
|
|
|
|
|
|
SDRDeviceInfo *getDevice();
|
|
|
|
void setDevice(SDRDeviceInfo *dev);
|
2015-09-22 21:03:23 -04:00
|
|
|
int getOptimalElementCount(long long sampleRate, int fps);
|
2015-10-14 00:54:48 -04:00
|
|
|
int getOptimalChannelCount(long long sampleRate);
|
2015-10-03 21:35:11 -04:00
|
|
|
|
|
|
|
void setFrequency(long long freq);
|
|
|
|
long long getFrequency();
|
|
|
|
|
2016-01-07 00:35:02 -05:00
|
|
|
void lockFrequency(long long freq);
|
|
|
|
bool isFrequencyLocked();
|
|
|
|
void unlockFrequency();
|
|
|
|
|
2015-10-03 21:35:11 -04:00
|
|
|
void setOffset(long long ofs);
|
|
|
|
long long getOffset();
|
2017-08-23 17:27:49 -04:00
|
|
|
|
|
|
|
void setAntenna(const std::string& name);
|
|
|
|
std::string getAntenna();
|
2015-10-03 21:35:11 -04:00
|
|
|
|
2017-01-21 05:26:51 -05:00
|
|
|
void setSampleRate(long rate);
|
|
|
|
long getSampleRate();
|
2015-09-13 22:18:29 -04:00
|
|
|
|
2015-10-03 21:35:11 -04:00
|
|
|
void setPPM(int ppm);
|
|
|
|
int getPPM();
|
|
|
|
|
2015-10-27 01:56:49 -04:00
|
|
|
void setAGCMode(bool mode);
|
|
|
|
bool getAGCMode();
|
|
|
|
|
2016-02-15 15:07:57 -05:00
|
|
|
void setIQSwap(bool swap);
|
|
|
|
bool getIQSwap();
|
|
|
|
|
2015-10-27 01:56:49 -04:00
|
|
|
void setGain(std::string name, float value);
|
|
|
|
float getGain(std::string name);
|
|
|
|
|
2015-11-03 21:06:22 -05:00
|
|
|
void writeSetting(std::string name, std::string value);
|
|
|
|
std::string readSetting(std::string name);
|
|
|
|
|
2015-11-04 02:04:52 -05:00
|
|
|
void setStreamArgs(SoapySDR::Kwargs streamArgs);
|
|
|
|
|
2015-09-13 22:18:29 -04:00
|
|
|
protected:
|
2015-10-27 01:56:49 -04:00
|
|
|
void updateGains();
|
2015-11-03 21:06:22 -05:00
|
|
|
void updateSettings();
|
2015-11-04 02:04:52 -05:00
|
|
|
SoapySDR::Kwargs combineArgs(SoapySDR::Kwargs a, SoapySDR::Kwargs b);
|
2015-11-03 21:06:22 -05:00
|
|
|
|
2015-10-03 21:35:11 -04:00
|
|
|
SoapySDR::Stream *stream;
|
|
|
|
SoapySDR::Device *device;
|
|
|
|
void *buffs[1];
|
|
|
|
ReBuffer<SDRThreadIQData> buffers;
|
2016-01-26 21:49:42 -05:00
|
|
|
SDRThreadIQData overflowBuffer;
|
|
|
|
int numOverflow;
|
2015-10-03 21:35:11 -04:00
|
|
|
std::atomic<DeviceConfig *> deviceConfig;
|
|
|
|
std::atomic<SDRDeviceInfo *> deviceInfo;
|
2015-11-03 21:06:22 -05:00
|
|
|
|
|
|
|
std::mutex setting_busy;
|
|
|
|
std::map<std::string, std::string> settings;
|
|
|
|
std::map<std::string, bool> settingChanged;
|
2015-10-03 21:35:11 -04:00
|
|
|
|
2017-01-21 05:26:51 -05:00
|
|
|
std::atomic_llong sampleRate;
|
2016-01-07 00:35:02 -05:00
|
|
|
std::atomic_llong frequency, offset, lock_freq;
|
2016-01-26 21:49:42 -05:00
|
|
|
std::atomic_int ppm, numElems, mtuElems, numChannels;
|
2015-11-02 19:02:45 -05:00
|
|
|
std::atomic_bool hasPPM, hasHardwareDC;
|
2017-08-23 17:27:49 -04:00
|
|
|
std::string antennaName;
|
|
|
|
std::atomic_bool agc_mode, rate_changed, freq_changed, offset_changed, antenna_changed,
|
2016-02-15 15:07:57 -05:00
|
|
|
ppm_changed, device_changed, agc_mode_changed, gain_value_changed, setting_value_changed, frequency_locked, frequency_lock_init, iq_swap;
|
2015-10-31 13:35:13 -04:00
|
|
|
|
|
|
|
std::mutex gain_busy;
|
|
|
|
std::map<std::string, float> gainValues;
|
|
|
|
std::map<std::string, bool> gainChanged;
|
2015-11-04 02:04:52 -05:00
|
|
|
|
|
|
|
SoapySDR::Kwargs streamArgs;
|
2017-05-19 14:01:07 -04:00
|
|
|
|
|
|
|
private:
|
|
|
|
void assureBufferMinSize(SDRThreadIQData * dataOut, size_t minSize);
|
2015-09-13 22:18:29 -04:00
|
|
|
};
|