test_rx.cpp

Go to the documentation of this file.

#include <iostream>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/date_time/gregorian/gregorian.hpp>
#include <boost/program_options.hpp>
#include "receiver.h"

using namespace fun;

void test_rx(double freq, double sample_rate, double rx_gain);
void test_rx_pause(double freq, double rate, double rx_gain);
void process_packets_callback(std::vector<std::vector<unsigned char> > packets);

double freq = 5.72e9;
double sample_rate = 5e6;
//double tx_gain = 30;
double rx_gain = 30;
//double amp = 0.5;
//Rate phy_rate = RATE_1_2_BPSK;

int rx_count = 0; 

int main(int argc, char * argv[]){

    std::cout << "Testing receive chain..." << std::endl;

    test_rx(freq, sample_rate, rx_gain);

//    test_rx_pause(freq, sample_rate, rx_gain);

    return 0;
}


void test_rx(double freq, double sample_rate, double rx_gain)
{

    // Instantiate a usrp
    printf("Instantiating the usrp.\n");

    receiver rx = receiver(&process_packets_callback, freq, sample_rate, rx_gain, "");

    while(1);
}


void test_rx_pause(double freq, double sample_rate, double rx_gain)
{

    // Instantiate a usrp
    printf("Instantiating the usrp.\n");
    receiver rx = receiver(&process_packets_callback, freq, sample_rate, rx_gain, "");

    while(1)
    {
        sleep(4);

        std::cout << "Pausing Receiver for 1 second " << std::endl;
        rx.pause();

        sleep(1);

        std::cout << "Resuming the Receiver" << std::endl;
        rx.resume();

    }
}


void process_packets_callback(std::vector<std::vector<unsigned char> > packets)
{
    rx_count += packets.size();

    boost::posix_time::ptime rx_time = boost::posix_time::microsec_clock::local_time();
    if(packets.size() > 0)
    {
        std::cout << "Received " << rx_count << " packets at " << rx_time.time_of_day() << std::endl;
    }

}