BladeRF2InputThread Class Reference

#include <bladerf2inputthread.h>

Inherits QThread.

Collaboration diagram for BladeRF2InputThread:

Classes
struct	Channel

Public Member Functions
	BladeRF2InputThread (struct bladerf *dev, unsigned int nbRxChannels, QObject *parent=NULL)
	~BladeRF2InputThread ()
void	startWork ()
void	stopWork ()
bool	isRunning () const
unsigned int	getNbChannels () const
void	setLog2Decimation (unsigned int channel, unsigned int log2_decim)
unsigned int	getLog2Decimation (unsigned int channel) const
void	setFcPos (unsigned int channel, int fcPos)
int	getFcPos (unsigned int channel) const
void	setFifo (unsigned int channel, SampleSinkFifo *sampleFifo)
SampleSinkFifo *	getFifo (unsigned int channel)

Private Member Functions
void	run ()
unsigned int	getNbFifos ()
void	callbackSI (const qint16 *buf, qint32 len, unsigned int channel=0)
void	callbackMI (const qint16 *buf, qint32 samplesPerChannel)

Private Attributes
QMutex	m_startWaitMutex
QWaitCondition	m_startWaiter
bool	m_running
struct bladerf *	m_dev
Channel *	m_channels
	Array of channels dynamically allocated for the given number of Rx channels. More...
qint16 *	m_buf
	Full buffer for SISO or MIMO operation. More...
unsigned int	m_nbChannels

Detailed Description

Definition at line 37 of file bladerf2inputthread.h.

Constructor & Destructor Documentation

BladeRF2InputThread()

BladeRF2InputThread::BladeRF2InputThread	(	struct bladerf *	dev,
		unsigned int	nbRxChannels,
		QObject *	parent = NULL
	)

Definition at line 22 of file bladerf2inputthread.cpp.

References DeviceBladeRF2::blockSize, i, m_buf, m_channels, and BladeRF2InputThread::Channel::m_convertBuffer.

                                                                                                        :
    QThread(parent),
    m_running(false),
    m_dev(dev),
    m_nbChannels(nbRxChannels)
{
    qDebug("BladeRF2InputThread::BladeRF2InputThread");
    m_channels = new Channel[nbRxChannels];

    for (unsigned int i = 0; i < nbRxChannels; i++) {
        m_channels[i].m_convertBuffer.resize(DeviceBladeRF2::blockSize, Sample{0,0});
    }

    m_buf = new qint16[2*DeviceBladeRF2::blockSize*nbRxChannels];
}

~BladeRF2InputThread()

BladeRF2InputThread::~BladeRF2InputThread

(

)

Definition at line 38 of file bladerf2inputthread.cpp.

References m_buf, m_channels, m_running, and stopWork().

{
    qDebug("BladeRF2InputThread::~BladeRF2InputThread");

    if (m_running) {
        stopWork();
    }

    delete[] m_buf;
    delete[] m_channels;
}

Here is the call graph for this function:

Member Function Documentation

callbackMI()

void BladeRF2InputThread::callbackMI ( const qint16 *  buf, qint32  samplesPerChannel  )

private

Definition at line 188 of file bladerf2inputthread.cpp.

References callbackSI(), m_channels, and m_nbChannels.

Referenced by run().

{
    // TODO: write a set of decimators that can take interleaved samples in input directly
    int status = bladerf_deinterleave_stream_buffer(BLADERF_RX_X2, BLADERF_FORMAT_SC16_Q11 , samplesPerChannel*m_nbChannels, (void *) buf);

    if (status < 0)
    {
        qCritical("BladeRF2InputThread::callbackMI: cannot de-interleave buffer: %s", bladerf_strerror(status));
        return;
    }

    for (unsigned int channel = 0; channel < m_nbChannels; channel++)
    {
        if (m_channels[channel].m_sampleFifo) {
            callbackSI(&buf[2*samplesPerChannel*channel], 2*samplesPerChannel, channel);
        }
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

callbackSI()

void BladeRF2InputThread::callbackSI ( const qint16 *  buf, qint32  len, unsigned int  channel = 0  )

private

Definition at line 207 of file bladerf2inputthread.cpp.

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(), m_channels, BladeRF2InputThread::Channel::m_convertBuffer, BladeRF2InputThread::Channel::m_decimators, BladeRF2InputThread::Channel::m_sampleFifo, and SampleSinkFifo::write().

Referenced by callbackMI(), and run().

{
    SampleVector::iterator it = m_channels[channel].m_convertBuffer.begin();

    if (m_channels[channel].m_log2Decim == 0)
    {
        m_channels[channel].m_decimators.decimate1(&it, buf, len);
    }
    else
    {
        if (m_channels[channel].m_fcPos == 0) // Infra
        {
            switch (m_channels[channel].m_log2Decim)
            {
            case 1:
                m_channels[channel].m_decimators.decimate2_inf(&it, buf, len);
                break;
            case 2:
                m_channels[channel].m_decimators.decimate4_inf(&it, buf, len);
                break;
            case 3:
                m_channels[channel].m_decimators.decimate8_inf(&it, buf, len);
                break;
            case 4:
                m_channels[channel].m_decimators.decimate16_inf(&it, buf, len);
                break;
            case 5:
                m_channels[channel].m_decimators.decimate32_inf(&it, buf, len);
                break;
            case 6:
                m_channels[channel].m_decimators.decimate64_inf(&it, buf, len);
                break;
            default:
                break;
            }
        }
        else if (m_channels[channel].m_fcPos == 1) // Supra
        {
            switch (m_channels[channel].m_log2Decim)
            {
            case 1:
                m_channels[channel].m_decimators.decimate2_sup(&it, buf, len);
                break;
            case 2:
                m_channels[channel].m_decimators.decimate4_sup(&it, buf, len);
                break;
            case 3:
                m_channels[channel].m_decimators.decimate8_sup(&it, buf, len);
                break;
            case 4:
                m_channels[channel].m_decimators.decimate16_sup(&it, buf, len);
                break;
            case 5:
                m_channels[channel].m_decimators.decimate32_sup(&it, buf, len);
                break;
            case 6:
                m_channels[channel].m_decimators.decimate64_sup(&it, buf, len);
                break;
            default:
                break;
            }
        }
        else if (m_channels[channel].m_fcPos == 2) // Center
        {
            switch (m_channels[channel].m_log2Decim)
            {
            case 1:
                m_channels[channel].m_decimators.decimate2_cen(&it, buf, len);
                break;
            case 2:
                m_channels[channel].m_decimators.decimate4_cen(&it, buf, len);
                break;
            case 3:
                m_channels[channel].m_decimators.decimate8_cen(&it, buf, len);
                break;
            case 4:
                m_channels[channel].m_decimators.decimate16_cen(&it, buf, len);
                break;
            case 5:
                m_channels[channel].m_decimators.decimate32_cen(&it, buf, len);
                break;
            case 6:
                m_channels[channel].m_decimators.decimate64_cen(&it, buf, len);
                break;
            default:
                break;
            }
        }
    }

    m_channels[channel].m_sampleFifo->write(m_channels[channel].m_convertBuffer.begin(), it);
}

Here is the call graph for this function:

Here is the caller graph for this function:

getFcPos()

int BladeRF2InputThread::getFcPos

(

unsigned int

channel

)

const

Definition at line 163 of file bladerf2inputthread.cpp.

References m_channels, BladeRF2InputThread::Channel::m_fcPos, and m_nbChannels.

Referenced by getNbChannels(), BladeRF2Input::start(), and BladeRF2Input::stop().

{
    if (channel < m_nbChannels) {
        return m_channels[channel].m_fcPos;
    } else {
        return 0;
    }
}

Here is the caller graph for this function:

getFifo()

SampleSinkFifo * BladeRF2InputThread::getFifo

(

unsigned int

channel

)

Definition at line 179 of file bladerf2inputthread.cpp.

References m_channels, m_nbChannels, and BladeRF2InputThread::Channel::m_sampleFifo.

Referenced by getNbChannels(), BladeRF2Input::start(), and BladeRF2Input::stop().

{
    if (channel < m_nbChannels) {
        return m_channels[channel].m_sampleFifo;
    } else {
        return 0;
    }
}

Here is the caller graph for this function:

getLog2Decimation()

unsigned int BladeRF2InputThread::getLog2Decimation

(

unsigned int

channel

)

const

Definition at line 147 of file bladerf2inputthread.cpp.

References m_channels, BladeRF2InputThread::Channel::m_log2Decim, and m_nbChannels.

Referenced by getNbChannels(), BladeRF2Input::start(), and BladeRF2Input::stop().

{
    if (channel < m_nbChannels) {
        return m_channels[channel].m_log2Decim;
    } else {
        return 0;
    }
}

Here is the caller graph for this function:

getNbChannels()

unsigned int BladeRF2InputThread::getNbChannels ( ) const

inline

Definition at line 47 of file bladerf2inputthread.h.

References getFcPos(), getFifo(), getLog2Decimation(), m_nbChannels, setFcPos(), setFifo(), and setLog2Decimation().

Referenced by BladeRF2Input::start(), and BladeRF2Input::stop().

{ return m_nbChannels; }

Here is the call graph for this function:

Here is the caller graph for this function:

getNbFifos()

unsigned int BladeRF2InputThread::getNbFifos ( )

private

Definition at line 126 of file bladerf2inputthread.cpp.

References i, m_channels, and m_nbChannels.

Referenced by run().

{
    unsigned int fifoCount = 0;

    for (unsigned int i = 0; i < m_nbChannels; i++)
    {
        if (m_channels[i].m_sampleFifo) {
            fifoCount++;
        }
    }

    return fifoCount;
}

Here is the caller graph for this function:

isRunning()

bool BladeRF2InputThread::isRunning ( ) const

inline

Definition at line 46 of file bladerf2inputthread.h.

References m_running.

{ return m_running; }

run()

void BladeRF2InputThread::run ( )

private

Definition at line 68 of file bladerf2inputthread.cpp.

References DeviceBladeRF2::blockSize, callbackMI(), callbackSI(), getNbFifos(), m_buf, m_dev, m_nbChannels, m_running, and m_startWaiter.

{
    int res;

    m_running = true;
    m_startWaiter.wakeAll();

    unsigned int nbFifos = getNbFifos();

    if ((m_nbChannels > 0) && (nbFifos > 0))
    {
        int status;

        if (m_nbChannels > 1) {
            status = bladerf_sync_config(m_dev, BLADERF_RX_X2, BLADERF_FORMAT_SC16_Q11, 64, 8192, 32, 10000);
        } else {
            status = bladerf_sync_config(m_dev, BLADERF_RX_X1, BLADERF_FORMAT_SC16_Q11, 64, 8192, 32, 10000);
        }

        if (status < 0)
        {
            qCritical("BladeRF2InputThread::run: cannot configure streams: %s", bladerf_strerror(status));
        }
        else
        {
            qDebug("BladeRF2InputThread::run: start running loop");
            while (m_running)
            {
                if (m_nbChannels > 1) {
                    res = bladerf_sync_rx(m_dev, m_buf, DeviceBladeRF2::blockSize*m_nbChannels, NULL, 10000);
                } else {
                    res = bladerf_sync_rx(m_dev, m_buf, DeviceBladeRF2::blockSize, NULL, 10000);
                }

                if (res < 0)
                {
                    qCritical("BladeRF2InputThread::run sync Rx error: %s", bladerf_strerror(res));
                    break;
                }

                if (m_nbChannels > 1) {
                    callbackMI(m_buf, DeviceBladeRF2::blockSize);
                } else {
                    callbackSI(m_buf, 2*DeviceBladeRF2::blockSize);
                }
            }
            qDebug("BladeRF2InputThread::run: stop running loop");
        }
    }
    else
    {
        qWarning("BladeRF2InputThread::run: no channels or FIFO allocated. Aborting");
    }


    m_running = false;
}

Here is the call graph for this function:

setFcPos()

void BladeRF2InputThread::setFcPos	(	unsigned int	channel,
		int	fcPos
	)

Definition at line 156 of file bladerf2inputthread.cpp.

References m_channels, BladeRF2InputThread::Channel::m_fcPos, and m_nbChannels.

Referenced by BladeRF2Input::applySettings(), getNbChannels(), BladeRF2Input::handleMessage(), BladeRF2Input::start(), and BladeRF2Input::stop().

{
    if (channel < m_nbChannels) {
        m_channels[channel].m_fcPos = fcPos;
    }
}

Here is the caller graph for this function:

setFifo()

void BladeRF2InputThread::setFifo	(	unsigned int	channel,
		SampleSinkFifo *	sampleFifo
	)

Definition at line 172 of file bladerf2inputthread.cpp.

References m_channels, m_nbChannels, and BladeRF2InputThread::Channel::m_sampleFifo.

Referenced by getNbChannels(), BladeRF2Input::start(), and BladeRF2Input::stop().

{
    if (channel < m_nbChannels) {
        m_channels[channel].m_sampleFifo = sampleFifo;
    }
}

Here is the caller graph for this function:

setLog2Decimation()

void BladeRF2InputThread::setLog2Decimation	(	unsigned int	channel,
		unsigned int	log2_decim
	)

Definition at line 140 of file bladerf2inputthread.cpp.

References m_channels, BladeRF2InputThread::Channel::m_log2Decim, and m_nbChannels.

Referenced by BladeRF2Input::applySettings(), getNbChannels(), BladeRF2Input::start(), and BladeRF2Input::stop().

{
    if (channel < m_nbChannels) {
        m_channels[channel].m_log2Decim = log2_decim;
    }
}

Here is the caller graph for this function:

startWork()

void BladeRF2InputThread::startWork

(

)

Definition at line 50 of file bladerf2inputthread.cpp.

References m_running, m_startWaiter, and m_startWaitMutex.

Referenced by BladeRF2Input::start(), and BladeRF2Input::stop().

{
    m_startWaitMutex.lock();
    start();

    while(!m_running) {
        m_startWaiter.wait(&m_startWaitMutex, 100);
    }

    m_startWaitMutex.unlock();
}

Here is the caller graph for this function:

stopWork()

void BladeRF2InputThread::stopWork

(

)

Definition at line 62 of file bladerf2inputthread.cpp.

References m_running.

Referenced by BladeRF2Input::start(), BladeRF2Input::stop(), and ~BladeRF2InputThread().

{
    m_running = false;
    wait();
}

Here is the caller graph for this function:

Member Data Documentation

m_buf

qint16* BladeRF2InputThread::m_buf

private

Full buffer for SISO or MIMO operation.

Definition at line 80 of file bladerf2inputthread.h.

Referenced by BladeRF2InputThread(), run(), and ~BladeRF2InputThread().

m_channels

Channel* BladeRF2InputThread::m_channels

private

Array of channels dynamically allocated for the given number of Rx channels.

Definition at line 79 of file bladerf2inputthread.h.

Referenced by BladeRF2InputThread(), callbackMI(), callbackSI(), getFcPos(), getFifo(), getLog2Decimation(), getNbFifos(), setFcPos(), setFifo(), setLog2Decimation(), and ~BladeRF2InputThread().

m_dev

struct bladerf* BladeRF2InputThread::m_dev

private

Definition at line 77 of file bladerf2inputthread.h.

Referenced by run().

m_nbChannels

unsigned int BladeRF2InputThread::m_nbChannels

private

Definition at line 81 of file bladerf2inputthread.h.

Referenced by callbackMI(), getFcPos(), getFifo(), getLog2Decimation(), getNbChannels(), getNbFifos(), run(), setFcPos(), setFifo(), and setLog2Decimation().

m_running

bool BladeRF2InputThread::m_running

private

Definition at line 76 of file bladerf2inputthread.h.

Referenced by isRunning(), run(), startWork(), stopWork(), and ~BladeRF2InputThread().

m_startWaiter

QWaitCondition BladeRF2InputThread::m_startWaiter

private

Definition at line 75 of file bladerf2inputthread.h.

Referenced by run(), and startWork().

m_startWaitMutex

QMutex BladeRF2InputThread::m_startWaitMutex

private

Definition at line 74 of file bladerf2inputthread.h.

Referenced by startWork().

---

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

• plugins/samplesource/bladerf2input/bladerf2inputthread.h
• plugins/samplesource/bladerf2input/bladerf2inputthread.cpp