Imported Upstream version 3.2.2
[debian/gnuradio] / gnuradio-core / src / lib / io / gr_oscope_sink_f.cc
1 /* -*- c++ -*- */
2 /*
3  * Copyright 2003,2004,2005 Free Software Foundation, Inc.
4  * 
5  * This file is part of GNU Radio
6  * 
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)
10  * any later version.
11  * 
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.
16  * 
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.
21  */
22
23 #ifdef HAVE_CONFIG_H
24 #include "config.h"
25 #endif
26
27 #include <gr_oscope_sink_f.h>
28 #include <gr_io_signature.h>
29 #include <gr_oscope_guts.h>
30
31
32 gr_oscope_sink_f_sptr
33 gr_make_oscope_sink_f (double sampling_rate, gr_msg_queue_sptr msgq)
34 {
35   return gr_oscope_sink_f_sptr (new gr_oscope_sink_f (sampling_rate, msgq));
36 }
37
38
39 gr_oscope_sink_f::gr_oscope_sink_f (double sampling_rate, gr_msg_queue_sptr msgq)
40   : gr_oscope_sink_x ("oscope_sink_f",
41                       gr_make_io_signature (1, gr_oscope_guts::MAX_CHANNELS, sizeof (float)),
42                       sampling_rate),
43     d_msgq(msgq)
44 {
45   d_guts = new gr_oscope_guts (d_sampling_rate, d_msgq);
46 }
47
48
49 bool
50 gr_oscope_sink_f::check_topology (int ninputs, int noutputs)
51 {
52   return d_guts->set_num_channels(ninputs);
53 }
54
55
56 gr_oscope_sink_f::~gr_oscope_sink_f ()
57 {
58 }
59
60 int
61 gr_oscope_sink_f::work (int noutput_items,
62                         gr_vector_const_void_star &input_items,
63                         gr_vector_void_star &output_items)
64 {
65   int     ni = input_items.size ();
66   float   tmp[gr_oscope_guts::MAX_CHANNELS];
67
68   for (int i = 0; i < noutput_items; i++){
69
70     // FIXME for now, copy the data.  Fix later if reqd
71     for (int ch = 0; ch < ni; ch++)     
72       tmp[ch] = ((const float *) input_items[ch])[i];
73
74     d_guts->process_sample (tmp);
75   }
76
77   return noutput_items;
78 }