summaryrefslogtreecommitdiff
path: root/gr-blocks/lib/streams_to_stream_impl.cc
diff options
context:
space:
mode:
authorMarcus Müller <mmueller@gnuradio.org>2019-08-07 21:45:12 +0200
committerMarcus Müller <marcus@hostalia.de>2019-08-09 23:04:28 +0200
commitf7bbf2c1d8d780294f3e016aff239ca35eb6516e (patch)
treee09ab6112e02b2215b2d59ac24d3d6ea2edac745 /gr-blocks/lib/streams_to_stream_impl.cc
parent78431dc6941e3acc67c858277dfe4a0ed583643c (diff)
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-blocks/lib/streams_to_stream_impl.cc')
-rw-r--r--gr-blocks/lib/streams_to_stream_impl.cc65
1 files changed, 32 insertions, 33 deletions
diff --git a/gr-blocks/lib/streams_to_stream_impl.cc b/gr-blocks/lib/streams_to_stream_impl.cc
index cbd31c4b72..146c456f3e 100644
--- a/gr-blocks/lib/streams_to_stream_impl.cc
+++ b/gr-blocks/lib/streams_to_stream_impl.cc
@@ -28,45 +28,44 @@
#include <gnuradio/io_signature.h>
namespace gr {
- namespace blocks {
+namespace blocks {
- streams_to_stream::sptr streams_to_stream::make(size_t itemsize, size_t nstreams)
- {
- return gnuradio::get_initial_sptr(new streams_to_stream_impl(itemsize, nstreams));
- }
-
- streams_to_stream_impl::streams_to_stream_impl(size_t itemsize, size_t nstreams)
- : sync_interpolator ("streams_to_stream",
- io_signature::make (nstreams, nstreams, itemsize),
- io_signature::make (1, 1, itemsize),
- nstreams)
- {
- }
+streams_to_stream::sptr streams_to_stream::make(size_t itemsize, size_t nstreams)
+{
+ return gnuradio::get_initial_sptr(new streams_to_stream_impl(itemsize, nstreams));
+}
- int
- streams_to_stream_impl::work(int noutput_items,
- gr_vector_const_void_star &input_items,
- gr_vector_void_star &output_items)
- {
- size_t itemsize = output_signature()->sizeof_stream_item (0);
+streams_to_stream_impl::streams_to_stream_impl(size_t itemsize, size_t nstreams)
+ : sync_interpolator("streams_to_stream",
+ io_signature::make(nstreams, nstreams, itemsize),
+ io_signature::make(1, 1, itemsize),
+ nstreams)
+{
+}
- const char **inv = (const char **) &input_items[0];
- char *out = (char *) output_items[0];
- int nstreams = input_items.size();
+int streams_to_stream_impl::work(int noutput_items,
+ gr_vector_const_void_star& input_items,
+ gr_vector_void_star& output_items)
+{
+ size_t itemsize = output_signature()->sizeof_stream_item(0);
- assert (noutput_items % nstreams == 0);
- int ni = noutput_items / nstreams;
+ const char** inv = (const char**)&input_items[0];
+ char* out = (char*)output_items[0];
+ int nstreams = input_items.size();
- for (int i = 0; i < ni; i++){
- for (int j = 0; j < nstreams; j++){
- memcpy(out, inv[j], itemsize);
- out += itemsize;
- inv[j] += itemsize;
- }
- }
+ assert(noutput_items % nstreams == 0);
+ int ni = noutput_items / nstreams;
- return noutput_items;
+ for (int i = 0; i < ni; i++) {
+ for (int j = 0; j < nstreams; j++) {
+ memcpy(out, inv[j], itemsize);
+ out += itemsize;
+ inv[j] += itemsize;
+ }
}
- } /* namespace blocks */
+ return noutput_items;
+}
+
+} /* namespace blocks */
} /* namespace gr */