receiver.cpp

Go to the documentation of this file.

#include "receiver.h"

namespace fun
{

    receiver::receiver(void (*callback)(std::vector<std::vector<unsigned char> > packets), double freq, double samp_rate, double rx_gain, std::string device_addr) :
        receiver(callback, usrp_params(freq, samp_rate, 20, rx_gain, 1.0, device_addr))
    {
    }

    receiver::receiver(void (*callback)(std::vector<std::vector<unsigned char> > packets), usrp_params params) :
        m_usrp(params),
        m_samples(NUM_RX_SAMPLES),
        m_callback(callback),
        m_rec_chain()
    {
        sem_init(&m_pause, 0, 1); //Initial value is 1 so that the receiver_chain_loop() will begin executing immediately
        m_rec_thread = std::thread(&receiver::receiver_chain_loop, this); //Initialize the main receiver thread
    }

    void receiver::receiver_chain_loop()
    {
        while(1)
        {
            sem_wait(&m_pause); // Block if the receiver is paused

            m_usrp.get_samples(NUM_RX_SAMPLES, m_samples);

            std::vector<std::vector<unsigned char> > packets =
                    m_rec_chain.process_samples(m_samples);

            m_callback(packets);

            sem_post(&m_pause); // Flags the end of this loop and wakes up any other threads waiting on this semaphore
                                // i.e. a call to the pause() function in the main thread.
        }
    }

    void receiver::pause()
    {
        sem_wait(&m_pause);
    }

    void receiver::resume()
    {
        sem_post(&m_pause);
    }
}