TestMIThread Class Reference

#include <testmithread.h>

Inherits QThread.

Collaboration diagram for TestMIThread:

Classes
class	MsgStartStop

Public Member Functions
	TestMIThread (SampleSinkFifo *sampleFifo, int streamIndex, QObject *parent=0)
	~TestMIThread ()
void	startStop (bool start)
void	setSamplerate (int samplerate)
void	setLog2Decimation (unsigned int log2_decim)
void	setFcPos (int fcPos)
void	setBitSize (uint32_t bitSizeIndex)
void	setAmplitudeBits (int32_t amplitudeBits)
void	setDCFactor (float iFactor)
void	setIFactor (float iFactor)
void	setQFactor (float qFactor)
void	setPhaseImbalance (float phaseImbalance)
void	setFrequencyShift (int shift)
void	setToneFrequency (int toneFrequency)
void	setModulation (TestMIStreamSettings::Modulation modulation)
void	setAMModulation (float amModulation)
void	setFMDeviation (float deviation)
void	setPattern0 ()
void	setPattern1 ()
void	setPattern2 ()

Private Slots
void	tick ()
void	handleInputMessages ()

Private Member Functions
void	startWork ()
void	stopWork ()
void	run ()
void	callback (const qint16 *buf, qint32 len)
void	setBuffers (quint32 chunksize)
void	generate (quint32 chunksize)
void	pullAF (Real &afSample)
void	convert_8 (SampleVector::iterator *it, const qint16 *buf, qint32 len)
void	convert_12 (SampleVector::iterator *it, const qint16 *buf, qint32 len)
void	convert_16 (SampleVector::iterator *it, const qint16 *buf, qint32 len)

Private Attributes
QMutex	m_startWaitMutex
QWaitCondition	m_startWaiter
volatile bool	m_running
qint16 *	m_buf
quint32	m_bufsize
quint32	m_chunksize
SampleVector	m_convertBuffer
SampleSinkFifo *	m_sampleFifo
int	m_streamIndex
NCOF	m_nco
NCOF	m_toneNco
int	m_frequencyShift
int	m_toneFrequency
TestMIStreamSettings::Modulation	m_modulation
float	m_amModulation
float	m_fmDeviationUnit
float	m_fmPhasor
uint32_t	m_pulseWidth
	pulse width in number of samples More...
uint32_t	m_pulseSampleCount
uint32_t	m_pulsePatternCount
uint32_t	m_pulsePatternCycle
uint32_t	m_pulsePatternPlaces
int	m_samplerate
unsigned int	m_log2Decim
int	m_fcPos
uint32_t	m_bitSizeIndex
uint32_t	m_bitShift
int32_t	m_amplitudeBits
float	m_dcBias
float	m_iBias
float	m_qBias
float	m_phaseImbalance
int32_t	m_amplitudeBitsDC
int32_t	m_amplitudeBitsI
int32_t	m_amplitudeBitsQ
uint64_t	m_frequency
int	m_fcPosShift
int	m_throttlems
QTimer	m_timer
QElapsedTimer	m_elapsedTimer
bool	m_throttleToggle
QMutex	m_mutex
MessageQueue	m_inputMessageQueue
Decimators< qint32, qint16, SDR_RX_SAMP_SZ, 8 >	m_decimators_8
Decimators< qint32, qint16, SDR_RX_SAMP_SZ, 12 >	m_decimators_12
Decimators< qint32, qint16, SDR_RX_SAMP_SZ, 16 >	m_decimators_16

Detailed Description

Definition at line 38 of file testmithread.h.

Constructor & Destructor Documentation

TestMIThread()

TestMIThread::TestMIThread	(	SampleSinkFifo *	sampleFifo,
		int	streamIndex,
		QObject *	parent = 0
	)

Definition at line 31 of file testmithread.cpp.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

                                                                                       :
    QThread(parent),
    m_running(false),
    m_buf(0),
    m_bufsize(0),
    m_chunksize(0),
    m_convertBuffer(TESTMI_BLOCKSIZE),
    m_sampleFifo(sampleFifo),
    m_streamIndex(streamIndex),
    m_frequencyShift(0),
    m_toneFrequency(440),
    m_modulation(TestMIStreamSettings::ModulationNone),
    m_amModulation(0.5f),
    m_fmDeviationUnit(0.0f),
    m_fmPhasor(0.0f),
    m_pulseWidth(150),
    m_pulseSampleCount(0),
    m_pulsePatternCount(0),
    m_pulsePatternCycle(8),
    m_pulsePatternPlaces(3),
    m_samplerate(48000),
    m_log2Decim(4),
    m_fcPos(0),
    m_bitSizeIndex(0),
    m_bitShift(8),
    m_amplitudeBits(127),
    m_dcBias(0.0f),
    m_iBias(0.0f),
    m_qBias(0.0f),
    m_phaseImbalance(0.0f),
    m_amplitudeBitsDC(0),
    m_amplitudeBitsI(127),
    m_amplitudeBitsQ(127),
    m_frequency(435*1000),
    m_fcPosShift(0),
    m_throttlems(TESTMI_THROTTLE_MS),
    m_throttleToggle(false),
    m_mutex(QMutex::Recursive)
{
    connect(&m_inputMessageQueue, SIGNAL(messageEnqueued()), this, SLOT(handleInputMessages()), Qt::QueuedConnection);
}

Here is the caller graph for this function:

~TestMIThread()

TestMIThread::~TestMIThread

(

)

Definition at line 73 of file testmithread.cpp.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
}

Here is the caller graph for this function:

Member Function Documentation

callback()

void TestMIThread::callback ( const qint16 *  buf, qint32  len  )

private

Definition at line 371 of file testmithread.cpp.

References convert_12(), convert_16(), convert_8(), m_bitSizeIndex, m_convertBuffer, m_sampleFifo, and SampleSinkFifo::write().

Referenced by generate().

{
    SampleVector::iterator it = m_convertBuffer.begin();

    switch (m_bitSizeIndex)
    {
    case 0: // 8 bit samples
        convert_8(&it, buf, len);
        break;
    case 1: // 12 bit samples
        convert_12(&it, buf, len);
        break;
    case 2: // 16 bit samples
    default:
        convert_16(&it, buf, len);
        break;
    }

    m_sampleFifo->write(m_convertBuffer.begin(), it);
}

Here is the call graph for this function:

Here is the caller graph for this function:

convert_12()

void TestMIThread::convert_12 ( SampleVector::iterator *  it, const qint16 *  buf, qint32  len  )

inlineprivate

Definition at line 224 of file testmithread.h.

References Decimators< StorageType, T, SdrBits, InputBits >::decimate1(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_inf(), and Decimators< StorageType, T, SdrBits, InputBits >::decimate8_sup().

Referenced by callback().

    {
        if (m_log2Decim == 0) {
            m_decimators_12.decimate1(it, buf, len);
        } else {
            if (m_fcPos == 0) { // Infradyne
                switch (m_log2Decim) {
                case 1:
                    m_decimators_12.decimate2_inf(it, buf, len);
                    break;
                case 2:
                    m_decimators_12.decimate4_inf(it, buf, len);
                    break;
                case 3:
                    m_decimators_12.decimate8_inf(it, buf, len);
                    break;
                case 4:
                    m_decimators_12.decimate16_inf(it, buf, len);
                    break;
                case 5:
                    m_decimators_12.decimate32_inf(it, buf, len);
                    break;
                case 6:
                    m_decimators_12.decimate64_inf(it, buf, len);
                    break;
                default:
                    break;
                }
            } else if (m_fcPos == 1)  {// Supradyne
                switch (m_log2Decim) {
                case 1:
                    m_decimators_12.decimate2_sup(it, buf, len);
                    break;
                case 2:
                    m_decimators_12.decimate4_sup(it, buf, len);
                    break;
                case 3:
                    m_decimators_12.decimate8_sup(it, buf, len);
                    break;
                case 4:
                    m_decimators_12.decimate16_sup(it, buf, len);
                    break;
                case 5:
                    m_decimators_12.decimate32_sup(it, buf, len);
                    break;
                case 6:
                    m_decimators_12.decimate64_sup(it, buf, len);
                    break;
                default:
                    break;
                }
            } else { // Centered
                switch (m_log2Decim) {
                case 1:
                    m_decimators_12.decimate2_cen(it, buf, len);
                    break;
                case 2:
                    m_decimators_12.decimate4_cen(it, buf, len);
                    break;
                case 3:
                    m_decimators_12.decimate8_cen(it, buf, len);
                    break;
                case 4:
                    m_decimators_12.decimate16_cen(it, buf, len);
                    break;
                case 5:
                    m_decimators_12.decimate32_cen(it, buf, len);
                    break;
                case 6:
                    m_decimators_12.decimate64_cen(it, buf, len);
                    break;
                default:
                    break;
                }
            }
        }
    }

Here is the call graph for this function:

Here is the caller graph for this function:

convert_16()

void TestMIThread::convert_16 ( SampleVector::iterator *  it, const qint16 *  buf, qint32  len  )

inlineprivate

Definition at line 302 of file testmithread.h.

References Decimators< StorageType, T, SdrBits, InputBits >::decimate1(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_sup(), handleInputMessages(), and tick().

Referenced by callback().

    {
        if (m_log2Decim == 0) {
            m_decimators_16.decimate1(it, buf, len);
        } else {
            if (m_fcPos == 0) { // Infradyne
                switch (m_log2Decim) {
                case 1:
                    m_decimators_16.decimate2_inf(it, buf, len);
                    break;
                case 2:
                    m_decimators_16.decimate4_inf(it, buf, len);
                    break;
                case 3:
                    m_decimators_16.decimate8_inf(it, buf, len);
                    break;
                case 4:
                    m_decimators_16.decimate16_inf(it, buf, len);
                    break;
                case 5:
                    m_decimators_16.decimate32_inf(it, buf, len);
                    break;
                case 6:
                    m_decimators_16.decimate64_inf(it, buf, len);
                    break;
                default:
                    break;
                }
            } else if (m_fcPos == 1)  {// Supradyne
                switch (m_log2Decim) {
                case 1:
                    m_decimators_16.decimate2_sup(it, buf, len);
                    break;
                case 2:
                    m_decimators_16.decimate4_sup(it, buf, len);
                    break;
                case 3:
                    m_decimators_16.decimate8_sup(it, buf, len);
                    break;
                case 4:
                    m_decimators_16.decimate16_sup(it, buf, len);
                    break;
                case 5:
                    m_decimators_16.decimate32_sup(it, buf, len);
                    break;
                case 6:
                    m_decimators_16.decimate64_sup(it, buf, len);
                    break;
                default:
                    break;
                }
            } else { // Centered
                switch (m_log2Decim) {
                case 1:
                    m_decimators_16.decimate2_cen(it, buf, len);
                    break;
                case 2:
                    m_decimators_16.decimate4_cen(it, buf, len);
                    break;
                case 3:
                    m_decimators_16.decimate8_cen(it, buf, len);
                    break;
                case 4:
                    m_decimators_16.decimate16_cen(it, buf, len);
                    break;
                case 5:
                    m_decimators_16.decimate32_cen(it, buf, len);
                    break;
                case 6:
                    m_decimators_16.decimate64_cen(it, buf, len);
                    break;
                default:
                    break;
                }
            }
        }
    }

Here is the call graph for this function:

Here is the caller graph for this function:

convert_8()

void TestMIThread::convert_8 ( SampleVector::iterator *  it, const qint16 *  buf, qint32  len  )

inlineprivate

Definition at line 146 of file testmithread.h.

References Decimators< StorageType, T, SdrBits, InputBits >::decimate1(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate16_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate2_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate32_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate4_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_inf(), Decimators< StorageType, T, SdrBits, InputBits >::decimate64_sup(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_cen(), Decimators< StorageType, T, SdrBits, InputBits >::decimate8_inf(), and Decimators< StorageType, T, SdrBits, InputBits >::decimate8_sup().

Referenced by callback().

    {
        if (m_log2Decim == 0) {
            m_decimators_8.decimate1(it, buf, len);
        } else {
            if (m_fcPos == 0) { // Infradyne
                switch (m_log2Decim) {
                case 1:
                    m_decimators_8.decimate2_inf(it, buf, len);
                    break;
                case 2:
                    m_decimators_8.decimate4_inf(it, buf, len);
                    break;
                case 3:
                    m_decimators_8.decimate8_inf(it, buf, len);
                    break;
                case 4:
                    m_decimators_8.decimate16_inf(it, buf, len);
                    break;
                case 5:
                    m_decimators_8.decimate32_inf(it, buf, len);
                    break;
                case 6:
                    m_decimators_8.decimate64_inf(it, buf, len);
                    break;
                default:
                    break;
                }
            } else if (m_fcPos == 1)  {// Supradyne
                switch (m_log2Decim) {
                case 1:
                    m_decimators_8.decimate2_sup(it, buf, len);
                    break;
                case 2:
                    m_decimators_8.decimate4_sup(it, buf, len);
                    break;
                case 3:
                    m_decimators_8.decimate8_sup(it, buf, len);
                    break;
                case 4:
                    m_decimators_8.decimate16_sup(it, buf, len);
                    break;
                case 5:
                    m_decimators_8.decimate32_sup(it, buf, len);
                    break;
                case 6:
                    m_decimators_8.decimate64_sup(it, buf, len);
                    break;
                default:
                    break;
                }
            } else { // Centered
                switch (m_log2Decim) {
                case 1:
                    m_decimators_8.decimate2_cen(it, buf, len);
                    break;
                case 2:
                    m_decimators_8.decimate4_cen(it, buf, len);
                    break;
                case 3:
                    m_decimators_8.decimate8_cen(it, buf, len);
                    break;
                case 4:
                    m_decimators_8.decimate16_cen(it, buf, len);
                    break;
                case 5:
                    m_decimators_8.decimate32_cen(it, buf, len);
                    break;
                case 6:
                    m_decimators_8.decimate64_cen(it, buf, len);
                    break;
                default:
                    break;
                }
            }
        }
    }

Here is the call graph for this function:

Here is the caller graph for this function:

generate()

void TestMIThread::generate ( quint32  chunksize )

private

Definition at line 242 of file testmithread.cpp.

References callback(), cos(), i, m_amModulation, m_amplitudeBitsDC, m_amplitudeBitsI, m_amplitudeBitsQ, m_buf, m_fmDeviationUnit, m_fmPhasor, m_modulation, m_nco, m_phaseImbalance, M_PI, m_pulsePatternCount, m_pulsePatternCycle, m_pulsePatternPlaces, m_pulseSampleCount, m_pulseWidth, TestMIStreamSettings::ModulationAM, TestMIStreamSettings::ModulationFM, TestMIStreamSettings::ModulationNone, TestMIStreamSettings::ModulationPattern0, TestMIStreamSettings::ModulationPattern1, TestMIStreamSettings::ModulationPattern2, NCOF::nextIQ(), pullAF(), setBuffers(), and sin().

Referenced by tick().

{
    int n = chunksize / 2;
    setBuffers(chunksize);

    for (int i = 0; i < n-1;)
    {
        switch (m_modulation)
        {
        case TestMIStreamSettings::ModulationAM:
        {
            Complex c = m_nco.nextIQ();
            Real t, re, im;
            pullAF(t);
            t = (t*m_amModulation + 1.0f)*0.5f;
            re = c.real()*t;
            im = c.imag()*t + m_phaseImbalance*re;
            m_buf[i++] = (int16_t) (re * (float) m_amplitudeBitsI) + m_amplitudeBitsDC;
            m_buf[i++] = (int16_t) (im * (float) m_amplitudeBitsQ);
        }
        break;
        case TestMIStreamSettings::ModulationFM:
        {
            Complex c = m_nco.nextIQ();
            Real t, re, im;
            pullAF(t);
            m_fmPhasor += m_fmDeviationUnit * t;
            m_fmPhasor = m_fmPhasor < -1.0f ? -m_fmPhasor - 1.0f  : m_fmPhasor > 1.0f ? m_fmPhasor - 1.0f : m_fmPhasor;
            re =  c.real()*cos(m_fmPhasor*M_PI) - c.imag()*sin(m_fmPhasor*M_PI);
            im = (c.real()*sin(m_fmPhasor*M_PI) + c.imag()*cos(m_fmPhasor*M_PI)) + m_phaseImbalance*re;
            m_buf[i++] = (int16_t) (re * (float) m_amplitudeBitsI) + m_amplitudeBitsDC;
            m_buf[i++] = (int16_t) (im * (float) m_amplitudeBitsQ);
        }
        break;
        case TestMIStreamSettings::ModulationPattern0: // binary pattern
        {
            if (m_pulseSampleCount < m_pulseWidth) // sync pattern: 0
            {
                m_buf[i++] = m_amplitudeBitsDC;
                m_buf[i++] = 0;
            }
            else if (m_pulseSampleCount < 2*m_pulseWidth) // sync pattern: 1
            {
                m_buf[i++] = (int16_t) (m_amplitudeBitsI + m_amplitudeBitsDC);
                m_buf[i++] = (int16_t) (m_phaseImbalance * (float) m_amplitudeBitsQ);
            }
            else if (m_pulseSampleCount < 3*m_pulseWidth) // sync pattern: 0
            {
                m_buf[i++] = m_amplitudeBitsDC;
                m_buf[i++] = 0;
            }
            else if (m_pulseSampleCount < (3+m_pulsePatternPlaces)*m_pulseWidth) // binary pattern
            {
                uint32_t patPulseSampleCount = m_pulseSampleCount - 3*m_pulseWidth;
                uint32_t patPulseIndex = patPulseSampleCount / m_pulseWidth;
                float patFigure = (m_pulsePatternCount & (1<<patPulseIndex)) != 0 ? 0.3 : 0.0; // make binary pattern ~-10dB vs sync pattern
                m_buf[i++] = (int16_t) (patFigure * (float) m_amplitudeBitsI) + m_amplitudeBitsDC;
                m_buf[i++] = (int16_t) (patFigure * (float) m_phaseImbalance * m_amplitudeBitsQ);
            }

            if (m_pulseSampleCount < (4+m_pulsePatternPlaces)*m_pulseWidth - 1)
            {
                m_pulseSampleCount++;
            }
            else
            {
                if (m_pulsePatternCount < m_pulsePatternCycle - 1) {
                    m_pulsePatternCount++;
                } else {
                    m_pulsePatternCount = 0;
                }

                m_pulseSampleCount = 0;
            }
        }
        break;
        case TestMIStreamSettings::ModulationPattern1: // sawtooth pattern
        {
            Real re, im;
            re = (float) (m_pulseWidth - m_pulseSampleCount) / (float) m_pulseWidth;
            im = m_phaseImbalance*re;
            m_buf[i++] = (int16_t) (re * (float) m_amplitudeBitsI) + m_amplitudeBitsDC;
            m_buf[i++] = (int16_t) (im * (float) m_amplitudeBitsQ);

            if (m_pulseSampleCount < m_pulseWidth - 1) {
                m_pulseSampleCount++;
            } else {
                m_pulseSampleCount = 0;
            }
        }
        break;
        case TestMIStreamSettings::ModulationPattern2: // 50% duty cycle square pattern
        {
            if (m_pulseSampleCount < m_pulseWidth) // 1
            {
                m_buf[i++] = (int16_t) (m_amplitudeBitsI + m_amplitudeBitsDC);
                m_buf[i++] = (int16_t) (m_phaseImbalance * (float) m_amplitudeBitsQ);
            } else { // 0
                m_buf[i++] = m_amplitudeBitsDC;
                m_buf[i++] = 0;
            }

            if (m_pulseSampleCount < 2*m_pulseWidth - 1) {
                m_pulseSampleCount++;
            } else {
                m_pulseSampleCount = 0;
            }
        }
        break;
        case TestMIStreamSettings::ModulationNone:
        default:
        {
            Complex c = m_nco.nextIQ(m_phaseImbalance);
            m_buf[i++] = (int16_t) (c.real() * (float) m_amplitudeBitsI) + m_amplitudeBitsDC;
            m_buf[i++] = (int16_t) (c.imag() * (float) m_amplitudeBitsQ);
        }
        break;
        }
    }

    callback(m_buf, n);
}

Here is the call graph for this function:

Here is the caller graph for this function:

handleInputMessages

void TestMIThread::handleInputMessages ( )

privateslot

Definition at line 410 of file testmithread.cpp.

References TestMIThread::MsgStartStop::getStartStop(), m_inputMessageQueue, Message::match(), MessageQueue::pop(), startWork(), and stopWork().

Referenced by convert_16().

{
    Message* message;

    while ((message = m_inputMessageQueue.pop()) != 0)
    {
        if (MsgStartStop::match(*message))
        {
            MsgStartStop* notif = (MsgStartStop*) message;
            qDebug("TestMIThread::handleInputMessages: MsgStartStop: %s", notif->getStartStop() ? "start" : "stop");

            if (notif->getStartStop()) {
                startWork();
            } else {
                stopWork();
            }

            delete message;
        }
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

pullAF()

void TestMIThread::pullAF ( Real &  afSample )

private

Definition at line 365 of file testmithread.cpp.

References m_toneNco, and NCOF::next().

Referenced by generate().

{
    afSample = m_toneNco.next();
}

Here is the call graph for this function:

Here is the caller graph for this function:

run()

void TestMIThread::run ( )

private

Definition at line 203 of file testmithread.cpp.

References m_running, and m_startWaiter.

{
    m_running = true;
    m_startWaiter.wakeAll();

    while (m_running) // actual work is in the tick() function
    {
        sleep(1);
    }

    m_running = false;
}

setAMModulation()

void TestMIThread::setAMModulation

(

float

amModulation

)

Definition at line 185 of file testmithread.cpp.

References m_amModulation.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_amModulation = amModulation < 0.0f ? 0.0f : amModulation > 1.0f ? 1.0f : amModulation;
}

Here is the caller graph for this function:

setAmplitudeBits()

void TestMIThread::setAmplitudeBits

(

int32_t

amplitudeBits

)

Definition at line 139 of file testmithread.cpp.

References m_amplitudeBits, m_amplitudeBitsDC, m_amplitudeBitsI, m_amplitudeBitsQ, m_dcBias, m_iBias, and m_qBias.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_amplitudeBits = amplitudeBits;
    m_amplitudeBitsDC = m_dcBias * amplitudeBits;
    m_amplitudeBitsI = (1.0f + m_iBias) * amplitudeBits;
    m_amplitudeBitsQ = (1.0f + m_qBias) * amplitudeBits;
}

Here is the caller graph for this function:

setBitSize()

void TestMIThread::setBitSize

(

uint32_t

bitSizeIndex

)

Definition at line 119 of file testmithread.cpp.

References m_bitShift, and m_bitSizeIndex.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    switch (bitSizeIndex)
    {
    case 0:
        m_bitShift = 7;
        m_bitSizeIndex = 0;
        break;
    case 1:
        m_bitShift = 11;
        m_bitSizeIndex = 1;
        break;
    case 2:
    default:
        m_bitShift = 15;
        m_bitSizeIndex = 2;
        break;
    }
}

Here is the caller graph for this function:

setBuffers()

void TestMIThread::setBuffers ( quint32  chunksize )

private

Definition at line 216 of file testmithread.cpp.

References m_buf, m_bufsize, and m_convertBuffer.

Referenced by generate().

{
    if (chunksize > m_bufsize)
    {
        m_bufsize = chunksize;

        if (m_buf == 0)
        {
            qDebug() << "TestMIThread::setBuffer: Allocate buffer:    "
                    << " size: " << m_bufsize << " bytes"
                    << " #samples: " << (m_bufsize/4);
            m_buf = (qint16*) malloc(m_bufsize);
        }
        else
        {
            qDebug() << "TestMIThread::setBuffer: Re-allocate buffer: "
                    << " size: " << m_bufsize << " bytes"
                    << " #samples: " << (m_bufsize/4);
            free(m_buf);
            m_buf = (qint16*) malloc(m_bufsize);
        }

        m_convertBuffer.resize(chunksize/4);
    }
}

Here is the caller graph for this function:

setDCFactor()

void TestMIThread::setDCFactor

(

float

iFactor

)

Definition at line 147 of file testmithread.cpp.

References m_amplitudeBits, m_amplitudeBitsDC, and m_dcBias.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_dcBias = dcFactor;
    m_amplitudeBitsDC = m_dcBias * m_amplitudeBits;
}

Here is the caller graph for this function:

setFcPos()

void TestMIThread::setFcPos

(

int

fcPos

)

Definition at line 114 of file testmithread.cpp.

References m_fcPos.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_fcPos = fcPos;
}

Here is the caller graph for this function:

setFMDeviation()

void TestMIThread::setFMDeviation

(

float

deviation

)

Definition at line 190 of file testmithread.cpp.

References m_fmDeviationUnit, and m_samplerate.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    float fmDeviationUnit = deviation / (float) m_samplerate;
    m_fmDeviationUnit = fmDeviationUnit < 0.0f ? 0.0f : fmDeviationUnit > 0.5f ? 0.5f : fmDeviationUnit;
    qDebug("TestMIThread::setFMDeviation: m_fmDeviationUnit: %f", m_fmDeviationUnit);
}

Here is the caller graph for this function:

setFrequencyShift()

void TestMIThread::setFrequencyShift

(

int

shift

)

Definition at line 170 of file testmithread.cpp.

References m_nco, m_samplerate, and NCOF::setFreq().

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_nco.setFreq(shift, m_samplerate);
}

Here is the call graph for this function:

Here is the caller graph for this function:

setIFactor()

void TestMIThread::setIFactor

(

float

iFactor

)

Definition at line 153 of file testmithread.cpp.

References m_amplitudeBits, m_amplitudeBitsI, and m_iBias.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_iBias = iFactor;
    m_amplitudeBitsI = (1.0f + m_iBias) * m_amplitudeBits;
}

Here is the caller graph for this function:

setLog2Decimation()

void TestMIThread::setLog2Decimation

(

unsigned int

log2_decim

)

Definition at line 109 of file testmithread.cpp.

References m_log2Decim.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_log2Decim = log2_decim;
}

Here is the caller graph for this function:

setModulation()

void TestMIThread::setModulation

(

TestMIStreamSettings::Modulation

modulation

)

Definition at line 180 of file testmithread.cpp.

References m_modulation.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_modulation = modulation;
}

Here is the caller graph for this function:

setPattern0()

void TestMIThread::setPattern0

(

)

Definition at line 432 of file testmithread.cpp.

References m_pulsePatternCount, m_pulsePatternCycle, m_pulsePatternPlaces, m_pulseSampleCount, and m_pulseWidth.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_pulseWidth = 150;
    m_pulseSampleCount = 0;
    m_pulsePatternCount = 0;
    m_pulsePatternCycle = 8;
    m_pulsePatternPlaces = 3;
}

Here is the caller graph for this function:

setPattern1()

void TestMIThread::setPattern1

(

)

Definition at line 441 of file testmithread.cpp.

References m_pulseSampleCount, and m_pulseWidth.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_pulseWidth = 1000;
    m_pulseSampleCount = 0;
}

Here is the caller graph for this function:

setPattern2()

void TestMIThread::setPattern2

(

)

Definition at line 447 of file testmithread.cpp.

References m_pulseSampleCount, and m_pulseWidth.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_pulseWidth = 1000;
    m_pulseSampleCount = 0;
}

Here is the caller graph for this function:

setPhaseImbalance()

void TestMIThread::setPhaseImbalance

(

float

phaseImbalance

)

Definition at line 165 of file testmithread.cpp.

References m_phaseImbalance.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_phaseImbalance = phaseImbalance;
}

Here is the caller graph for this function:

setQFactor()

void TestMIThread::setQFactor

(

float

qFactor

)

Definition at line 159 of file testmithread.cpp.

References m_amplitudeBits, m_amplitudeBitsQ, and m_qBias.

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_qBias = iFactor;
    m_amplitudeBitsQ = (1.0f + m_qBias) * m_amplitudeBits;
}

Here is the caller graph for this function:

setSamplerate()

void TestMIThread::setSamplerate

(

int

samplerate

)

Definition at line 98 of file testmithread.cpp.

References m_chunksize, m_frequencyShift, m_mutex, m_nco, m_samplerate, m_throttlems, m_throttleToggle, m_toneFrequency, m_toneNco, and NCOF::setFreq().

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    QMutexLocker mutexLocker(&m_mutex);

    m_samplerate = samplerate;
    m_chunksize = 4 * ((m_samplerate * (m_throttlems+(m_throttleToggle ? 1 : 0))) / 1000);
    m_throttleToggle = !m_throttleToggle;
    m_nco.setFreq(m_frequencyShift, m_samplerate);
    m_toneNco.setFreq(m_toneFrequency, m_samplerate);
}

Here is the call graph for this function:

Here is the caller graph for this function:

setToneFrequency()

void TestMIThread::setToneFrequency

(

int

toneFrequency

)

Definition at line 175 of file testmithread.cpp.

References m_samplerate, m_toneNco, and NCOF::setFreq().

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    m_toneNco.setFreq(toneFrequency, m_samplerate);
}

Here is the call graph for this function:

Here is the caller graph for this function:

startStop()

void TestMIThread::startStop

(

bool

start

)

Definition at line 197 of file testmithread.cpp.

References TestMIThread::MsgStartStop::create(), m_inputMessageQueue, and MessageQueue::push().

Referenced by TestMIThread::MsgStartStop::MsgStartStop().

{
    MsgStartStop *msg = MsgStartStop::create(start);
    m_inputMessageQueue.push(msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

startWork()

void TestMIThread::startWork ( )

private

Definition at line 77 of file testmithread.cpp.

References m_elapsedTimer, m_running, m_startWaiter, m_startWaitMutex, m_timer, and tick().

Referenced by handleInputMessages().

{
    m_timer.setTimerType(Qt::PreciseTimer);
    connect(&m_timer, SIGNAL(timeout()), this, SLOT(tick()));
    m_timer.start(50);
    m_startWaitMutex.lock();
    m_elapsedTimer.start();
    start();
    while(!m_running)
        m_startWaiter.wait(&m_startWaitMutex, 100);
    m_startWaitMutex.unlock();
}

Here is the call graph for this function:

Here is the caller graph for this function:

stopWork()

void TestMIThread::stopWork ( )

private

Definition at line 90 of file testmithread.cpp.

References m_running, m_timer, and tick().

Referenced by handleInputMessages().

{
    m_running = false;
    wait();
    m_timer.stop();
    disconnect(&m_timer, SIGNAL(timeout()), this, SLOT(tick()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

tick

void TestMIThread::tick ( )

privateslot

Definition at line 392 of file testmithread.cpp.

References generate(), m_chunksize, m_elapsedTimer, m_mutex, m_running, m_samplerate, m_throttlems, and m_throttleToggle.

Referenced by convert_16(), startWork(), and stopWork().

{
    if (m_running)
    {
        qint64 throttlems = m_elapsedTimer.restart();

        if ((throttlems > 45) && (throttlems < 55) && (throttlems != m_throttlems))
        {
            QMutexLocker mutexLocker(&m_mutex);
            m_throttlems = throttlems;
            m_chunksize = 4 * ((m_samplerate * (m_throttlems+(m_throttleToggle ? 1 : 0))) / 1000);
            m_throttleToggle = !m_throttleToggle;
        }

        generate(m_chunksize);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

m_amModulation

float TestMIThread::m_amModulation

private

Definition at line 99 of file testmithread.h.

Referenced by generate(), and setAMModulation().

m_amplitudeBits

int32_t TestMIThread::m_amplitudeBits

private

Definition at line 113 of file testmithread.h.

Referenced by setAmplitudeBits(), setDCFactor(), setIFactor(), and setQFactor().

m_amplitudeBitsDC

int32_t TestMIThread::m_amplitudeBitsDC

private

Definition at line 118 of file testmithread.h.

Referenced by generate(), setAmplitudeBits(), and setDCFactor().

m_amplitudeBitsI

int32_t TestMIThread::m_amplitudeBitsI

private

Definition at line 119 of file testmithread.h.

Referenced by generate(), setAmplitudeBits(), and setIFactor().

m_amplitudeBitsQ

int32_t TestMIThread::m_amplitudeBitsQ

private

Definition at line 120 of file testmithread.h.

Referenced by generate(), setAmplitudeBits(), and setQFactor().

m_bitShift

uint32_t TestMIThread::m_bitShift

private

Definition at line 112 of file testmithread.h.

Referenced by setBitSize().

m_bitSizeIndex

uint32_t TestMIThread::m_bitSizeIndex

private

Definition at line 111 of file testmithread.h.

Referenced by callback(), and setBitSize().

m_buf

qint16* TestMIThread::m_buf

private

Definition at line 88 of file testmithread.h.

Referenced by generate(), and setBuffers().

m_bufsize

quint32 TestMIThread::m_bufsize

private

Definition at line 89 of file testmithread.h.

Referenced by setBuffers().

m_chunksize

quint32 TestMIThread::m_chunksize

private

Definition at line 90 of file testmithread.h.

Referenced by setSamplerate(), and tick().

m_convertBuffer

SampleVector TestMIThread::m_convertBuffer

private

Definition at line 91 of file testmithread.h.

Referenced by callback(), and setBuffers().

m_dcBias

float TestMIThread::m_dcBias

private

Definition at line 114 of file testmithread.h.

Referenced by setAmplitudeBits(), and setDCFactor().

m_decimators_12

Decimators<qint32, qint16, SDR_RX_SAMP_SZ, 12> TestMIThread::m_decimators_12

private

Definition at line 134 of file testmithread.h.

m_decimators_16

Decimators<qint32, qint16, SDR_RX_SAMP_SZ, 16> TestMIThread::m_decimators_16

private

Definition at line 135 of file testmithread.h.

m_decimators_8

Decimators<qint32, qint16, SDR_RX_SAMP_SZ, 8> TestMIThread::m_decimators_8

private

Definition at line 133 of file testmithread.h.

m_elapsedTimer

QElapsedTimer TestMIThread::m_elapsedTimer

private

Definition at line 127 of file testmithread.h.

Referenced by startWork(), and tick().

m_fcPos

int TestMIThread::m_fcPos

private

Definition at line 110 of file testmithread.h.

Referenced by setFcPos().

m_fcPosShift

int TestMIThread::m_fcPosShift

private

Definition at line 123 of file testmithread.h.

m_fmDeviationUnit

float TestMIThread::m_fmDeviationUnit

private

Definition at line 100 of file testmithread.h.

Referenced by generate(), and setFMDeviation().

m_fmPhasor

float TestMIThread::m_fmPhasor

private

Definition at line 101 of file testmithread.h.

Referenced by generate().

m_frequency

uint64_t TestMIThread::m_frequency

private

Definition at line 122 of file testmithread.h.

m_frequencyShift

int TestMIThread::m_frequencyShift

private

Definition at line 96 of file testmithread.h.

Referenced by setSamplerate().

m_iBias

float TestMIThread::m_iBias

private

Definition at line 115 of file testmithread.h.

Referenced by setAmplitudeBits(), and setIFactor().

m_inputMessageQueue

MessageQueue TestMIThread::m_inputMessageQueue

private

Definition at line 131 of file testmithread.h.

Referenced by handleInputMessages(), and startStop().

m_log2Decim

unsigned int TestMIThread::m_log2Decim

private

Definition at line 109 of file testmithread.h.

Referenced by setLog2Decimation().

m_modulation

TestMIStreamSettings::Modulation TestMIThread::m_modulation

private

Definition at line 98 of file testmithread.h.

Referenced by generate(), and setModulation().

m_mutex

QMutex TestMIThread::m_mutex

private

Definition at line 129 of file testmithread.h.

Referenced by setSamplerate(), and tick().

m_nco

NCOF TestMIThread::m_nco

private

Definition at line 94 of file testmithread.h.

Referenced by generate(), setFrequencyShift(), and setSamplerate().

m_phaseImbalance

float TestMIThread::m_phaseImbalance

private

Definition at line 117 of file testmithread.h.

Referenced by generate(), and setPhaseImbalance().

m_pulsePatternCount

uint32_t TestMIThread::m_pulsePatternCount

private

Definition at line 104 of file testmithread.h.

Referenced by generate(), and setPattern0().

m_pulsePatternCycle

uint32_t TestMIThread::m_pulsePatternCycle

private

Definition at line 105 of file testmithread.h.

Referenced by generate(), and setPattern0().

m_pulsePatternPlaces

uint32_t TestMIThread::m_pulsePatternPlaces

private

Definition at line 106 of file testmithread.h.

Referenced by generate(), and setPattern0().

m_pulseSampleCount

uint32_t TestMIThread::m_pulseSampleCount

private

Definition at line 103 of file testmithread.h.

Referenced by generate(), setPattern0(), setPattern1(), and setPattern2().

m_pulseWidth

uint32_t TestMIThread::m_pulseWidth

private

pulse width in number of samples

Definition at line 102 of file testmithread.h.

Referenced by generate(), setPattern0(), setPattern1(), and setPattern2().

m_qBias

float TestMIThread::m_qBias

private

Definition at line 116 of file testmithread.h.

Referenced by setAmplitudeBits(), and setQFactor().

m_running

volatile bool TestMIThread::m_running

private

Definition at line 86 of file testmithread.h.

Referenced by run(), startWork(), stopWork(), and tick().

m_sampleFifo

SampleSinkFifo* TestMIThread::m_sampleFifo

private

Definition at line 92 of file testmithread.h.

Referenced by callback().

m_samplerate

int TestMIThread::m_samplerate

private

Definition at line 108 of file testmithread.h.

Referenced by setFMDeviation(), setFrequencyShift(), setSamplerate(), setToneFrequency(), and tick().

m_startWaiter

QWaitCondition TestMIThread::m_startWaiter

private

Definition at line 85 of file testmithread.h.

Referenced by run(), and startWork().

m_startWaitMutex

QMutex TestMIThread::m_startWaitMutex

private

Definition at line 84 of file testmithread.h.

Referenced by startWork().

m_streamIndex

int TestMIThread::m_streamIndex

private

Definition at line 93 of file testmithread.h.

m_throttlems

int TestMIThread::m_throttlems

private

Definition at line 125 of file testmithread.h.

Referenced by setSamplerate(), and tick().

m_throttleToggle

bool TestMIThread::m_throttleToggle

private

Definition at line 128 of file testmithread.h.

Referenced by setSamplerate(), and tick().

m_timer

QTimer TestMIThread::m_timer

private

Definition at line 126 of file testmithread.h.

Referenced by startWork(), and stopWork().

m_toneFrequency

int TestMIThread::m_toneFrequency

private

Definition at line 97 of file testmithread.h.

Referenced by setSamplerate().

m_toneNco

NCOF TestMIThread::m_toneNco

private

Definition at line 95 of file testmithread.h.

Referenced by pullAF(), setSamplerate(), and setToneFrequency().

---

The documentation for this class was generated from the following files:

• plugins/samplemimo/testmi/testmithread.h
• plugins/samplemimo/testmi/testmithread.cpp