BaseRadioSet.h

Go to the documentation of this file.

#include <SoapySDR/Device.hpp>
#include <chrono>
#include <complex>
#include <csignal>
#include <cstddef>
#include <cstdint>
#include <cstdlib>
#include <fstream>
#include <iostream>
#include <string>
 
#include "config.h"
 
class Radio;
 
class BaseRadioSet {
 public:
  BaseRadioSet(Config* cfg);
  ~BaseRadioSet(void);
  void radioTx(const void* const* buffs);
  void radioRx(void* const* buffs);
  int radioTx(size_t radio_id, size_t cell_id, const void* const* buffs,
              int flags, long long& frameTime);
  int radioRx(size_t radio_id, size_t cell_id, void* const* buffs,
              long long& frameTime);
  int radioRx(size_t radio_id, size_t cell_id, void* const* buffs, int numSamps,
              long long& frameTime);
  void radioStart(void);
  void radioStop(void);
  bool getRadioNotFound() { return radioNotFound; }
 
 private:
  // use for create pthread
  struct BaseRadioContext {
    BaseRadioSet* brs;
    std::atomic_ulong* thread_count;
    size_t tid;
    size_t cell;
  };
  void init(BaseRadioContext* context);
  void configure(BaseRadioContext* context);
 
  static void* init_launch(void* in_context);
  static void* configure_launch(void* in_context);
 
  void radioTrigger(void);
  void sync_delays(size_t cellIdx);
  SoapySDR::Device* baseRadio(size_t cellId);
  void collectCSI(bool&);
  void dciqCalibrationProc(size_t);
  void readSensors(void);
 
  Config* _cfg;
  std::vector<SoapySDR::Device*> hubs;
  std::vector<std::vector<Radio*>> bsRadios;  // [cell, iris]
  bool radioNotFound;
};