From f7bbf2c1d8d780294f3e016aff239ca35eb6516e Mon Sep 17 00:00:00 2001
From: Marcus Müller <mmueller@gnuradio.org>
Date: Wed, 7 Aug 2019 21:45:12 +0200
Subject: Tree: clang-format without the include sorting
---
gr-blocks/lib/annotator_alltoall_impl.cc | 137 +++++++++++++++----------------
1 file changed, 66 insertions(+), 71 deletions(-)
(limited to 'gr-blocks/lib/annotator_alltoall_impl.cc')
diff --git a/gr-blocks/lib/annotator_alltoall_impl.cc b/gr-blocks/lib/annotator_alltoall_impl.cc
index afc60d0acb..8eeb7625e0 100644
--- a/gr-blocks/lib/annotator_alltoall_impl.cc
+++ b/gr-blocks/lib/annotator_alltoall_impl.cc
@@ -31,45 +31,40 @@
#include <iomanip>
namespace gr {
- namespace blocks {
-
- annotator_alltoall::sptr
- annotator_alltoall::make(int when, size_t sizeof_stream_item)
- {
- return gnuradio::get_initial_sptr
- (new annotator_alltoall_impl(when, sizeof_stream_item));
- }
-
- annotator_alltoall_impl::annotator_alltoall_impl(int when,
- size_t sizeof_stream_item)
- : sync_block("annotator_alltoall",
- io_signature::make(1, -1, sizeof_stream_item),
- io_signature::make(1, -1, sizeof_stream_item)),
- d_when((uint64_t)when)
- {
- set_tag_propagation_policy(TPP_ALL_TO_ALL);
-
- d_tag_counter = 0;
- }
-
- annotator_alltoall_impl::~annotator_alltoall_impl()
- {
- }
-
- int
- annotator_alltoall_impl::work(int noutput_items,
- gr_vector_const_void_star &input_items,
- gr_vector_void_star &output_items)
- {
- const float *in = (const float*)input_items[0];
- float *out = (float*)output_items[0];
-
- std::stringstream str;
- str << name() << unique_id();
-
- uint64_t abs_N = 0, end_N;
- int ninputs = input_items.size();
- for(int i = 0; i < ninputs; i++) {
+namespace blocks {
+
+annotator_alltoall::sptr annotator_alltoall::make(int when, size_t sizeof_stream_item)
+{
+ return gnuradio::get_initial_sptr(
+ new annotator_alltoall_impl(when, sizeof_stream_item));
+}
+
+annotator_alltoall_impl::annotator_alltoall_impl(int when, size_t sizeof_stream_item)
+ : sync_block("annotator_alltoall",
+ io_signature::make(1, -1, sizeof_stream_item),
+ io_signature::make(1, -1, sizeof_stream_item)),
+ d_when((uint64_t)when)
+{
+ set_tag_propagation_policy(TPP_ALL_TO_ALL);
+
+ d_tag_counter = 0;
+}
+
+annotator_alltoall_impl::~annotator_alltoall_impl() {}
+
+int annotator_alltoall_impl::work(int noutput_items,
+ gr_vector_const_void_star& input_items,
+ gr_vector_void_star& output_items)
+{
+ const float* in = (const float*)input_items[0];
+ float* out = (float*)output_items[0];
+
+ std::stringstream str;
+ str << name() << unique_id();
+
+ uint64_t abs_N = 0, end_N;
+ int ninputs = input_items.size();
+ for (int i = 0; i < ninputs; i++) {
abs_N = nitems_read(i);
end_N = abs_N + (uint64_t)(noutput_items);
@@ -77,41 +72,41 @@ namespace gr {
get_tags_in_range(all_tags, i, abs_N, end_N);
std::vector<tag_t>::iterator itr;
- for(itr = all_tags.begin(); itr != all_tags.end(); itr++) {
- d_stored_tags.push_back(*itr);
+ for (itr = all_tags.begin(); itr != all_tags.end(); itr++) {
+ d_stored_tags.push_back(*itr);
}
- }
-
- // Source ID and key for any tag that might get applied from this block
- pmt::pmt_t srcid = pmt::string_to_symbol(str.str());
- pmt::pmt_t key = pmt::string_to_symbol("seq");
-
- // Work does nothing to the data stream; just copy all inputs to
- // outputs Adds a new tag when the number of items read is a
- // multiple of d_when
- abs_N = nitems_written(0);
- int noutputs = output_items.size();
-
- for(int j = 0; j < noutput_items; j++) {
- for(int i = 0; i < noutputs; i++) {
- if(abs_N % d_when == 0) {
- pmt::pmt_t value = pmt::from_uint64(d_tag_counter++);
- add_item_tag(i, abs_N, key, value, srcid);
- }
-
- // Sum all of the inputs together for each output. Just 'cause.
- out = (float*)output_items[i];
- out[j] = 0;
- for(int ins = 0; ins < ninputs; ins++) {
- in = (const float*)input_items[ins];
- out[j] += in[j];
- }
+ }
+
+ // Source ID and key for any tag that might get applied from this block
+ pmt::pmt_t srcid = pmt::string_to_symbol(str.str());
+ pmt::pmt_t key = pmt::string_to_symbol("seq");
+
+ // Work does nothing to the data stream; just copy all inputs to
+ // outputs Adds a new tag when the number of items read is a
+ // multiple of d_when
+ abs_N = nitems_written(0);
+ int noutputs = output_items.size();
+
+ for (int j = 0; j < noutput_items; j++) {
+ for (int i = 0; i < noutputs; i++) {
+ if (abs_N % d_when == 0) {
+ pmt::pmt_t value = pmt::from_uint64(d_tag_counter++);
+ add_item_tag(i, abs_N, key, value, srcid);
+ }
+
+ // Sum all of the inputs together for each output. Just 'cause.
+ out = (float*)output_items[i];
+ out[j] = 0;
+ for (int ins = 0; ins < ninputs; ins++) {
+ in = (const float*)input_items[ins];
+ out[j] += in[j];
+ }
}
abs_N++;
- }
-
- return noutput_items;
}
- } /* namespace blocks */
+ return noutput_items;
+}
+
+} /* namespace blocks */
} /* namespace gr */
--
cgit v1.2.3