diff options
| author | David Pi <david.pinho@gmail.com> | 2020-09-23 11:53:32 +0100 |
|---|---|---|
| committer | mormj <34754695+mormj@users.noreply.github.com> | 2020-09-25 06:40:13 -0400 |
| commit | c196dacea56ef938902646a2143907858415b240 (patch) | |
| tree | afb260d0803e14c71971e0d5eec28f70be1939bc /gr-blocks/lib/stream_demux_impl.h | |
| parent | 8f3d61984ecd9ecc97789a174a54c7f0505bddb4 (diff) | |
blocks: New block 'Stream Demux'
Stream demuxing block to demultiplex one stream into N output streams.
Demuxes a stream producing N outputs streams that contains n_0 items in
the first stream, n_1 items in the second, etc. and repeats. Number of
items of each output stream is specified using the 'lengths' parameter
like so [n_0, n_1, ..., n_N-1].
Example:
lengths = [2, 3, 4]
input stream: [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, ...]
output_streams: [0, 1, 9, 10, ...]
[2, 3, 4, 11, ...]
[5, 6, 7, 8, ...]
Diffstat (limited to 'gr-blocks/lib/stream_demux_impl.h')
| -rw-r--r-- | gr-blocks/lib/stream_demux_impl.h | 53 |
1 files changed, 53 insertions, 0 deletions
diff --git a/gr-blocks/lib/stream_demux_impl.h b/gr-blocks/lib/stream_demux_impl.h new file mode 100644 index 0000000000..8fabf5e613 --- /dev/null +++ b/gr-blocks/lib/stream_demux_impl.h @@ -0,0 +1,53 @@ +/* -*- c++ -*- */ +/* + * Copyright 2020 Free Software Foundation, Inc. + * + * This file is part of GNU Radio + * + * GNU Radio is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 3, or (at your option) + * any later version. + * + * GNU Radio is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with GNU Radio; see the file COPYING. If not, write to + * the Free Software Foundation, Inc., 51 Franklin Street, + * Boston, MA 02110-1301, USA. + */ + +#ifndef INCLUDED_BLOCKS_STREAM_DEMUX_IMPL_H +#define INCLUDED_BLOCKS_STREAM_DEMUX_IMPL_H + +#include <gnuradio/blocks/stream_demux.h> + +namespace gr { +namespace blocks { + +class BLOCKS_API stream_demux_impl : public stream_demux +{ +private: + const size_t d_itemsize; + unsigned int d_stream{ 0 }; // index of currently selected stream + int d_residual{ 0 }; // number of items left to put into current stream + const gr_vector_int d_lengths; // number of items to pack per stream + +public: + stream_demux_impl(size_t itemsize, const std::vector<int>& lengths); + + void forecast(int noutput_items, gr_vector_int& ninput_items_required); + + int general_work(int noutput_items, + gr_vector_int& ninput_items, + gr_vector_const_void_star& input_items, + gr_vector_void_star& output_items); +}; + +} // namespace blocks +} // namespace gr + +#endif /* INCLUDED_BLOCKS_STREAM_DEMUX_IMPL_H */ |