CubicSDR/src/demod/DemodDefs.h

149 lines
3.7 KiB
C
Raw Normal View History

2014-12-11 19:07:21 -05:00
#pragma once
#include "ThreadQueue.h"
#include "CubicSDRDefs.h"
#include "liquid/liquid.h"
2014-12-11 19:07:21 -05:00
#include <atomic>
#include <mutex>
2015-01-01 18:08:54 -05:00
#define DEMOD_TYPE_NULL 0
#define DEMOD_TYPE_FM 1
#define DEMOD_TYPE_AM 2
#define DEMOD_TYPE_LSB 3
#define DEMOD_TYPE_USB 4
#define DEMOD_TYPE_DSB 5
2015-06-27 23:23:43 -04:00
#define DEMOD_TYPE_RAW 6
2015-07-29 18:34:58 -04:00
#include "IOThread.h"
2015-01-01 18:08:54 -05:00
2014-12-11 19:07:21 -05:00
class DemodulatorThread;
class DemodulatorThreadCommand {
public:
2014-12-16 21:30:03 -05:00
enum DemodulatorThreadCommandEnum {
DEMOD_THREAD_CMD_NULL,
DEMOD_THREAD_CMD_SET_BANDWIDTH,
DEMOD_THREAD_CMD_SET_FREQUENCY,
DEMOD_THREAD_CMD_SET_AUDIO_RATE,
2014-12-16 21:30:03 -05:00
DEMOD_THREAD_CMD_DEMOD_PREPROCESS_TERMINATED,
DEMOD_THREAD_CMD_DEMOD_TERMINATED,
DEMOD_THREAD_CMD_AUDIO_TERMINATED
};
2014-12-11 19:07:21 -05:00
2014-12-16 21:30:03 -05:00
DemodulatorThreadCommand() :
cmd(DEMOD_THREAD_CMD_NULL), context(NULL), llong_value(0) {
2014-12-16 21:30:03 -05:00
}
2014-12-11 19:07:21 -05:00
2014-12-16 21:30:03 -05:00
DemodulatorThreadCommand(DemodulatorThreadCommandEnum cmd) :
cmd(cmd), context(NULL), llong_value(0) {
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
}
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
DemodulatorThreadCommandEnum cmd;
void *context;
long long llong_value;
2014-12-11 19:07:21 -05:00
};
class DemodulatorThreadControlCommand {
public:
enum DemodulatorThreadControlCommandEnum {
DEMOD_THREAD_CMD_CTL_NULL, DEMOD_THREAD_CMD_CTL_SQUELCH_ON, DEMOD_THREAD_CMD_CTL_SQUELCH_OFF, DEMOD_THREAD_CMD_CTL_TYPE
};
DemodulatorThreadControlCommand() :
2015-01-01 18:08:54 -05:00
cmd(DEMOD_THREAD_CMD_CTL_NULL), demodType(DEMOD_TYPE_NULL) {
}
DemodulatorThreadControlCommandEnum cmd;
2015-01-01 18:08:54 -05:00
int demodType;
};
2014-12-24 01:28:33 -05:00
class DemodulatorThreadIQData: public ReferenceCounter {
2014-12-11 19:07:21 -05:00
public:
long long frequency;
2015-01-11 17:08:16 -05:00
long long sampleRate;
2014-12-26 16:15:35 -05:00
std::vector<liquid_float_complex> data;
2015-05-27 23:22:19 -04:00
std::mutex busy_rw;
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
DemodulatorThreadIQData() :
2015-01-11 17:08:16 -05:00
frequency(0), sampleRate(0) {
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
}
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
~DemodulatorThreadIQData() {
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
}
2014-12-11 19:07:21 -05:00
};
2014-12-24 01:28:33 -05:00
class DemodulatorThreadPostIQData: public ReferenceCounter {
public:
2014-12-24 01:28:33 -05:00
std::vector<liquid_float_complex> data;
2015-01-11 17:08:16 -05:00
long long sampleRate;
msresamp_rrrf audioResampler;
msresamp_rrrf stereoResampler;
double audioResampleRatio;
int audioSampleRate;
firfilt_rrrf firStereoLeft;
firfilt_rrrf firStereoRight;
iirfilt_crcf iirStereoPilot;
2014-12-24 01:28:33 -05:00
DemodulatorThreadPostIQData() :
sampleRate(0), audioResampler(NULL), stereoResampler(NULL), audioResampleRatio(0), audioSampleRate(0), firStereoLeft(NULL), firStereoRight(NULL), iirStereoPilot(NULL) {
2014-12-24 01:28:33 -05:00
}
2014-12-24 01:28:33 -05:00
~DemodulatorThreadPostIQData() {
std::lock_guard < std::mutex > lock(m_mutex);
2014-12-24 01:28:33 -05:00
}
};
2014-12-24 01:28:33 -05:00
class DemodulatorThreadAudioData: public ReferenceCounter {
2014-12-11 19:07:21 -05:00
public:
long long frequency;
2014-12-24 01:28:33 -05:00
unsigned int sampleRate;
unsigned char channels;
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
std::vector<float> *data;
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
DemodulatorThreadAudioData() :
frequency(0), sampleRate(0), channels(0), data(NULL) {
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
}
2014-12-11 19:07:21 -05:00
DemodulatorThreadAudioData(long long frequency, unsigned int sampleRate, std::vector<float> *data) :
2014-12-24 01:28:33 -05:00
frequency(frequency), sampleRate(sampleRate), channels(1), data(data) {
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
}
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
~DemodulatorThreadAudioData() {
2014-12-11 19:07:21 -05:00
2014-12-24 01:28:33 -05:00
}
2014-12-11 19:07:21 -05:00
};
2014-12-22 23:27:52 -05:00
typedef ThreadQueue<DemodulatorThreadIQData *> DemodulatorThreadInputQueue;
2014-12-23 01:12:14 -05:00
typedef ThreadQueue<DemodulatorThreadPostIQData *> DemodulatorThreadPostInputQueue;
2014-12-11 19:07:21 -05:00
typedef ThreadQueue<DemodulatorThreadCommand> DemodulatorThreadCommandQueue;
typedef ThreadQueue<DemodulatorThreadControlCommand> DemodulatorThreadControlCommandQueue;
class DemodulatorThreadParameters {
public:
long long frequency;
2015-01-11 17:08:16 -05:00
long long sampleRate;
unsigned int bandwidth; // set equal to disable second stage re-sampling?
unsigned int audioSampleRate;
2015-01-01 18:08:54 -05:00
int demodType;
DemodulatorThreadParameters() :
frequency(0), sampleRate(DEFAULT_SAMPLE_RATE), bandwidth(200000), audioSampleRate(0),
demodType(DEMOD_TYPE_FM) {
}
~DemodulatorThreadParameters() {
}
};