cefac5476acba483db404cea4a0a481cf1329440
[debian/gnuradio] / gr-msdd6000 / src / msdd_source_simple.cc
1 /* -*- c++ -*- */
2 /*
3  * Copyright 2008 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 along
18  * with this program; if not, write to the Free Software Foundation, Inc.,
19  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
20  */
21 #ifdef HAVE_CONFIG_H
22 #include <config.h>
23 #endif
24
25 #include <msdd_source_simple.h>
26 #include <gr_io_signature.h>
27 #include <string.h>
28
29
30 msdd_source_simple_sptr
31 msdd_make_source_simple ( const char *src, unsigned short port_src) 
32 {
33   return msdd_source_simple_sptr (new msdd_source_simple ( src, port_src)); 
34 }
35
36
37 msdd_source_simple::msdd_source_simple (
38                     const char *src, 
39                     unsigned short port_src) 
40                 : gr_sync_block("MSDD_SOURCE_SIMPLE",
41                                 gr_make_io_signature (0,0,0),
42                                 gr_make_io_signature (1, 1, sizeof (short))),
43                   rcv(new MSDD6000((char*) src)), d_lastseq(0)
44 {
45 }
46
47 msdd_source_simple::~msdd_source_simple ()
48 {
49 }
50
51
52 int
53 msdd_source_simple::work (int noutput_items,
54                          gr_vector_const_void_star &input_items,
55                          gr_vector_void_star &output_items)
56 {
57         
58 #define BUF_LEN (366*sizeof(short)*2 + 6)
59
60         float* out1 =(float*) output_items[0];
61
62         char buffer[BUF_LEN];
63         rcv->read( &buffer[0], BUF_LEN );
64
65         int seq = *((int*) &buffer[2]);
66         
67         // FIXME get rid of these magic 366's!
68         if(d_lastseq == -366){
69                 // not started case
70                 if(seq == 0){
71                         d_lastseq = 0;
72                         } else {
73                         // THROW AWAY SAMPLES WE ARE NOT STARTED YET!
74                         return 0;
75                         }
76                 
77                 } else {
78                 // started case
79                 int samples_missed = seq - d_lastseq - 366;
80                 if(samples_missed > 0){
81                         printf("dropped %d samples.\n", samples_missed);
82                         }
83                 d_lastseq = seq;
84                 }
85         
86         if(noutput_items< 366*2){
87                 printf("NOT ENOUGH SPACE IN OUTPUT BUFFER!!! >:-(\n");
88                 }
89         
90         memcpy(&out1[0], &buffer[6], BUF_LEN - 6);
91         
92 //      for(int i = 0; i < 366*2; i++){
93 //              out1[i] = (float)  (*((short*) &buffer[6+2*i]) );
94 //      }
95         
96         return 366*2;
97 }
98
99 bool msdd_source_simple::set_decim_rate(unsigned int rate)
100 {
101         // FIXME seems buggy.  How about a floor or ceil?
102         rcv->set_decim((int) log2(rate));
103         return true;
104 }
105
106
107 bool msdd_source_simple::set_rx_freq(int channel, double freq)
108 {
109         long new_fc = (long)freq;
110         rcv->set_fc( new_fc/1000000, new_fc%1000000);
111         return true;
112 }
113
114
115 bool msdd_source_simple::set_pga(int which, double gain)
116 {
117         if(gain < 0 || gain > 10){
118                 printf("GAIN IS OUTSIDE ACCEPTABLE RANGE!\n");
119                 return false;
120         }
121         // ok i lied this is not really a pga, its decimation gain
122         rcv->set_ddc_gain((int)gain);
123         return true;
124 }
125
126
127 bool msdd_source_simple::start()
128 {
129         rcv->start();
130         return true;
131 }
132
133
134 bool msdd_source_simple::stop()
135 {
136         rcv->stop();
137         return true;
138 }
139
140 long msdd_source_simple::adc_freq(){
141         return 102400000;
142 }
143
144 int msdd_source_simple::decim_rate(){
145         return 1 << rcv->d_decim;
146 }
147
148
149 std::vector<int> msdd_source_simple::gain_range(){
150         static std::vector<int> r;
151         r.push_back(0);
152         r.push_back(12);
153         return r;
154 }
155
156 std::vector<float> msdd_source_simple::freq_range(){
157         std::vector<float> r;
158         r.push_back(30.0*1000*1000);
159         r.push_back(6.0*1000*1000*1000);
160         return r;
161 }