3 * Copyright 2006 Free Software Foundation, Inc.
5 * This file is part of GNU Radio
7 * GNU Radio is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License as published by
9 * the Free Software Foundation; either version 3, or (at your option)
12 * GNU Radio is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU General Public License for more details.
17 * You should have received a copy of the GNU General Public License
18 * along with GNU Radio; see the file COPYING. If not, write to
19 * the Free Software Foundation, Inc., 51 Franklin Street,
20 * Boston, MA 02110-1301, USA.
27 #include <gr_stream_mux.h>
28 #include <gr_io_signature.h>
33 gr_make_stream_mux (size_t itemsize, const std::vector<int> &lengths)
35 return gr_stream_mux_sptr (new gr_stream_mux (itemsize, lengths));
38 gr_stream_mux::gr_stream_mux (size_t itemsize, const std::vector<int> &lengths)
39 : gr_block ("stream_mux",
40 gr_make_io_signature (1, -1, itemsize),
41 gr_make_io_signature (1, 1, itemsize)),
47 if(d_lengths[d_stream] == 0) {
50 d_residual = d_lengths[d_stream];
53 gr_stream_mux::~gr_stream_mux(void)
58 gr_stream_mux::forecast (int noutput_items, gr_vector_int &ninput_items_required)
60 unsigned ninputs = ninput_items_required.size ();
61 for (unsigned i = 0; i < ninputs; i++)
62 ninput_items_required[i] = (d_lengths[i] == 0 ? 0 : 1);
65 void gr_stream_mux::increment_stream()
68 d_stream = (d_stream+1) % d_lengths.size();
69 } while(d_lengths[d_stream] == 0);
71 d_residual = d_lengths[d_stream];
75 gr_stream_mux::general_work(int noutput_items,
76 gr_vector_int &ninput_items,
77 gr_vector_const_void_star &input_items,
78 gr_vector_void_star &output_items)
80 char *out = (char *) output_items[0];
83 std::vector<int> input_index(d_lengths.size(), 0);
86 printf("mux: nouput_items: %d d_stream: %d\n", noutput_items, d_stream);
87 for(size_t i = 0; i < d_lengths.size(); i++)
88 printf("\tninput_items[%d]: %d\n", i, ninput_items[i]);
92 int r = std::min(noutput_items - out_index,
94 ninput_items[d_stream] - input_index[d_stream]));
96 printf("mux: r=%d\n", r);
97 printf("\tnoutput_items - out_index: %d\n",
98 noutput_items - out_index);
99 printf("\td_residual: %d\n",
101 printf("\tninput_items[d_stream] - input_index[d_stream]: %d\n",
102 ninput_items[d_stream] - input_index[d_stream]);
109 in = (const char *) input_items[d_stream] + input_index[d_stream]*d_itemsize;
111 memcpy(&out[out_index*d_itemsize], in, r*d_itemsize);
113 input_index[d_stream] += r;
116 consume(d_stream, r);
118 if(d_residual == 0) {