3 from gnuradio import gr, gru, usrp, optfir, eng_notation, blks2, pager
4 from gnuradio.eng_option import eng_option
5 from optparse import OptionParser
6 from string import split, join, printable
9 class app_top_block(gr.top_block):
10 def __init__(self, options, queue):
11 gr.top_block.__init__(self, "usrp_flex_all")
13 if options.from_file is not None:
14 self.src = gr.file_source(gr.sizeof_gr_complex, options.from_file)
16 print "Reading samples from file", options.from_file
18 self.src = usrp.source_c()
19 if options.rx_subdev_spec is None:
20 options.rx_subdev_spec = usrp.pick_rx_subdevice(self.src)
21 self.subdev = usrp.selected_subdev(self.src, options.rx_subdev_spec)
22 self.src.set_mux(usrp.determine_rx_mux_value(self.src, options.rx_subdev_spec))
23 self.src.set_decim_rate(64)
24 frequency = options.frequency+options.calibration
25 result = usrp.tune(self.src, 0, self.subdev, frequency)
27 print "Using", self.subdev.name(), " for receiving."
28 print "Tuned USRP to", frequency
30 taps = gr.firdes.low_pass(1.0,
37 print "Channel filter has", len(taps), "taps"
39 bank = blks2.analysis_filterbank(40, taps)
40 self.connect(self.src, bank)
42 if options.log and options.from_file == None:
43 src_sink = gr.file_sink(gr.sizeof_gr_complex, 'usrp.dat')
44 self.connect(self.src, src_sink)
48 freq = options.frequency+i*25e3
50 freq = options.frequency-0.5e6+(i-20)*25e3
52 self.connect((bank, i), pager.flex_demod(queue, freq, options.verbose, options.log))
54 self.connect((bank, i), gr.file_sink(gr.sizeof_gr_complex, 'chan_'+'%3.3f'%(freq/1e6)+'.dat'))
57 parser = OptionParser(option_class=eng_option)
58 parser.add_option("-f", "--frequency", type="eng_float", default=929.5e6,
59 help="set receive center frequency to Hz", metavar="Hz")
60 parser.add_option("-R", "--rx-subdev-spec", type="subdev",
61 help="select USRP Rx side A or B (default=first daughterboard found)")
62 parser.add_option("-c", "--calibration", type="eng_float", default=0.0,
63 help="set frequency offset to Hz", metavar="Hz")
64 parser.add_option("-g", "--gain", type="int",
65 help="set RF gain", metavar="dB")
66 parser.add_option("-F", "--from-file", default=None,
67 help="Read from file instead of USRP")
68 parser.add_option("-l", "--log", action="store_true", default=False,
69 help="log flowgraph to files (LOTS of data)")
70 parser.add_option("-v", "--verbose", action="store_true", default=False,
71 help="display debug output")
72 (options, args) = parser.parse_args()
77 queue = gr.msg_queue()
78 tb = app_top_block(options, queue)
83 if not queue.empty_p():
84 msg = queue.delete_head() # Blocking read
85 page = join(split(msg.to_string(), chr(128)), '|')
87 for n in range(len(page)):
97 except KeyboardInterrupt:
100 if __name__ == "__main__":