diff options
Diffstat (limited to 'lib/bladerf/bladerf_sink_c.h')
| -rw-r--r-- | lib/bladerf/bladerf_sink_c.h | 73 |
1 files changed, 43 insertions, 30 deletions
diff --git a/lib/bladerf/bladerf_sink_c.h b/lib/bladerf/bladerf_sink_c.h index e76f0ec..fc5b02c 100644 --- a/lib/bladerf/bladerf_sink_c.h +++ b/lib/bladerf/bladerf_sink_c.h @@ -21,14 +21,12 @@ #ifndef INCLUDED_BLADERF_SINK_C_H #define INCLUDED_BLADERF_SINK_C_H -#include <gnuradio/thread/thread.h> -#include <gnuradio/block.h> #include <gnuradio/sync_block.h> - -#include "osmosdr/ranges.h" #include "sink_iface.h" #include "bladerf_common.h" +#include "osmosdr/ranges.h" + class bladerf_sink_c; /* @@ -42,7 +40,7 @@ class bladerf_sink_c; * * As a convention, the _sptr suffix indicates a boost::shared_ptr */ -typedef boost::shared_ptr < bladerf_sink_c > bladerf_sink_c_sptr; +typedef boost::shared_ptr<bladerf_sink_c> bladerf_sink_c_sptr; /*! * \brief Return a shared_ptr to a new instance of bladerf_sink_c. @@ -53,25 +51,28 @@ typedef boost::shared_ptr < bladerf_sink_c > bladerf_sink_c_sptr; */ bladerf_sink_c_sptr make_bladerf_sink_c(const std::string &args = ""); -class bladerf_sink_c:public gr::sync_block, - public sink_iface, protected bladerf_common +class bladerf_sink_c : + public gr::sync_block, + public sink_iface, + protected bladerf_common { private: // The friend declaration allows bladerf_make_sink_c to // access the private constructor. friend bladerf_sink_c_sptr make_bladerf_sink_c(const std::string &args); - bladerf_sink_c(const std::string &args); // private constructor - - // Transmit converted samples stored in _conv_buf, applying SOB and EOB - // based upon the provided tags - // - // Returns bladeRF error code - int transmit_with_tags(int noutput_items); + bladerf_sink_c(const std::string &args); - bool _in_burst; + bool is_antenna_valid(const std::string &antenna); public: + std::string name(); + + static std::vector<std::string> get_devices(); + + size_t get_max_channels(void); + size_t get_num_channels(void); + bool start(); bool stop(); @@ -79,10 +80,6 @@ public: gr_vector_const_void_star &input_items, gr_vector_void_star &output_items); - static std::vector < std::string > get_devices(); - - size_t get_num_channels(void); - osmosdr::meta_range_t get_sample_rates(void); double set_sample_rate(double rate); double get_sample_rate(void); @@ -94,10 +91,10 @@ public: double set_freq_corr(double ppm, size_t chan = 0); double get_freq_corr(size_t chan = 0); - std::vector < std::string > get_gain_names(size_t chan = 0); + std::vector<std::string> get_gain_names(size_t chan = 0); osmosdr::gain_range_t get_gain_range(size_t chan = 0); - osmosdr::gain_range_t get_gain_range(const std::string &name, size_t chan = - 0); + osmosdr::gain_range_t get_gain_range(const std::string &name, + size_t chan = 0); bool set_gain_mode(bool automatic, size_t chan = 0); bool get_gain_mode(size_t chan = 0); double set_gain(double gain, size_t chan = 0); @@ -105,20 +102,36 @@ public: double get_gain(size_t chan = 0); double get_gain(const std::string &name, size_t chan = 0); - std::vector < std::string > get_antennas(size_t chan = 0); + std::vector<std::string> get_antennas(size_t chan = 0); std::string set_antenna(const std::string &antenna, size_t chan = 0); std::string get_antenna(size_t chan = 0); - void set_dc_offset(const std::complex < double > &offset, size_t chan); - void set_iq_balance(const std::complex < double > &balance, size_t chan); + void set_dc_offset(const std::complex<double> &offset, size_t chan); + void set_iq_balance(const std::complex<double> &balance, size_t chan); + osmosdr::freq_range_t get_bandwidth_range(size_t chan = 0); double set_bandwidth(double bandwidth, size_t chan = 0); double get_bandwidth(size_t chan = 0); - osmosdr::freq_range_t get_bandwidth_range(size_t chan = 0); - void set_clock_source(const std::string &source, const size_t mboard = 0); - std::string get_clock_source(const size_t mboard); - std::vector < std::string > get_clock_sources(const size_t mboard); + std::vector<std::string> get_clock_sources(size_t mboard); + void set_clock_source(const std::string &source, size_t mboard = 0); + std::string get_clock_source(size_t mboard); + +private: + int transmit_with_tags(int16_t const *samples, int noutput_items); + + // Sample-handling buffers + int16_t *_16icbuf; /**< raw samples to bladeRF */ + gr_complex *_32fcbuf; /**< intermediate buffer for conversions */ + + bool _in_burst; /**< are we currently in a burst? */ + bool _running; /**< is the sink running? */ + bladerf_channel_layout _layout; /**< channel layout */ + + gr::thread::mutex d_mutex; /**< mutex to protect set/work access */ + + /* Scaling factor used when converting from float to int16_t */ + const float SCALING_FACTOR = 2048.0f; }; -#endif /* INCLUDED_BLADERF_SINK_C_H */ +#endif // INCLUDED_BLADERF_SINK_C_H |