blob: 63426a3fa17d17f482cedc59a2f0f527b6520543 [file] [log] [blame]
ptrkrysik3b776542015-01-03 00:06:39 +01001#!/usr/bin/env python
2##################################################
3# Gnuradio Python Flow Graph
4# Title: Airprobe Usrp
5# Generated: Sat Jan 3 00:02:32 2015
6##################################################
7
8from PyQt4 import Qt
9from PyQt4.QtCore import QObject, pyqtSlot
10from gnuradio import blocks
11from gnuradio import eng_notation
12from gnuradio import gr
13from gnuradio import qtgui
14from gnuradio import uhd
15from gnuradio.eng_option import eng_option
16from gnuradio.filter import firdes
17from optparse import OptionParser
18import PyQt4.Qwt5 as Qwt
19import grgsm
20import pmt
21import sip
22import sys
23import time
24
25from distutils.version import StrictVersion
26class airprobe_usrp(gr.top_block, Qt.QWidget):
27
28 def __init__(self):
29 gr.top_block.__init__(self, "Airprobe Usrp")
30 Qt.QWidget.__init__(self)
31 self.setWindowTitle("Airprobe Usrp")
32 try:
33 self.setWindowIcon(Qt.QIcon.fromTheme('gnuradio-grc'))
34 except:
35 pass
36 self.top_scroll_layout = Qt.QVBoxLayout()
37 self.setLayout(self.top_scroll_layout)
38 self.top_scroll = Qt.QScrollArea()
39 self.top_scroll.setFrameStyle(Qt.QFrame.NoFrame)
40 self.top_scroll_layout.addWidget(self.top_scroll)
41 self.top_scroll.setWidgetResizable(True)
42 self.top_widget = Qt.QWidget()
43 self.top_scroll.setWidget(self.top_widget)
44 self.top_layout = Qt.QVBoxLayout(self.top_widget)
45 self.top_grid_layout = Qt.QGridLayout()
46 self.top_layout.addLayout(self.top_grid_layout)
47
48 self.settings = Qt.QSettings("GNU Radio", "airprobe_usrp")
49 self.restoreGeometry(self.settings.value("geometry").toByteArray())
50
51
52 ##################################################
53 # Variables
54 ##################################################
55 self.samp_rate = samp_rate = 100e6/100
56 self.g = g = 30
57 self.fc = fc = 1869e6
58 self.SDCCH = SDCCH = 6
59 self.RACH = RACH = 3
60 self.PCH = PCH = 5
61 self.CHANNEL_UNKNOWN = CHANNEL_UNKNOWN = 0
62 self.CCCH = CCCH = 2
63 self.BCCH = BCCH = 1
64 self.AGCH = AGCH = 4
65
66 ##################################################
67 # Blocks
68 ##################################################
69 self._g_layout = Qt.QHBoxLayout()
70 self._g_layout.addWidget(Qt.QLabel("Gain"+": "))
71 class qwt_counter_pyslot(Qwt.QwtCounter):
72 def __init__(self, parent=None):
73 Qwt.QwtCounter.__init__(self, parent)
74 @pyqtSlot('double')
75 def setValue(self, value):
76 super(Qwt.QwtCounter, self).setValue(value)
77 self._g_counter = qwt_counter_pyslot()
78 self._g_counter.setRange(0, 50, 0.5)
79 self._g_counter.setNumButtons(2)
80 self._g_counter.setMinimumWidth(100)
81 self._g_counter.setValue(self.g)
82 self._g_layout.addWidget(self._g_counter)
83 self._g_counter.valueChanged.connect(self.set_g)
84 self.top_layout.addLayout(self._g_layout)
85 self._fc_layout = Qt.QVBoxLayout()
86 self._fc_tool_bar = Qt.QToolBar(self)
87 self._fc_layout.addWidget(self._fc_tool_bar)
88 self._fc_tool_bar.addWidget(Qt.QLabel("Frequency"+": "))
89 class qwt_counter_pyslot(Qwt.QwtCounter):
90 def __init__(self, parent=None):
91 Qwt.QwtCounter.__init__(self, parent)
92 @pyqtSlot('double')
93 def setValue(self, value):
94 super(Qwt.QwtCounter, self).setValue(value)
95 self._fc_counter = qwt_counter_pyslot()
96 self._fc_counter.setRange(1800e6, 1900e6, 2e5)
97 self._fc_counter.setNumButtons(2)
98 self._fc_counter.setValue(self.fc)
99 self._fc_tool_bar.addWidget(self._fc_counter)
100 self._fc_counter.valueChanged.connect(self.set_fc)
101 self._fc_slider = Qwt.QwtSlider(None, Qt.Qt.Horizontal, Qwt.QwtSlider.BottomScale, Qwt.QwtSlider.BgSlot)
102 self._fc_slider.setRange(1800e6, 1900e6, 2e5)
103 self._fc_slider.setValue(self.fc)
104 self._fc_slider.setMinimumWidth(100)
105 self._fc_slider.valueChanged.connect(self.set_fc)
106 self._fc_layout.addWidget(self._fc_slider)
107 self.top_layout.addLayout(self._fc_layout)
108 self.uhd_usrp_source_0 = uhd.usrp_source(
109 ",".join(("addr=192.168.10.2", "")),
110 uhd.stream_args(
111 cpu_format="fc32",
112 channels=range(1),
113 ),
114 )
115 self.uhd_usrp_source_0.set_clock_source("internal", 0)
116 self.uhd_usrp_source_0.set_samp_rate(samp_rate)
117 self.uhd_usrp_source_0.set_center_freq(fc, 0)
118 self.uhd_usrp_source_0.set_gain(g, 0)
119 self.qtgui_freq_sink_x_0 = qtgui.freq_sink_c(
120 1024, #size
121 firdes.WIN_BLACKMAN_hARRIS, #wintype
122 fc, #fc
123 samp_rate, #bw
124 "", #name
125 1 #number of inputs
126 )
127 self.qtgui_freq_sink_x_0.set_update_time(0.10)
128 self.qtgui_freq_sink_x_0.set_y_axis(-140, 10)
129 self.qtgui_freq_sink_x_0.set_trigger_mode(qtgui.TRIG_MODE_FREE, 0.0, 0, "")
130 self.qtgui_freq_sink_x_0.enable_autoscale(False)
131 self.qtgui_freq_sink_x_0.enable_grid(False)
132 self.qtgui_freq_sink_x_0.set_fft_average(1.0)
133
134 if complex == type(float()):
135 self.qtgui_freq_sink_x_0.set_plot_pos_half(not True)
136
137 labels = ["", "", "", "", "",
138 "", "", "", "", ""]
139 widths = [1, 1, 1, 1, 1,
140 1, 1, 1, 1, 1]
141 colors = ["blue", "red", "green", "black", "cyan",
142 "magenta", "yellow", "dark red", "dark green", "dark blue"]
143 alphas = [1.0, 1.0, 1.0, 1.0, 1.0,
144 1.0, 1.0, 1.0, 1.0, 1.0]
145 for i in xrange(1):
146 if len(labels[i]) == 0:
147 self.qtgui_freq_sink_x_0.set_line_label(i, "Data {0}".format(i))
148 else:
149 self.qtgui_freq_sink_x_0.set_line_label(i, labels[i])
150 self.qtgui_freq_sink_x_0.set_line_width(i, widths[i])
151 self.qtgui_freq_sink_x_0.set_line_color(i, colors[i])
152 self.qtgui_freq_sink_x_0.set_line_alpha(i, alphas[i])
153
154 self._qtgui_freq_sink_x_0_win = sip.wrapinstance(self.qtgui_freq_sink_x_0.pyqwidget(), Qt.QWidget)
155 self.top_layout.addWidget(self._qtgui_freq_sink_x_0_win)
156 self.gsm_universal_ctrl_chans_demapper_0 = grgsm.universal_ctrl_chans_demapper(([2,6,12,16,22,26,32,36,42,46]), ([BCCH,CCCH,CCCH,CCCH,CCCH,CCCH,CCCH,CCCH,CCCH,CCCH]))
157 self.gsm_receiver_0 = grgsm.receiver(4, ([0]), ([]))
158 self.gsm_message_printer_0 = grgsm.message_printer(pmt.intern(""))
159 self.gsm_input_0 = grgsm.gsm_input(
160 ppm=0,
161 osr=4,
162 fc=fc,
163 samp_rate_in=samp_rate,
164 )
165 self.gsm_control_channels_decoder_0 = grgsm.control_channels_decoder()
166 self.blocks_socket_pdu_0 = blocks.socket_pdu("UDP_CLIENT", "127.0.0.1", "4729", 10000, False)
167 self.blocks_message_debug_0 = blocks.message_debug()
168
169 ##################################################
170 # Connections
171 ##################################################
172 self.connect((self.uhd_usrp_source_0, 0), (self.qtgui_freq_sink_x_0, 0))
173 self.connect((self.uhd_usrp_source_0, 0), (self.gsm_input_0, 0))
174 self.connect((self.gsm_input_0, 0), (self.gsm_receiver_0, 0))
175
176 ##################################################
177 # Message Connections
178 ##################################################
179 self.msg_connect(self.gsm_control_channels_decoder_0, "msgs", self.gsm_message_printer_0, "msgs")
180 self.msg_connect(self.gsm_control_channels_decoder_0, "msgs", self.blocks_socket_pdu_0, "pdus")
181 self.msg_connect(self.gsm_universal_ctrl_chans_demapper_0, "bursts", self.gsm_control_channels_decoder_0, "bursts")
182 self.msg_connect(self.gsm_receiver_0, "C0", self.gsm_universal_ctrl_chans_demapper_0, "bursts")
183 self.msg_connect(self.gsm_receiver_0, "measurements", self.blocks_message_debug_0, "print")
184
185 def closeEvent(self, event):
186 self.settings = Qt.QSettings("GNU Radio", "airprobe_usrp")
187 self.settings.setValue("geometry", self.saveGeometry())
188 event.accept()
189
190 def get_samp_rate(self):
191 return self.samp_rate
192
193 def set_samp_rate(self, samp_rate):
194 self.samp_rate = samp_rate
195 self.gsm_input_0.set_samp_rate_in(self.samp_rate)
196 self.qtgui_freq_sink_x_0.set_frequency_range(self.fc, self.samp_rate)
197 self.uhd_usrp_source_0.set_samp_rate(self.samp_rate)
198
199 def get_g(self):
200 return self.g
201
202 def set_g(self, g):
203 self.g = g
204 Qt.QMetaObject.invokeMethod(self._g_counter, "setValue", Qt.Q_ARG("double", self.g))
205 self.uhd_usrp_source_0.set_gain(self.g, 0)
206
207 def get_fc(self):
208 return self.fc
209
210 def set_fc(self, fc):
211 self.fc = fc
212 self.gsm_input_0.set_fc(self.fc)
213 self.qtgui_freq_sink_x_0.set_frequency_range(self.fc, self.samp_rate)
214 self.uhd_usrp_source_0.set_center_freq(self.fc, 0)
215 Qt.QMetaObject.invokeMethod(self._fc_counter, "setValue", Qt.Q_ARG("double", self.fc))
216 Qt.QMetaObject.invokeMethod(self._fc_slider, "setValue", Qt.Q_ARG("double", self.fc))
217
218 def get_SDCCH(self):
219 return self.SDCCH
220
221 def set_SDCCH(self, SDCCH):
222 self.SDCCH = SDCCH
223
224 def get_RACH(self):
225 return self.RACH
226
227 def set_RACH(self, RACH):
228 self.RACH = RACH
229
230 def get_PCH(self):
231 return self.PCH
232
233 def set_PCH(self, PCH):
234 self.PCH = PCH
235
236 def get_CHANNEL_UNKNOWN(self):
237 return self.CHANNEL_UNKNOWN
238
239 def set_CHANNEL_UNKNOWN(self, CHANNEL_UNKNOWN):
240 self.CHANNEL_UNKNOWN = CHANNEL_UNKNOWN
241
242 def get_CCCH(self):
243 return self.CCCH
244
245 def set_CCCH(self, CCCH):
246 self.CCCH = CCCH
247
248 def get_BCCH(self):
249 return self.BCCH
250
251 def set_BCCH(self, BCCH):
252 self.BCCH = BCCH
253
254 def get_AGCH(self):
255 return self.AGCH
256
257 def set_AGCH(self, AGCH):
258 self.AGCH = AGCH
259
260if __name__ == '__main__':
261 import ctypes
262 import sys
263 if sys.platform.startswith('linux'):
264 try:
265 x11 = ctypes.cdll.LoadLibrary('libX11.so')
266 x11.XInitThreads()
267 except:
268 print "Warning: failed to XInitThreads()"
269 parser = OptionParser(option_class=eng_option, usage="%prog: [options]")
270 (options, args) = parser.parse_args()
271 if(StrictVersion(Qt.qVersion()) >= StrictVersion("4.5.0")):
272 Qt.QApplication.setGraphicsSystem(gr.prefs().get_string('qtgui','style','raster'))
273 qapp = Qt.QApplication(sys.argv)
274 tb = airprobe_usrp()
275 tb.start()
276 tb.show()
277 def quitting():
278 tb.stop()
279 tb.wait()
280 qapp.connect(qapp, Qt.SIGNAL("aboutToQuit()"), quitting)
281 qapp.exec_()
282 tb = None #to clean up Qt widgets