From: jcorgan <jcorgan@221aa14e-8319-0410-a670-987f0aec2ac5>
Date: Mon, 16 Jul 2007 15:04:44 +0000 (+0000)
Subject: Added decoder script for band (40 channels).
X-Git-Url: https://git.gag.com/?a=commitdiff_plain;h=877a3e627d3d5db76f205bb78aad5ed0ca898ad3;p=debian%2Fgnuradio

Added decoder script for band (40 channels).

git-svn-id: http://gnuradio.org/svn/gnuradio/trunk@5983 221aa14e-8319-0410-a670-987f0aec2ac5
---

diff --git a/gr-pager/src/usrp_flex_band.py b/gr-pager/src/usrp_flex_band.py
new file mode 100755
index 00000000..69b0dbf8
--- /dev/null
+++ b/gr-pager/src/usrp_flex_band.py
@@ -0,0 +1,102 @@
+#!/usr/bin/env python
+
+from gnuradio import gr, gru, usrp, optfir, eng_notation, blks2, pager
+from gnuradio.eng_option import eng_option
+from optparse import OptionParser
+from string import split, join, printable
+import time
+
+class app_top_block(gr.top_block):
+    def __init__(self, options, queue):
+	gr.top_block.__init__(self, "usrp_flex_all")
+
+        if options.from_file is not None:
+            self.src = gr.file_source(gr.sizeof_gr_complex, options.from_file)
+            if options.verbose:
+                print "Reading samples from file", options.from_file
+        else:
+            self.src = usrp.source_c()
+            if options.rx_subdev_spec is None:
+                options.rx_subdev_spec = usrp.pick_rx_subdevice(self.src)
+            self.subdev = usrp.selected_subdev(self.src, options.rx_subdev_spec)
+            self.src.set_mux(usrp.determine_rx_mux_value(self.src, options.rx_subdev_spec))
+            self.src.set_decim_rate(64)
+	    frequency = options.frequency+options.calibration
+            result = usrp.tune(self.src, 0, self.subdev, frequency)
+            if options.verbose:
+                print "Using", self.subdev.name(), " for receiving."
+                print "Tuned USRP to", frequency
+                
+        taps = gr.firdes.low_pass(1.0,
+                                  1.0,
+                                  1.0/40.0*0.4,
+                                  1.0/40.0*0.1,
+                                  gr.firdes.WIN_HANN)
+
+        if options.verbose:
+            print "Channel filter has", len(taps), "taps"
+
+        bank = blks2.analysis_filterbank(40, taps)
+        self.connect(self.src, bank)
+
+        if options.log and options.from_file == None:
+            src_sink = gr.file_sink(gr.sizeof_gr_complex, 'usrp.dat')
+            self.connect(self.src, src_sink)
+
+        for i in range(40):
+	    if i < 20:
+		freq = options.frequency+i*25e3
+	    else:
+		freq = options.frequency-0.5e6+(i-20)*25e3
+
+	    self.connect((bank, i), pager.flex_demod(queue, freq, options.verbose, options.log))
+	    if options.log:
+		self.connect((bank, i), gr.file_sink(gr.sizeof_gr_complex, 'chan_'+'%3.3f'%(freq/1e6)+'.dat'))
+
+def main():
+    parser = OptionParser(option_class=eng_option)
+    parser.add_option("-f", "--frequency", type="eng_float", default=929.5e6,
+                      help="set receive center frequency to Hz", metavar="Hz")
+    parser.add_option("-R", "--rx-subdev-spec", type="subdev",
+                      help="select USRP Rx side A or B (default=first daughterboard found)")
+    parser.add_option("-c", "--calibration", type="eng_float", default=0.0,
+                      help="set frequency offset to Hz", metavar="Hz")
+    parser.add_option("-g", "--gain", type="int",
+                      help="set RF gain", metavar="dB")
+    parser.add_option("-F", "--from-file", default=None,
+                      help="Read from file instead of USRP")
+    parser.add_option("-l", "--log", action="store_true", default=False,
+                      help="log flowgraph to files (LOTS of data)")
+    parser.add_option("-v", "--verbose", action="store_true", default=False,
+                      help="display debug output")
+    (options, args) = parser.parse_args()
+
+    if options.verbose:
+        print options
+
+    queue = gr.msg_queue()
+    tb = app_top_block(options, queue)
+    r = gr.runtime(tb)
+
+    try:
+        r.start()
+	while 1:
+	    if not queue.empty_p():
+		msg = queue.delete_head() # Blocking read
+		page = join(split(msg.to_string(), chr(128)), '|')
+		disp = []
+		for n in range(len(page)):
+		    if ord(page[n]) < 32:
+			disp.append('.')
+		    else:
+			disp.append(page[n])
+		print join(disp, '')
+						
+	    else:
+		time.sleep(1)
+
+    except KeyboardInterrupt:
+        r.stop()
+    
+if __name__ == "__main__":
+    main()