agora-doxy/html/radio__soapysdr_8h_source.html

#ifndef RADIO_SOAPYSDR_H_

#define RADIO_SOAPYSDR_H_


#include <memory>


#include "SoapySDR/Device.hpp"

#include "config.h"

#include "radio.h"

#include "radio_data_plane.h"


class RadioSoapySdr : public Radio {

 public:

  explicit RadioSoapySdr(RadioDataPlane::DataPlaneType rx_dp_type);

  ~RadioSoapySdr() final;


  void Init(const Config* cfg, size_t id, const std::string& serial,

            const std::vector<size_t>& enabled_channels, bool hw_framer) final;

  void Setup(const std::vector<double>& tx_gains,

             const std::vector<double>& rx_gains) final;

  void Activate(Radio::ActivationTypes type = Radio::ActivationTypes::kActivate,

                long long act_time_ns = 0, size_t samples = 0) final;

  void Deactivate() final;

  void Close() final;

  void Flush() final;


  int Tx(const void* const* tx_buffs, size_t tx_size, Radio::TxFlags tx_flags,

         long long& tx_time_ns) final;


  int Rx(std::vector<std::vector<std::complex<int16_t>>>& rx_data,

         size_t rx_size, RxFlags& out_flags, long long& rx_time_ns) final;


  int Rx(std::vector<std::vector<std::complex<int16_t>>*>& rx_buffs,

         size_t rx_size, RxFlags& out_flags, long long& rx_time_ns) final;


  int Rx(std::vector<void*>& rx_locs, size_t rx_size, RxFlags& out_flags,

         long long& rx_time_ns) final;


  void SetTimeAtTrigger(long long time_ns = 0) final;

  long long GetTimeNs() final;

  //End of generic interface


  void ConfigureTddModeBs(bool is_ref_radio) final;

  void ConfigureTddModeUe() final;

  void ClearSyncDelay() final;

  void PrintSettings() const final;

  void Trigger() final;

  void ReadSensor() const final;

  void AdjustDelay(const std::string& delay) final;


  // Calibration helper functions

  void InitRefTx(size_t channel, double freq);

  void InitCalRx(size_t channel, double center_freq);

  void ResetTxGains();

  void ResetRxGains();

  void SetTxCalGain(size_t channel);

  void SetRxGain(size_t channel, const std::string& gain_stage, double value);

  void SetTxGain(size_t channel, const std::string& gain_stage, double value);

  void StartRefTx(size_t channel);

  void StopRefTx(size_t channel);

  void SetDcOffset(int direction, size_t channel, std::complex<double> dc_corr);

  void SetIQBalance(int direction, size_t channel,

                    std::complex<double> i_qcorr);

  //Sets both tx and rx, is this ok?

  void SetFreqBb(size_t channel, double freq);

  void SetFreqRf(size_t channel, double freq);

  //End Calibration Routines

  void InitAgc(bool enabled, size_t setting);


  std::vector<std::complex<float>> SnoopSamples(size_t channel,

                                                size_t read_size);


  inline SoapySDR::Device* SoapyDevice() const { return dev_; }

  inline const std::string& IpAddress() const { return ip_address_; }


 private:

  void Correlator(bool enable);


  SoapySDR::Device* dev_;

  std::string ip_address_;

  std::unique_ptr<RadioDataPlane> rxp_;

  SoapySDR::Stream* txs_;

  bool correlator_enabled_;

};


#endif  // RADIO_SOAPYSDR_H_