diff --git a/include/ieee802_11/extract_csi.h b/include/ieee802_11/extract_csi.h index 2110bda..a4c0f66 100644 --- a/include/ieee802_11/extract_csi.h +++ b/include/ieee802_11/extract_csi.h @@ -25,17 +25,15 @@ #include namespace gr { - namespace ieee802_11 { +namespace ieee802_11 { - class IEEE802_11_API extract_csi : virtual public gr::sync_block - { - public: - typedef boost::shared_ptr sptr; - static sptr make(); - }; +class IEEE802_11_API extract_csi : virtual public gr::sync_block { +public: + typedef boost::shared_ptr sptr; + static sptr make(); +}; - } // namespace ieee802_11 +} // namespace ieee802_11 } // namespace gr #endif /* INCLUDED_IEEE802_11_EXTRACT_CSI_H */ - diff --git a/lib/extract_csi_impl.cc b/lib/extract_csi_impl.cc index dd2c7a9..71a7e16 100644 --- a/lib/extract_csi_impl.cc +++ b/lib/extract_csi_impl.cc @@ -26,60 +26,53 @@ #include "extract_csi_impl.h" namespace gr { - namespace ieee802_11 { +namespace ieee802_11 { - extract_csi::sptr - extract_csi::make() - { - return gnuradio::get_initial_sptr - (new extract_csi_impl()); - } +extract_csi::sptr extract_csi::make() { + return gnuradio::get_initial_sptr(new extract_csi_impl()); +} - extract_csi_impl::extract_csi_impl() - : gr::sync_block("extract_csi", - gr::io_signature::make(0, 0, 0), - gr::io_signature::make(1, 1, 52 * sizeof(gr_complex))) - { - message_port_register_in(pmt::mp("pdu in")); - } +extract_csi_impl::extract_csi_impl() + : gr::sync_block("extract_csi", gr::io_signature::make(0, 0, 0), + gr::io_signature::make(1, 1, 52 * sizeof(gr_complex))) { + message_port_register_in(pmt::mp("pdu in")); +} - extract_csi_impl::~extract_csi_impl() - { - } +extract_csi_impl::~extract_csi_impl() {} - int - extract_csi_impl::work(int noutput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items) - { - pmt::pmt_t pdu(delete_head_nowait(pmt::mp("pdu in"))); +int extract_csi_impl::work(int noutput_items, + gr_vector_const_void_star &input_items, + gr_vector_void_star &output_items) { + pmt::pmt_t pdu(delete_head_nowait(pmt::mp("pdu in"))); - if (pdu.get() == NULL) return 0; + if (pdu.get() == NULL) + return 0; - if (!pmt::is_pair(pdu) || !pmt::is_dict(pmt::car(pdu))) - throw std::runtime_error("received a malformed pdu message"); + if (!pmt::is_pair(pdu) || !pmt::is_dict(pmt::car(pdu))) + throw std::runtime_error("received a malformed pdu message"); - d_meta = pmt::car(pdu); + d_meta = pmt::car(pdu); - if (!pmt::dict_has_key(d_meta, pmt::mp("csi"))) return 0; + if (!pmt::dict_has_key(d_meta, pmt::mp("csi"))) + return 0; - d_csi = pmt::c32vector_elements(pmt::dict_ref(d_meta, pmt::mp("csi"), pmt::PMT_NIL)); + d_csi = pmt::c32vector_elements( + pmt::dict_ref(d_meta, pmt::mp("csi"), pmt::PMT_NIL)); - gr_complex* out = (gr_complex*) output_items[0]; + gr_complex *out = (gr_complex *)output_items[0]; - std::copy(d_csi.begin(), d_csi.end(), out); + std::copy(d_csi.begin(), d_csi.end(), out); - pmt::pmt_t keys(pmt::dict_keys(d_meta)); - for (int i = 0; i < pmt::length(keys); i++) { - pmt::pmt_t k(pmt::nth(i, keys)); - pmt::pmt_t v(pmt::dict_ref(d_meta, k, pmt::PMT_NIL)); - add_item_tag(0, nitems_written(0), k, v, alias_pmt()); - } + pmt::pmt_t keys(pmt::dict_keys(d_meta)); + for (int i = 0; i < pmt::length(keys); i++) { + pmt::pmt_t k(pmt::nth(i, keys)); + pmt::pmt_t v(pmt::dict_ref(d_meta, k, pmt::PMT_NIL)); + add_item_tag(0, nitems_written(0), k, v, alias_pmt()); + } - return 1; - } + return 1; +} - } /* namespace ieee802_11 */ +} /* namespace ieee802_11 */ } /* namespace gr */ - diff --git a/lib/extract_csi_impl.h b/lib/extract_csi_impl.h index d2b3e5a..930b8c0 100644 --- a/lib/extract_csi_impl.h +++ b/lib/extract_csi_impl.h @@ -24,27 +24,22 @@ #include namespace gr { - namespace ieee802_11 { +namespace ieee802_11 { - class extract_csi_impl : public extract_csi - { - private: - pmt::pmt_t d_meta; - std::vector d_csi; +class extract_csi_impl : public extract_csi { +private: + pmt::pmt_t d_meta; + std::vector d_csi; - public: - extract_csi_impl(); - ~extract_csi_impl(); +public: + extract_csi_impl(); + ~extract_csi_impl(); - int work( - int noutput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items - ); - }; + int work(int noutput_items, gr_vector_const_void_star &input_items, + gr_vector_void_star &output_items); +}; - } // namespace ieee802_11 +} // namespace ieee802_11 } // namespace gr #endif /* INCLUDED_IEEE802_11_EXTRACT_CSI_IMPL_H */ -