-<?xml version='1.0' encoding='ASCII'?>

- <key>id</key>

- <value>pam_timing</value>

- <key>_enabled</key>

- <value>True</value>

- <key>title</key>

- <value></value>

- <key>author</key>

- <key>window_size</key>

- <value>1280, 1024</value>

- <key>category</key>

- <value>Custom</value>

- <key>max_nouts</key>

- <value>0</value>

- <key>realtime_scheduling</key>

- <key>alias</key>

- <value>(-1, 0)</value>

- </block>

- <block>

- <key>variable</key>

- <key>_enabled</key>

- <value>True</value>

- </param>

- <param>

- <key>alias</key>

- <value>(206, 116)</value>

- </block>

- <block>

- <key>variable</key>

- <value>sig_amp</value>

- <key>_enabled</key>

- <value>True</value>

- <key>alias</key>

- <value></value>

- <value>(791, 46)</value>

- </block>

- <block>

- <key>variable</key>

- <value>samp_rate</value>

- <key>_enabled</key>

- <value>True</value>

- <key>value</key>

- <value>32000</value>

- <key>alias</key>

- <value></value>

- <key>_coordinate</key>

- <value>(267, 357)</value>

- <key>_rotation</key>

- <value>0</value>

- <key>id</key>

- <value>spb</value>

- <value>4.2563</value>

- <key>alias</key>

- <value>(300, 0)</value>

- <key>id</key>

- <value>rolloff</value>

- <key>alias</key>

- <value>(482, 335)</value>

- <key>id</key>

- <value>nfilts</value>

- <value>32</value>

- <key>alias</key>

- <value>(562, 334)</value>

- <key>analog_random_source_x</key>

- <key>id</key>

- <value>analog_random_source_x</value>

- <key>type</key>

- <value>byte</value>

- <key>min</key>

- <key>max</key>

- <value>const.arity()</value>

- <key>num_samps</key>

- <value>10000000</value>

- <key>repeat</key>

- <value>True</value>

- <key>affinity</key>

- <key>minoutbuf</key>

- <value>0</value>

- <key>maxoutbuf</key>

- <value>0</value>

- </block>

- <block>

- <key>digital_chunks_to_symbols_xx</key>

- <value>digital_chunks_to_symbols_xx</value>

- <key>_enabled</key>

- <value>True</value>

- <key>in_type</key>

- <value>byte</value>

- <key>out_type</key>

- <value>complex</value>

- <key>symbol_table</key>

- <value>const.points()</value>

- <key>dimension</key>

- <value>1</value>

- <key>num_ports</key>

- <value>1</value>

- <key>affinity</key>

- <key>minoutbuf</key>

- <value>0</value>

- <key>maxoutbuf</key>

- <value>0</value>

- <value>(203, 178)</value>

- </block>

- <block>

- <key>blocks_throttle</key>

- <value>blocks_throttle_0</value>

- </param>

- <param>

- <key>_enabled</key>

- <value>True</value>

- <key>samples_per_second</key>

- <value>samp_rate</value>

- <key>vlen</key>

- <value>1</value>

- <key>ignoretag</key>

- <value>True</value>

- <key>affinity</key>

- <key>minoutbuf</key>

- <value>0</value>

- <key>maxoutbuf</key>

- <value>0</value>

- </block>

- <block>

- <key>channels_channel_model</key>

- <value>channels_channel_model_0</value>

- <key>_enabled</key>

- <key>noise_voltage</key>

- <value>noise_amp</value>

- <key>freq_offset</key>

- <value>freq_offset</value>

- <key>epsilon</key>

- <value>interpratio</value>

- <key>taps</key>

- <value>1.0</value>

- <key>seed</key>

- <value>42</value>

- <key>alias</key>

- <key>minoutbuf</key>

- <value>0</value>

- <key>maxoutbuf</key>

- <value>0</value>

- </block>

- <block>

- <key>pfb_arb_resampler_xxx</key>

- <value>pfb_arb_resampler_xxx_0</value>

- </param>

- <param>

- <key>_enabled</key>

- <value>True</value>

- <key>type</key>

- <value>ccf</value>

- <key>rrate</key>

- <value>spb</value>

- <key>taps</key>

- <value>firdes.root_raised_cosine(nfilts, nfilts, 1.0, rolloff, 44*nfilts)</value>

- <key>nfilts</key>

- <value>32</value>

- <key>atten</key>

- <value>100</value>

- <key>samp_delay</key>

- <value>0</value>

- <key>alias</key>

- <key>minoutbuf</key>

- <value>0</value>

- <key>maxoutbuf</key>

- <value>0</value>

- <value>(458, 179)</value>

- </block>

- <block>

- <key>import</key>

- <value>import_0</value>

- </param>

- <param>

- <key>_enabled</key>

- <value>True</value>

- </param>

- <param>

- <key>import</key>

- <value>from gnuradio import digital</value>

- </param>

- <param>

- <key>alias</key>

- <value></value>

- <key>_coordinate</key>

- <value>(-1, 61)</value>

- <key>_rotation</key>

- </block>

- <block>

- <key>blocks_multiply_const_vxx</key>

- <key>id</key>

- <value>blocks_multiply_const_vxx_0</value>

- <key>_enabled</key>

- <value>True</value>

- <key>type</key>

- <key>const</key>

- <value>sig_amp</value>

- <key>vlen</key>

- <value>1</value>

- <key>alias</key>

- <key>minoutbuf</key>

- <value>0</value>

- <key>maxoutbuf</key>

- <value>0</value>

- <value>(760, 159)</value>

- </block>

- <block>

- <key>qtgui_time_sink_x</key>

- <value>qtgui_time_sink_x_0</value>

- <key>_enabled</key>

- <value>True</value>

- <key>type</key>

- <value>complex</value>

- <key>name</key>

- <value>Error</value>

- <key>ylabel</key>

- <value>Amplitude</value>

- <key>yunit</key>

- <value>""</value>

- <key>size</key>

- <value>1024</value>

- <key>srate</key>

- <value>samp_rate</value>

- <key>grid</key>

- <value>False</value>

- <key>autoscale</key>

- <value>False</value>

- <key>ymin</key>

- <value>-1</value>

- <key>ymax</key>

- <value>1</value>

- <key>nconnections</key>

- <value>1</value>

- <key>update_time</key>

- <value>0.10</value>

- <key>entags</key>

- <value>True</value>

- <key>gui_hint</key>

- <value>notebook@3</value>

- <key>tr_mode</key>

- <value>qtgui.TRIG_MODE_FREE</value>

- <key>tr_slope</key>

- <value>qtgui.TRIG_SLOPE_POS</value>

- <key>tr_level</key>

- <value>0.0</value>

- <key>tr_delay</key>

- <value>0</value>

- <key>tr_chan</key>

- <key>tr_tag</key>

- <value>""</value>

- <value></value>

- <key>width1</key>

- <value>1</value>

- <key>color1</key>

- <value>"blue"</value>

- <key>style1</key>

- <value>1</value>

- <key>marker1</key>

- <value>-1</value>

- <key>alpha1</key>

- <value>1.0</value>

- <key>label2</key>

- <value></value>

- <key>width2</key>

- <value>1</value>

- <key>color2</key>

- <value>"red"</value>

- <key>style2</key>

- <value>1</value>

- <key>marker2</key>

- <value>-1</value>

- <key>alpha2</key>

- <value>1.0</value>

- <value></value>

- <key>width3</key>

- <value>1</value>

- <key>color3</key>

- <value>"green"</value>

- <key>style3</key>

- <value>1</value>

- <key>marker3</key>

- <value>-1</value>

- <key>alpha3</key>

- <value>1.0</value>

- <key>label4</key>

- <key>width4</key>

- <value>1</value>

- <key>color4</key>

- <value>"black"</value>

- <key>style4</key>

- <value>1</value>

- <key>marker4</key>

- <value>-1</value>

- <key>alpha4</key>

- <value>1.0</value>

- <key>label5</key>

- <value></value>

- <key>width5</key>

- <value>1</value>

- <key>color5</key>

- <value>"cyan"</value>

- <key>style5</key>

- <value>1</value>

- <key>marker5</key>

- <value>-1</value>

- <key>alpha5</key>

- <value>1.0</value>

- <key>label6</key>

- <value></value>

- <key>width6</key>

- <value>1</value>

- <key>color6</key>

- <value>"magenta"</value>

- <key>style6</key>

- <value>1</value>

- <key>marker6</key>

- <value>-1</value>

- <key>alpha6</key>

- <value>1.0</value>

- <key>label7</key>

- <key>width7</key>

- <value>1</value>

- <key>color7</key>

- <value>"yellow"</value>

- <key>style7</key>

- <value>1</value>

- <key>marker7</key>

- <value>-1</value>

- <key>alpha7</key>

- <value>1.0</value>

- <key>label8</key>

- <value></value>

- <key>width8</key>

- <value>1</value>

- <key>color8</key>

- <value>"dark red"</value>

- <key>style8</key>

- <value>1</value>

- <key>marker8</key>

- <value>-1</value>

- <key>alpha8</key>

- <key>label9</key>

- <value></value>

- <key>width9</key>

- <value>1</value>

- <key>color9</key>

- <value>"dark green"</value>

- <key>style9</key>

- <key>marker9</key>

- <value>-1</value>

- <key>alpha9</key>

- <key>label10</key>

- <value></value>

- <key>width10</key>

- <value>1</value>

- <key>color10</key>

- <value>"blue"</value>

- <key>marker10</key>

- <value>-1</value>

- <key>alpha10</key>

- <key>alias</key>

- <value></value>

- <key>affinity</key>

- <key>_coordinate</key>

- <value>(1020, 128)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>qtgui_tab_widget</key>

- <key>id</key>

- <value>notebook</value>

- <key>_enabled</key>

- <value>True</value>

- <key>num_tabs</key>

- <value>4</value>

- <key>label0</key>

- <value>Error</value>

- <key>label1</key>

- <value>Phase</value>

- <key>label2</key>

- <value>Freq</value>

- <key>label3</key>

- <value>Resampled Signal</value>

- <key>label4</key>

- <value>Tab 4</value>

- <key>gui_hint</key>

- <value>1,1,5,1</value>

- <key>alias</key>

- <key>_coordinate</key>

- <value>(485, 554)</value>

- </param>

- <param>

- <key>_rotation</key>

- <value>0</value>

- </param>

- </block>

- <block>

- <key>variable_qtgui_range</key>

- <param>

- <key>id</key>

- <value>interpratio</value>

- <key>_enabled</key>

- <value>True</value>

- <key>label</key>

- <value>Timing Offset</value>

- <key>value</key>

- <value>1</value>

- <key>start</key>

- <value>.99</value>

- <key>stop</key>

- <value>1.01</value>

- <key>step</key>

- <value>0.0001</value>

- <key>widget</key>

- <value>counter_slider</value>

- <key>orient</key>

- <value>Qt.Horizontal</value>

- <key>min_len</key>

- <value>200</value>

- <key>gui_hint</key>

- <value>2,2,1,1</value>

- <key>alias</key>

- <key>_coordinate</key>

- <value>(6, 526)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>variable_qtgui_range</key>

- <key>id</key>

- <value>noise_amp</value>

- <key>_enabled</key>

- <value>True</value>

- <key>label</key>

- <value>Channel Noise</value>

- <key>value</key>

- <value>0</value>

- <key>start</key>

- <value>0</value>

- <key>stop</key>

- <key>step</key>

- <value>.001</value>

- </param>

- <param>

- <key>widget</key>

- <value>counter_slider</value>

- <key>orient</key>

- <value>Qt.Horizontal</value>

- <key>min_len</key>

- <value>200</value>

- <key>gui_hint</key>

- <value>3,2,1,1</value>

- <key>alias</key>

- <value></value>

- <key>_coordinate</key>

- <value>(130, 528)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>variable_qtgui_range</key>

- <key>id</key>

- <value>freq_offset</value>

- <key>_enabled</key>

- <value>True</value>

- <key>label</key>

- <value>Frequency Offset</value>

- <key>value</key>

- <value>0</value>

- <key>start</key>

- <value>-.5</value>

- <key>stop</key>

- <value>.5</value>

- <key>step</key>

- <value>.01</value>

- <key>widget</key>

- <value>counter_slider</value>

- <key>orient</key>

- <value>Qt.Horizontal</value>

- <key>min_len</key>

- <value>200</value>

- <key>gui_hint</key>

- <value>4,2,1,1</value>

- <key>alias</key>

- <value></value>

- <key>_coordinate</key>

- <value>(268, 527)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>qtgui_time_sink_x</key>

- <key>id</key>

- <value>qtgui_time_sink_x_1_1</value>

- <key>_enabled</key>

- <value>True</value>

- <value>float</value>

- <key>name</key>

- <value>Phase</value>

- <key>size</key>

- <value>1024</value>

- <key>srate</key>

- <value>samp_rate</value>

- <key>grid</key>

- <key>autoscale</key>

- <key>ymin</key>

- <value>-1</value>

- <key>ymax</key>

- <value>1</value>

- <key>nconnections</key>

- <value>1</value>

- <key>update_time</key>

- <value>0.10</value>

- <value>notebook@1</value>

- <key>tr_mode</key>

- <value>qtgui.TRIG_MODE_FREE</value>

- <key>tr_slope</key>

- <value>qtgui.TRIG_SLOPE_POS</value>

- <key>tr_level</key>

- <value>0.0</value>

- <key>tr_delay</key>

- <value>0</value>

- <key>tr_chan</key>

- <value>0</value>

- <key>tr_tag</key>

- <value>""</value>

- <key>color1</key>

- <key>style1</key>

- <value>1</value>

- <key>marker1</key>

- <key>alpha1</key>

- <value>1.0</value>

- <key>label2</key>

- <value></value>

- <key>width2</key>

- <value>1</value>

- <key>style2</key>

- <value>1</value>

- <key>alpha2</key>

- <value>1.0</value>

- <key>label3</key>

- <value></value>

- <key>width3</key>

- <value>1</value>

- <key>style3</key>

- <value>1</value>

- <key>alpha3</key>

- <value>1.0</value>

- <key>label4</key>

- <value></value>

- <key>width4</key>

- <value>1</value>

- <key>style4</key>

- <value>1</value>

- <key>alpha4</key>

- <value>1.0</value>

- <key>label5</key>

- <value></value>

- <key>width5</key>

- <value>1</value>

- <key>style5</key>

- <value>1</value>

- <key>alpha5</key>

- <value>1.0</value>

- <key>label6</key>

- <value></value>

- <key>width6</key>

- <value>1</value>

- <key>style6</key>

- <value>1</value>

- <key>alpha6</key>

- <value>1.0</value>

- <key>label7</key>

- <value></value>

- <key>width7</key>

- <value>1</value>

- <key>style7</key>

- <value>1</value>

- <key>alpha7</key>

- <value>1.0</value>

- <key>label8</key>

- <value></value>

- <key>width8</key>

- <value>1</value>

- <key>style8</key>

- <value>1</value>

- <key>alpha8</key>

- <value>1.0</value>

- <key>label9</key>

- <value></value>

- <key>width9</key>

- <value>1</value>

- <key>style9</key>

- <value>1</value>

- <key>alpha9</key>

- <value>1.0</value>

- </param>

- <param>

- <key>label10</key>

- <value></value>

- <key>width10</key>

- <key>color10</key>

- <value>"blue"</value>

- <key>style10</key>

- <key>marker10</key>

- <value>-1</value>

- <key>alpha10</key>

- <value>1.0</value>

- <key>alias</key>

- <value></value>

- <key>affinity</key>

- <value></value>

- <key>_coordinate</key>

- <value>(1014, 622)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>qtgui_time_sink_x</key>

- <key>id</key>

- <value>qtgui_time_sink_x_1_0</value>

- <key>_enabled</key>

- <value>True</value>

- <value>float</value>

- <key>name</key>

- <value>Rate</value>

- <key>size</key>

- <value>1024</value>

- <key>srate</key>

- <value>samp_rate</value>

- <key>grid</key>

- <value>False</value>

- <key>autoscale</key>

- <key>ymin</key>

- <value>-1</value>

- <key>ymax</key>

- <value>1</value>

- <key>nconnections</key>

- <value>1</value>

- <key>update_time</key>

- <value>0.10</value>

- <value>notebook@2</value>

- <key>tr_mode</key>

- <value>qtgui.TRIG_MODE_FREE</value>

- <key>tr_slope</key>

- <value>qtgui.TRIG_SLOPE_POS</value>

- <key>tr_level</key>

- <value>0.0</value>

- <key>tr_delay</key>

- <value>0</value>

- <key>tr_chan</key>

- <value>0</value>

- <key>tr_tag</key>

- <value>""</value>

- <key>color1</key>

- <key>style1</key>

- <value>1</value>

- <key>marker1</key>

- <key>alpha1</key>

- <value>1.0</value>

- <key>label2</key>

- <value></value>

- <key>width2</key>

- <value>1</value>

- <key>style2</key>

- <value>1</value>

- <key>alpha2</key>

- <value>1.0</value>

- <key>label3</key>

- <value></value>

- <key>width3</key>

- <value>1</value>

- <key>style3</key>

- <value>1</value>

- <key>alpha3</key>

- <value>1.0</value>

- <key>label4</key>

- <value></value>

- <key>width4</key>

- <value>1</value>

- <key>style4</key>

- <value>1</value>

- <key>alpha4</key>

- <value>1.0</value>

- <key>label5</key>

- <value></value>

- <key>width5</key>

- <value>1</value>

- <key>style5</key>

- <value>1</value>

- <key>alpha5</key>

- <value>1.0</value>

- <key>label6</key>

- <value></value>

- <key>width6</key>

- <value>1</value>

- <key>style6</key>

- <value>1</value>

- <key>alpha6</key>

- <value>1.0</value>

- <key>label7</key>

- <value></value>

- <key>width7</key>

- <value>1</value>

- <key>style7</key>

- <value>1</value>

- <key>alpha7</key>

- <value>1.0</value>

- <key>label8</key>

- <value></value>

- <key>width8</key>

- <value>1</value>

- <key>style8</key>

- <value>1</value>

- <key>alpha8</key>

- <value>1.0</value>

- <key>label9</key>

- <value></value>

- <key>width9</key>

- <value>1</value>

- <key>style9</key>

- <value>1</value>

- <key>alpha9</key>

- <value>1.0</value>

- </param>

- <param>

- <key>label10</key>

- <value></value>

- <key>width10</key>

- <key>color10</key>

- <value>"blue"</value>

- <key>style10</key>

- <key>marker10</key>

- <value>-1</value>

- <key>alpha10</key>

- <value>1.0</value>

- <key>alias</key>

- <value></value>

- <key>affinity</key>

- <value></value>

- <key>_coordinate</key>

- <value>(1018, 503)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>qtgui_time_sink_x</key>

- <key>id</key>

- <value>qtgui_time_sink_x_1</value>

- <key>_enabled</key>

- <value>True</value>

- <key>name</key>

- <value>Error</value>

- <key>size</key>

- <value>1024</value>

- <key>srate</key>

- <value>samp_rate</value>

- <key>grid</key>

- <value>False</value>

- <key>autoscale</key>

- <key>ymin</key>

- <value>-1</value>

- <key>ymax</key>

- <value>1</value>

- <key>nconnections</key>

- <value>1</value>

- <key>update_time</key>

- <value>0.10</value>

- <value>notebook@0</value>

- <key>tr_mode</key>

- <value>qtgui.TRIG_MODE_FREE</value>

- <key>tr_slope</key>

- <value>qtgui.TRIG_SLOPE_POS</value>

- <key>tr_level</key>

- <value>0.0</value>

- <key>tr_delay</key>

- <value>0</value>

- <key>tr_chan</key>

- <value>0</value>

- <key>tr_tag</key>

- <value>""</value>

- <key>color1</key>

- <key>style1</key>

- <value>1</value>

- <key>marker1</key>

- <key>alpha1</key>

- <value>1.0</value>

- <key>label2</key>

- <value></value>

- <key>width2</key>

- <value>1</value>

- <key>style2</key>

- <value>1</value>

- <key>alpha2</key>

- <value>1.0</value>

- <key>label3</key>

- <value></value>

- <key>width3</key>

- <value>1</value>

- <key>style3</key>

- <value>1</value>

- <key>alpha3</key>

- <value>1.0</value>

- <key>label4</key>

- <value></value>

- <key>width4</key>

- <value>1</value>

- <key>style4</key>

- <value>1</value>

- <key>alpha4</key>

- <value>1.0</value>

- <key>label5</key>

- <value></value>

- <key>width5</key>

- <value>1</value>

- <key>style5</key>

- <value>1</value>

- <key>alpha5</key>

- <value>1.0</value>

- <key>label6</key>

- <value></value>

- <key>width6</key>

- <value>1</value>

- <key>style6</key>

- <value>1</value>

- <key>alpha6</key>

- <value>1.0</value>

- <key>label7</key>

- <value></value>

- <key>width7</key>

- <value>1</value>

- <key>style7</key>

- <value>1</value>

- <key>alpha7</key>

- <value>1.0</value>

- <key>label8</key>

- <value></value>

- <key>width8</key>

- <value>1</value>

- <key>style8</key>

- <value>1</value>

- <key>alpha8</key>

- <value>1.0</value>

- <key>label9</key>

- <value></value>

- <key>width9</key>

- <value>1</value>

- <key>style9</key>

- <value>1</value>

- <key>alpha9</key>

- <value>1.0</value>

- </param>

- <param>

- <key>label10</key>

- <value></value>

- <key>width10</key>

- <key>color10</key>

- <value>"blue"</value>

- <key>style10</key>

- <key>marker10</key>

- <value>-1</value>

- <key>alpha10</key>

- <value>1.0</value>

- <key>alias</key>

- <value></value>

- <key>affinity</key>

- <value></value>

- <key>_coordinate</key>

- <value>(1017, 378)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>qtgui_time_sink_x</key>

- <key>id</key>

- <value>qtgui_time_sink_x_0_0</value>

- <key>_enabled</key>

- <value>True</value>

- <value>complex</value>

- <key>name</key>

- <value>Scope Plot</value>

- <key>size</key>

- <value>1024</value>

- <key>srate</key>

- <value>samp_rate</value>

- <key>grid</key>

- <value>False</value>

- <key>autoscale</key>

- <value>False</value>

- <key>ymin</key>

- <value>-1</value>

- <key>ymax</key>

- <value>1</value>

- <key>nconnections</key>

- <value>1</value>

- <key>update_time</key>

- <value>0.10</value>

- <value></value>

- <key>tr_mode</key>

- <value>qtgui.TRIG_MODE_FREE</value>

- <key>tr_slope</key>

- <value>qtgui.TRIG_SLOPE_POS</value>

- <key>tr_level</key>

- <value>0.0</value>

- <key>tr_delay</key>

- <value>0</value>

- <key>tr_chan</key>

- <value>0</value>

- <key>tr_tag</key>

- <value>""</value>

- <key>color1</key>

- <key>style1</key>

- <value>1</value>

- <key>marker1</key>

- <key>alpha1</key>

- <value>1.0</value>

- <key>label2</key>

- <value></value>

- <key>width2</key>

- <value>1</value>

- <key>style2</key>

- <value>1</value>

- <key>alpha2</key>

- <value>1.0</value>

- <key>label3</key>

- <value></value>

- <key>width3</key>

- <value>1</value>

- <key>style3</key>

- <value>1</value>

- <key>alpha3</key>

- <value>1.0</value>

- <key>label4</key>

- <value></value>

- <key>width4</key>

- <value>1</value>

- <key>style4</key>

- <value>1</value>

- <key>alpha4</key>

- <value>1.0</value>

- <key>label5</key>

- <value></value>

- <key>width5</key>

- <value>1</value>

- <key>style5</key>

- <value>1</value>

- <key>alpha5</key>

- <value>1.0</value>

- <key>label6</key>

- <value></value>

- <key>width6</key>

- <value>1</value>

- <key>style6</key>

- <value>1</value>

- <key>alpha6</key>

- <value>1.0</value>

- <key>label7</key>

- <value></value>

- <key>width7</key>

- <value>1</value>

- <key>style7</key>

- <value>1</value>

- <key>alpha7</key>

- <value>1.0</value>

- <key>label8</key>

- <value></value>

- <key>width8</key>

- <value>1</value>

- <key>style8</key>

- <value>1</value>

- <key>alpha8</key>

- <value>1.0</value>

- <key>label9</key>

- <value></value>

- <key>width9</key>

- <value>1</value>

- <key>style9</key>

- <value>1</value>

- <key>alpha9</key>

- <value>1.0</value>

- </param>

- <param>

- <key>label10</key>

- <value></value>

- </param>

- <param>

- <key>width10</key>

- <key>color10</key>

- <value>"blue"</value>

- </param>

- <param>

- <key>style10</key>

- <key>marker10</key>

- <value>-1</value>

- </param>

- <param>

- <key>alpha10</key>

- <value>1.0</value>

- </param>

- <param>

- <key>alias</key>

- <value></value>

- </param>

- <param>

- <key>affinity</key>

- <value></value>

- </param>

- <param>

- <key>_coordinate</key>

- <value>(1029, 281)</value>

- </param>

- <param>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>variable_qtgui_range</key>

- <key>id</key>

- <value>time_bw</value>

- <key>_enabled</key>

- <value>True</value>

- <key>label</key>

- <value>Timing Loop BW</value>

- <key>value</key>

- <key>start</key>

- <key>stop</key>

- <value>.1</value>

- </param>

- <param>

- <key>step</key>

- <value>.001</value>

- </param>

- <param>

- <key>widget</key>

- <value>counter_slider</value>

- </param>

- <param>

- <key>orient</key>

- <value>Qt.Horizontal</value>

- </param>

- <param>

- <key>min_len</key>

- <value>200</value>

- </param>

- <param>

- <key>gui_hint</key>

- <value>1,2,1,1</value>

- </param>

- <param>

- <key>alias</key>

- <value></value>

- </param>

- <param>

- <key>_coordinate</key>

- <value>(451, 0)</value>

- <key>_rotation</key>

- <value>0</value>

- </block>

- <block>

- <key>digital_pfb_clock_sync_xxx</key>

- <key>id</key>

- <value>digital_pfb_clock_sync_xxx_0</value>

- <key>_enabled</key>

- <value>True</value>

- <value>ccf</value>

- </param>

- <param>

- <key>sps</key>

- <value>spb</value>

- </param>

- <param>

- <key>loop_bw</key>

- <value>time_bw</value>

- </param>

- <param>

- <key>taps</key>

- <value>firdes.root_raised_cosine(nfilts, nfilts*spb, 1.0, rolloff, 44*nfilts)</value>

- <key>filter_size</key>

- <value>nfilts</value>

- <key>init_phase</key>

- <value>16</value>

- <key>max_dev</key>

- <value>1.5</value>

- <key>osps</key>

- <key>alias</key>

- <value></value>

- </param>

- <param>

- <key>affinity</key>

- <value></value>

- </param>

- <param>

- <key>minoutbuf</key>

- <value>0</value>

- </param>

- <param>

- <key>maxoutbuf</key>

- <value>0</value>

- </param>

- <param>

- <key>_coordinate</key>

- <value>(467, 403)</value>

- </param>

- <param>

- <key>_rotation</key>

- <value>0</value>

- <source_block_id>blocks_throttle_0</source_block_id>

- <sink_block_id>digital_pfb_clock_sync_xxx_0</sink_block_id>

- <source_block_id>pfb_arb_resampler_xxx_0</source_block_id>

- <sink_block_id>blocks_multiply_const_vxx_0</sink_block_id>

- <source_block_id>digital_chunks_to_symbols_xx</source_block_id>

- <sink_block_id>pfb_arb_resampler_xxx_0</sink_block_id>

- <source_block_id>analog_random_source_x</source_block_id>

- <sink_block_id>digital_chunks_to_symbols_xx</sink_block_id>

- <source_block_id>blocks_multiply_const_vxx_0</source_block_id>

- <sink_block_id>channels_channel_model_0</sink_block_id>

- <source_block_id>blocks_multiply_const_vxx_0</source_block_id>

- <sink_block_id>qtgui_time_sink_x_0</sink_block_id>

- <source_key>0</source_key>

- <sink_block_id>qtgui_time_sink_x_1</sink_block_id>

- <source_key>1</source_key>

- <sink_key>0</sink_key>

- </connection>

- <connection>

- <source_block_id>digital_pfb_clock_sync_xxx_0</source_block_id>

- "Cheetah >= 2.0.0"

- "import Cheetah; assert Cheetah.Version >= '2.0.0'"

- CHEETAH_FOUND

-)

-

-GR_PYTHON_CHECK_MODULE_RAW(

- CHEETAH_FOUND

- <block>bus_sink</block>

- <block>bus_source</block>

- <block>bus_structure_sink</block>

- <block>bus_structure_source</block>

-

- <block>epy_block</block>

-<?xml version="1.0"?>

-<!--

-###################################################

-##Bus Sink

-###################################################

- -->

-<block>

- <name>Bus Sink</name>

- <key>bus_sink</key>

- <make>$yesno.yesno</make>

-

- <param>

- <name>On/Off</name>

- <key>yesno</key>

- <type>enum</type>

- <option>

- <name>On</name>

- <key>on</key>

- <opt>yesno:True</opt>

- </option>

- <option>

- <name>Off</name>

- <key>off</key>

- <opt>yesno:False</opt>

- </option>

- </param>

-</block>

-<?xml version="1.0"?>

-<!--

-###################################################

-##Bus Sink

-###################################################

- -->

-<block>

- <name>Bus Source</name>

- <key>bus_source</key>

- <make>$yesno.yesno</make>

-

- <param>

- <name>On/Off</name>

- <key>yesno</key>

- <type>enum</type>

- <option>

- <name>On</name>

- <key>on</key>

- <opt>yesno:True</opt>

- </option>

- <option>

- <name>Off</name>

- <key>off</key>

- <opt>yesno:False</opt>

- </option>

- </param>

-</block>

-<?xml version="1.0"?>

-<!--

-###################################################

-##Bus Sink

-###################################################

- -->

-<block>

- <name>Bus Sink Structure</name>

- <key>bus_structure_sink</key>

- <make>None</make>

-

- <param>

- <name>Structure</name>

- <key>struct</key>

- <value></value>

- <type>raw</type>

- </param>

-</block>

-<?xml version="1.0"?>

-<!--

-###################################################

-##Bus Sink

-###################################################

- -->

-<block>

- <name>Bus Source Structure</name>

- <key>bus_structure_source</key>

- <make>None</make>

-

- <param>

- <name>Structure</name>

- <key>struct</key>

- <value></value>

- <type>raw</type>

- </param>

-</block>

-<?xml version="1.0"?>

-<block>

- <name>Python Block</name>

- <key>epy_block</key>

- <import></import>

- <make></make>

- <param><!-- Cache the last working block IO to keep FG sane -->

- <name>Block Io</name>

- <key>_io_cache</key>

- <type>string</type>

- <hide>all</hide>

- </param>

- <param>

- <name>Code</name>

- <key>_source_code</key>

- <value>"""

-Embedded Python Blocks:

-

-Each time this file is saved, GRC will instantiate the first class it finds

-to get ports and parameters of your block. The arguments to __init__ will

-be the parameters. All of them are required to have default values!

-"""

-

-import numpy as np

-from gnuradio import gr

-

-

-class blk(gr.sync_block): # other base classes are basic_block, decim_block, interp_block

- """Embedded Python Block example - a simple multiply const"""

-

- def __init__(self, example_param=1.0): # only default arguments here

- """arguments to this function show up as parameters in GRC"""

- gr.sync_block.__init__(

- self,

- name='Embedded Python Block', # will show up in GRC

- in_sig=[np.complex64],

- out_sig=[np.complex64]

- )

- # if an attribute with the same name as a parameter is found,

- # a callback is registered (properties work, too).

- self.example_param = example_param

-

- def work(self, input_items, output_items):

- """example: multiply with constant"""

- output_items[0][:] = input_items[0] * self.example_param

- return len(output_items[0])

-</value>

- <type>_multiline_python_external</type>

- <hide>part</hide>

- </param>

- <doc>This block represents an arbitrary GNU Radio Python Block.

-

-Its source code can be accessed through the parameter 'Code' which opens your editor. Each time you save changes in the editor, GRC will update the block. This includes the number, names and defaults of the parameters, the ports (stream and message) and the block name and documentation.

-

-Block Documentation:

-(will be replaced the docstring of your block class)

-</doc>

-</block>

-<?xml version="1.0"?>

-<block>

- <name>Python Module</name>

- <key>epy_module</key>

- <import>import $id # embedded python module</import>

- <make></make>

- <param>

- <name>Code</name>

- <key>source_code</key>

- <value># this module will be imported in the into your flowgraph</value>

- <type>_multiline_python_external</type>

- <hide>part</hide>

- </param>

- <doc>This block lets you embed a python module in your flowgraph.

-

-Code you put in this module is accessible in other blocks using the ID of this

-block. Example:

-

-If you put

-

- a = 2

-

- def double(arg):

- return 2 * arg

-

-in a Python Module Block with the ID 'stuff' you can use code like

-

- stuff.a # evals to 2

- stuff.double(3) # evals to 6

-

-to set parameters of other blocks in your flowgraph.</doc>

-</block>

-<?xml version="1.0"?>

-<!--

-###################################################

-##GNU Radio default domain 'gr_message'

-###################################################

- -->

- <domain>

- <name>GR Message</name>

- <key>gr_message</key>

- <color>#000</color>

- <multiple_sources>True</multiple_sources>

- <connection>

- <source_domain>gr_message</source_domain>

- <sink_domain>gr_message</sink_domain>

- <make>#slurp

- self.msg_connect($make_port_sig($source), $make_port_sig($sink))#slurp

- </make>

- </connection>

-</domain>

-<?xml version="1.0"?>

-<!--

-###################################################

-##GNU Radio default domain 'gr_stream'

-###################################################

- -->

- <domain>

- <name>GR Stream</name>

- <key>gr_stream</key>

- <color>#000</color>

- <connection>

- <source_domain>gr_stream</source_domain>

- <sink_domain>gr_stream</sink_domain>

- <make>#slurp

- self.connect($make_port_sig($source), $make_port_sig($sink))#slurp

- </make>

- </connection>

-</domain>

- <import>$import</import>

- <key>import</key>

- <hide>#if $generate_options() == 'qt_gui' then ('part' if $run() else 'none') else 'all'#</hide>

- <hide>#if $generate_options() == 'qt_gui' then ('none' if $qt_qss_theme() else 'part') else 'all'#</hide>

-from .core.Platform import Platform

-"""

-Copyright 2008-2015 Free Software Foundation, Inc.

-This file is part of GNU Radio

-

-GNU Radio Companion is free software; you can redistribute it and/or

-modify it under the terms of the GNU General Public License

-as published by the Free Software Foundation; either version 2

-of the License, or (at your option) any later version.

-

-GNU Radio Companion is distributed in the hope that it will be useful,

-but WITHOUT ANY WARRANTY; without even the implied warranty of

-MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

-GNU General Public License for more details.

-

-You should have received a copy of the GNU General Public License

-along with this program; if not, write to the Free Software

-Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA

-"""

-

-from __future__ import absolute_import

-

-import collections

-import itertools

-import ast

-

-import six

-from six.moves import map, range

-

-from Cheetah.Template import Template

-

-from . import utils

-

-from . Constants import (

- BLOCK_FLAG_NEED_QT_GUI,

- ADVANCED_PARAM_TAB,

- BLOCK_FLAG_THROTTLE, BLOCK_FLAG_DISABLE_BYPASS,

- BLOCK_FLAG_DEPRECATED,

-)

-from . Element import Element, lazy_property

-

-

-def _get_elem(iterable, key):

- items = list(iterable)

- for item in items:

- if item.key == key:

- return item

- return ValueError('Key "{}" not found in {}.'.format(key, items))

-

-

-class Block(Element):

-

- is_block = True

-

- STATE_LABELS = ['disabled', 'enabled', 'bypassed']

-

- def __init__(self, parent, key, name, **n):

- """Make a new block from nested data."""

- super(Block, self).__init__(parent)

-

- self.key = key

- self.name = name

- self.category = [cat.strip() for cat in n.get('category', '').split('/') if cat.strip()]

- self.flags = n.get('flags', '')

- self._doc = n.get('doc', '').strip('\n').replace('\\\n', '')

-

- # Backwards compatibility

- if n.get('throttle') and BLOCK_FLAG_THROTTLE not in self.flags:

- self.flags += BLOCK_FLAG_THROTTLE

-

- self._imports = [i.strip() for i in n.get('import', [])]

- self._make = n.get('make')

- self._var_make = n.get('var_make')

- self._var_value = n.get('var_value', '$value')

- self._checks = n.get('check', [])

- self._callbacks = n.get('callback', [])

-

- self._grc_source = n.get('grc_source', '')

- self.block_wrapper_path = n.get('block_wrapper_path')

-

- # Virtual source/sink and pad source/sink blocks are

- # indistinguishable from normal GR blocks. Make explicit

- # checks for them here since they have no work function or

- # buffers to manage.

- self.is_virtual_or_pad = self.key in (

- "virtual_source", "virtual_sink", "pad_source", "pad_sink")

- self.is_variable = self.key.startswith('variable')

- self.is_import = (self.key == 'import')

-

- # Disable blocks that are virtual/pads or variables

- if self.is_virtual_or_pad or self.is_variable:

- self.flags += BLOCK_FLAG_DISABLE_BYPASS

-

- params_n = n.get('param', [])

- sources_n = n.get('source', [])

- sinks_n = n.get('sink', [])

-

- # Get list of param tabs

- self.params = collections.OrderedDict()

- self._init_params(

- params_n=params_n,

- has_sinks=len(sinks_n),

- has_sources=len(sources_n)

- )

-

- self.sources = self._init_ports(sources_n, direction='source')

- self.sinks = self._init_ports(sinks_n, direction='sink')

- self.active_sources = [] # on rewrite

- self.active_sinks = [] # on rewrite

-

- self.states = {'_enabled': True}

-

- self._init_bus_ports(n)

-

- def _init_params(self, params_n, has_sources, has_sinks):

- param_factory = self.parent_platform.get_new_param

-

- def add_param(key, **kwargs):

- self.params[key] = param_factory(self, key=key, **kwargs)

-

- add_param(key='id', name='ID', type='id')

-

- if not (self.is_virtual_or_pad or self.is_variable or self.key == 'options'):

- add_param(key='alias', name='Block Alias', type='string',

- hide='part', tab=ADVANCED_PARAM_TAB)

-

- if not self.is_virtual_or_pad and (has_sources or has_sinks):

- add_param(key='affinity', name='Core Affinity', type='int_vector',

- hide='part', tab=ADVANCED_PARAM_TAB)

-

- if not self.is_virtual_or_pad and has_sources:

- add_param(key='minoutbuf', name='Min Output Buffer', type='int',

- hide='part', value='0', tab=ADVANCED_PARAM_TAB)

- add_param(key='maxoutbuf', name='Max Output Buffer', type='int',

- hide='part', value='0', tab=ADVANCED_PARAM_TAB)

-

- base_params_n = {}

- for param_n in params_n:

- key = param_n['key']

- if key in self.params:

- raise Exception('Key "{}" already exists in params'.format(key))

-

- base_key = param_n.get('base_key', None)

- param_n_ext = base_params_n.get(base_key, {}).copy()

- param_n_ext.update(param_n)

- self.params[key] = param_factory(self, **param_n_ext)

- base_params_n[key] = param_n_ext

-

- add_param(key='comment', name='Comment', type='_multiline', hide='part',

- value='', tab=ADVANCED_PARAM_TAB)

-

- def _init_ports(self, ports_n, direction):

- port_factory = self.parent_platform.get_new_port

- ports = []

- port_keys = set()

- stream_port_keys = itertools.count()

- for i, port_n in enumerate(ports_n):

- port_n.setdefault('key', str(next(stream_port_keys)))

- port = port_factory(parent=self, direction=direction, **port_n)

- key = port.key

- if key in port_keys:

- raise Exception('Key "{}" already exists in {}'.format(key, direction))

- port_keys.add(key)

- ports.append(port)

- return ports

-

- ##############################################

- # validation and rewrite

- ##############################################

- def rewrite(self):

- """

- Add and remove ports to adjust for the nports.

- """

- Element.rewrite(self)

-

- def rekey(ports):

- """Renumber non-message/message ports"""

- domain_specific_port_index = collections.defaultdict(int)

- for port in [p for p in ports if p.key.isdigit()]:

- domain = port.domain

- port.key = str(domain_specific_port_index[domain])

- domain_specific_port_index[domain] += 1

-

- # Adjust nports

- for ports in (self.sources, self.sinks):

- self._rewrite_nports(ports)

- self.back_ofthe_bus(ports)

- rekey(ports)

-

- self._rewrite_bus_ports()

-

- # disconnect hidden ports

- for port in itertools.chain(self.sources, self.sinks):

- if port.get_hide():

- for connection in port.get_connections():

- self.parent_flowgraph.remove_element(connection)

-

-

- self.active_sources = [p for p in self.get_sources_gui() if not p.get_hide()]

- self.active_sinks = [p for p in self.get_sinks_gui() if not p.get_hide()]

-

- def _rewrite_nports(self, ports):

- for port in ports:

- if port.is_clone: # Not a master port and no left-over clones

- continue

- nports = port.get_nports() or 1

- for clone in port.clones[nports-1:]:

- # Remove excess connections

- for connection in clone.get_connections():

- self.parent_flowgraph.remove_element(connection)

- port.remove_clone(clone)

- ports.remove(clone)

- # Add more cloned ports

- for j in range(1 + len(port.clones), nports):

- clone = port.add_clone()

- ports.insert(ports.index(port) + j, clone)

-

- def validate(self):

- """

- Validate this block.

- Call the base class validate.

- Evaluate the checks: each check must evaluate to True.

- """

- Element.validate(self)

- self._run_checks()

- self._validate_generate_mode_compat()

- self._validate_var_value()

-

- def _run_checks(self):

- """Evaluate the checks"""

- for check in self._checks:

- check_res = self.resolve_dependencies(check)

- try:

- if not self.parent.evaluate(check_res):

- self.add_error_message('Check "{}" failed.'.format(check))

- except:

- self.add_error_message('Check "{}" did not evaluate.'.format(check))

-

- def _validate_generate_mode_compat(self):

- """check if this is a GUI block and matches the selected generate option"""

- current_generate_option = self.parent.get_option('generate_options')

-

- def check_generate_mode(label, flag, valid_options):

- block_requires_mode = (

- flag in self.flags or self.name.upper().startswith(label)

- )

- if block_requires_mode and current_generate_option not in valid_options:

- self.add_error_message("Can't generate this block in mode: {} ".format(

- repr(current_generate_option)))

-

- check_generate_mode('QT GUI', BLOCK_FLAG_NEED_QT_GUI, ('qt_gui', 'hb_qt_gui'))

-

- def _validate_var_value(self):

- """or variables check the value (only if var_value is used)"""

- if self.is_variable and self._var_value != '$value':

- value = self._var_value

- try:

- value = self.get_var_value()

- self.parent.evaluate(value)

- except Exception as err:

- self.add_error_message('Value "{}" cannot be evaluated:\n{}'.format(value, err))

-

- ##############################################

- # props

- ##############################################

-

- @lazy_property

- def is_throtteling(self):

- return BLOCK_FLAG_THROTTLE in self.flags

-

- @lazy_property

- def is_deprecated(self):

- return BLOCK_FLAG_DEPRECATED in self.flags

-

- @property

- def documentation(self):

- documentation = self.parent_platform.block_docstrings.get(self.key, {})

- from_xml = self._doc.strip()

- if from_xml:

- documentation[''] = from_xml

- return documentation

-

- @property

- def comment(self):

- return self.params['comment'].get_value()

-

- @property

- def state(self):

- """Gets the block's current state."""

- try:

- return self.STATE_LABELS[int(self.states['_enabled'])]

- except ValueError:

- return 'enabled'

-

- @state.setter

- def state(self, value):

- """Sets the state for the block."""

- try:

- encoded = self.STATE_LABELS.index(value)

- except ValueError:

- encoded = 1

- self.states['_enabled'] = encoded

-

- # Enable/Disable Aliases

- @property

- def enabled(self):

- """Get the enabled state of the block"""

- return self.state != 'disabled'

-

- ##############################################

- # Getters (old)

- ##############################################

-

- def get_imports(self, raw=False):

- """

- Resolve all import statements.

- Split each import statement at newlines.

- Combine all import statements into a list.

- Filter empty imports.

-

- Returns:

- a list of import statements

- """

- if raw:

- return self._imports

- return [i for i in sum((self.resolve_dependencies(i).split('\n')

- for i in self._imports), []) if i]

-

- def get_make(self, raw=False):

- if raw:

- return self._make

- return self.resolve_dependencies(self._make)

-

- def get_var_make(self):

- return self.resolve_dependencies(self._var_make)

-

- def get_var_value(self):

- return self.resolve_dependencies(self._var_value)

-

- def get_callbacks(self):

- """

- Get a list of function callbacks for this block.

-

- Returns:

- a list of strings

- """

- def make_callback(callback):

- callback = self.resolve_dependencies(callback)

- if 'self.' in callback:

- return callback

- return 'self.{}.{}'.format(self.get_id(), callback)

- return [make_callback(c) for c in self._callbacks]

-

- def is_virtual_sink(self):

- return self.key == 'virtual_sink'

-

- def is_virtual_source(self):

- return self.key == 'virtual_source'

-

- # Block bypassing

- def get_bypassed(self):

- """

- Check if the block is bypassed

- """

- return self.state == 'bypassed'

-

- def set_bypassed(self):

- """

- Bypass the block

-

- Returns:

- True if block chagnes state

- """

- if self.state != 'bypassed' and self.can_bypass():

- self.state = 'bypassed'

- return True

- return False

-

- def can_bypass(self):

- """ Check the number of sinks and sources and see if this block can be bypassed """

- # Check to make sure this is a single path block

- # Could possibly support 1 to many blocks

- if len(self.sources) != 1 or len(self.sinks) != 1:

- return False

- if not (self.sources[0].get_type() == self.sinks[0].get_type()):

- return False

- if BLOCK_FLAG_DISABLE_BYPASS in self.flags:

- return False

- return True

-

- def __str__(self):

- return 'Block - {} - {}({})'.format(self.get_id(), self.name, self.key)

-

- def get_id(self):

- return self.params['id'].get_value()

-

- def get_ports(self):

- return self.sources + self.sinks

-

- def get_ports_gui(self):

- return self.get_sources_gui() + self.get_sinks_gui()

-

- def active_ports(self):

- return itertools.chain(self.active_sources, self.active_sinks)

-

- def get_children(self):

- return self.get_ports() + list(self.params.values())

-

- def get_children_gui(self):

- return self.get_ports_gui() + self.params.values()

-

- ##############################################

- # Access

- ##############################################

-

- def get_param(self, key):

- return self.params[key]

-

- def get_sink(self, key):

- return _get_elem(self.sinks, key)

-

- def get_sinks_gui(self):

- return self.filter_bus_port(self.sinks)

-

- def get_source(self, key):

- return _get_elem(self.sources, key)

-

- def get_sources_gui(self):

- return self.filter_bus_port(self.sources)

-

- def get_connections(self):

- return sum((port.get_connections() for port in self.get_ports()), [])

-

- ##############################################

- # Resolve

- ##############################################

- def resolve_dependencies(self, tmpl):

- """

- Resolve a paramater dependency with cheetah templates.

-

- Args:

- tmpl: the string with dependencies

-

- Returns:

- the resolved value

- """

- tmpl = str(tmpl)

- if '$' not in tmpl:

- return tmpl

- # TODO: cache that

- n = {key: param.template_arg for key, param in six.iteritems(self.params)}

- try:

- return str(Template(tmpl, n))

- except Exception as err:

- return "Template error: {}\n {}".format(tmpl, err)

-

- ##############################################

- # Import/Export Methods

- ##############################################

- def export_data(self):

- """

- Export this block's params to nested data.

-

- Returns:

- a nested data odict

- """

- n = collections.OrderedDict()

- n['key'] = self.key

-

- params = (param.export_data() for param in six.itervalues(self.params))

- states = (collections.OrderedDict([('key', key), ('value', repr(value))])

- for key, value in six.iteritems(self.states))

- n['param'] = sorted(itertools.chain(states, params), key=lambda p: p['key'])

-

- if any('bus' in a.get_type() for a in self.sinks):

- n['bus_sink'] = '1'

- if any('bus' in a.get_type() for a in self.sources):

- n['bus_source'] = '1'

- return n

-

- def import_data(self, n):

- """

- Import this block's params from nested data.

- Any param keys that do not exist will be ignored.

- Since params can be dynamically created based another param,

- call rewrite, and repeat the load until the params stick.

- This call to rewrite will also create any dynamic ports

- that are needed for the connections creation phase.

-

- Args:

- n: the nested data odict

- """

- param_data = {p['key']: p['value'] for p in n.get('param', [])}

-

- for key in self.states:

- try:

- self.states[key] = ast.literal_eval(param_data.pop(key))

- except (KeyError, SyntaxError, ValueError):

- pass

-

- def get_hash():

- return hash(tuple(hash(v) for v in self.params.values()))

-

- pre_rewrite_hash = -1

- while pre_rewrite_hash != get_hash():

- for key, value in six.iteritems(param_data):

- try:

- self.params[key].set_value(value)

- except KeyError:

- continue

- # Store hash and call rewrite

- pre_rewrite_hash = get_hash()

- self.rewrite()

-

- self._import_bus_stuff(n)

-

- ##############################################

- # Bus ports stuff

- ##############################################

-

- def get_bus_structure(self, direction):

- bus_structure = self.resolve_dependencies(self._bus_structure[direction])

- if not bus_structure:

- return

- try:

- return self.parent_flowgraph.evaluate(bus_structure)

- except:

- return

-

- @staticmethod

- def back_ofthe_bus(portlist):

- portlist.sort(key=lambda p: p._type == 'bus')

-

- @staticmethod

- def filter_bus_port(ports):

- buslist = [p for p in ports if p._type == 'bus']

- return buslist or ports

-

- def _import_bus_stuff(self, n):

- bus_sinks = n.get('bus_sink', [])

- if len(bus_sinks) > 0 and not self._bussify_sink:

- self.bussify('sink')

- elif len(bus_sinks) > 0:

- self.bussify('sink')

- self.bussify('sink')

- bus_sources = n.get('bus_source', [])

- if len(bus_sources) > 0 and not self._bussify_source:

- self.bussify('source')

- elif len(bus_sources) > 0:

- self.bussify('source')

- self.bussify('source')

-

- def form_bus_structure(self, direc):

- ports = self.sources if direc == 'source' else self.sinks

- struct = self.get_bus_structure(direc)

-

- if not struct:

- struct = [list(range(len(ports)))]

-

- elif any(isinstance(p.get_nports(), int) for p in ports):

- last = 0

- structlet = []

- for port in ports:

- nports = port.get_nports()

- if not isinstance(nports, int):

- continue

- structlet.extend(a + last for a in range(nports))

- last += nports

- struct = [structlet]

-

- self.current_bus_structure[direc] = struct

- return struct

-

- def bussify(self, direc):

- ports = self.sources if direc == 'source' else self.sinks

-

- for elt in ports:

- for connect in elt.get_connections():

- self.parent.remove_element(connect)

-

- if ports and all('bus' != p.get_type() for p in ports):

- struct = self.current_bus_structure[direc] = self.form_bus_structure(direc)

- n = {'type': 'bus'}

- if ports[0].get_nports():

- n['nports'] = '1'

-

- for i, structlet in enumerate(struct):

- name = 'bus{}#{}'.format(i, len(structlet))

- port = self.parent_platform.get_new_port(

- self, direction=direc, key=str(len(ports)), name=name, **n)

- ports.append(port)

- elif any('bus' == p.get_type() for p in ports):

- get_p_gui = self.get_sources_gui if direc == 'source' else self.get_sinks_gui

- for elt in get_p_gui():

- ports.remove(elt)

- self.current_bus_structure[direc] = ''

-

- def _init_bus_ports(self, n):

- self.current_bus_structure = {'source': '', 'sink': ''}

- self._bus_structure = {'source': n.get('bus_structure_source', ''),

- 'sink': n.get('bus_structure_sink', '')}

- self._bussify_sink = n.get('bus_sink')

- self._bussify_source = n.get('bus_source')

- if self._bussify_sink:

- self.bussify('sink')

- if self._bussify_source:

- self.bussify('source')

-

- def _rewrite_bus_ports(self):

- return # fixme: probably broken

-

- def doit(ports, ports_gui, direc):

- if not self.current_bus_structure[direc]:

- return

-

- bus_structure = self.form_bus_structure(direc)

- for port in ports_gui[len(bus_structure):]:

- for connect in port.get_connections():

- self.parent_flowgraph.remove_element(connect)

- ports.remove(port)

-

- port_factory = self.parent_platform.get_new_port

-

- if len(ports_gui) < len(bus_structure):

- for i in range(len(ports_gui), len(bus_structure)):

- port = port_factory(self, direction=direc, key=str(1 + i),

- name='bus', type='bus')

- ports.append(port)

-

- doit(self.sources, self.get_sources_gui(), 'source')

- doit(self.sinks, self.get_sinks_gui(), 'sink')

-

- if 'bus' in [a.get_type() for a in self.get_sources_gui()]:

- for i in range(len(self.get_sources_gui())):

- if not self.get_sources_gui()[i].get_connections():

- continue

- source = self.get_sources_gui()[i]

- sink = []

-

- for j in range(len(source.get_connections())):

- sink.append(source.get_connections()[j].sink_port)

- for elt in source.get_connections():

- self.parent_flowgraph.remove_element(elt)

- for j in sink:

- self.parent_flowgraph.connect(source, j)

-

-

-class EPyBlock(Block):

-

- def __init__(self, flow_graph, **n):

- super(EPyBlock, self).__init__(flow_graph, **n)

- self._epy_source_hash = -1 # for epy blocks

- self._epy_reload_error = None

-

- def rewrite(self):

- Element.rewrite(self)

-

- param_blk = self.params['_io_cache']

- param_src = self.params['_source_code']

-

- src = param_src.get_value()

- src_hash = hash((self.get_id(), src))

- if src_hash == self._epy_source_hash:

- return

-

- try:

- blk_io = utils.epy_block_io.extract(src)

-

- except Exception as e:

- self._epy_reload_error = ValueError(str(e))

- try: # Load last working block io

- blk_io_args = eval(param_blk.get_value())

- if len(blk_io_args) == 6:

- blk_io_args += ([],) # add empty callbacks

- blk_io = utils.epy_block_io.BlockIO(*blk_io_args)

- except Exception:

- return

- else:

- self._epy_reload_error = None # Clear previous errors

- param_blk.set_value(repr(tuple(blk_io)))

-

- # print "Rewriting embedded python block {!r}".format(self.get_id())

-

- self._epy_source_hash = src_hash

- self.name = blk_io.name or blk_io.cls

- self._doc = blk_io.doc

- self._imports[0] = 'import ' + self.get_id()

- self._make = '{0}.{1}({2})'.format(self.get_id(), blk_io.cls, ', '.join(

- '{0}=${{ {0} }}'.format(key) for key, _ in blk_io.params))

- self._callbacks = ['{0} = ${{ {0} }}'.format(attr) for attr in blk_io.callbacks]

- self._update_params(blk_io.params)

- self._update_ports('in', self.sinks, blk_io.sinks, 'sink')

- self._update_ports('out', self.sources, blk_io.sources, 'source')

-

- super(EPyBlock, self).rewrite()

-

- def _update_params(self, params_in_src):

- param_factory = self.parent_platform.get_new_param

- params = {}

- for param in list(self.params):

- if hasattr(param, '__epy_param__'):

- params[param.key] = param

- del self.params[param.key]

-

- for key, value in params_in_src:

- try:

- param = params[key]

- if param.default == param.value:

- param.set_value(value)

- param.default = str(value)

- except KeyError: # need to make a new param

- param = param_factory(

- parent=self, key=key, type='raw', value=value,

- name=key.replace('_', ' ').title(),

- )

- setattr(param, '__epy_param__', True)

- self.params[key] = param

-

- def _update_ports(self, label, ports, port_specs, direction):

- port_factory = self.parent_platform.get_new_port

- ports_to_remove = list(ports)

- iter_ports = iter(ports)

- ports_new = []

- port_current = next(iter_ports, None)

- for key, port_type, vlen in port_specs:

- reuse_port = (

- port_current is not None and

- port_current.get_type() == port_type and

- port_current.get_vlen() == vlen and

- (key.isdigit() or port_current.key == key)

- )

- if reuse_port:

- ports_to_remove.remove(port_current)

- port, port_current = port_current, next(iter_ports, None)

- else:

- n = dict(name=label + str(key), type=port_type, key=key)

- if port_type == 'message':

- n['name'] = key

- n['optional'] = '1'

- if vlen > 1:

- n['vlen'] = str(vlen)

- port = port_factory(self, direction=direction, **n)

- ports_new.append(port)

- # replace old port list with new one

- del ports[:]

- ports.extend(ports_new)

- # remove excess port connections

- for port in ports_to_remove:

- for connection in port.get_connections():

- self.parent_flowgraph.remove_element(connection)

-

- def validate(self):

- super(EPyBlock, self).validate()

- if self._epy_reload_error:

- self.params['_source_code'].add_error_message(str(self._epy_reload_error))

-

-

-class DummyBlock(Block):

-

- is_dummy_block = True

- build_in_param_keys = 'id alias affinity minoutbuf maxoutbuf comment'

-

- def __init__(self, parent, key, missing_key, params_n):

- super(DummyBlock, self).__init__(parent=parent, key=missing_key, name='Missing Block')

- param_factory = self.parent_platform.get_new_param

- for param_n in params_n:

- key = param_n['key']

- self.params.setdefault(key, param_factory(self, key=key, name=key, type='string'))

-

- def is_valid(self):

- return False

-

- @property

- def enabled(self):

- return False

-

- def add_missing_port(self, key, dir):

- port = self.parent_platform.get_new_port(

- parent=self, direction=dir, key=key, name='?', type='',

- )

- if port.is_source:

- self.sources.append(port)

- else:

- self.sinks.append(port)

- return port

-"""

-Copyright 2016 Free Software Foundation, Inc.

-import collections

-

-from six.moves import range

-

-from . import Constants

-from .Element import Element, lazy_property

- def __init__(self, parent, porta, portb):

- porta: a port (any direction)

- portb: a port (any direction)

- source, sink = self._get_sink_source(porta, portb)

- # Ensure that this connection (source -> sink) is unique

- if self in self.parent_flowgraph.connections:

- raise LookupError('This connection between source and sink is not unique.')

-

- if self.is_bus():

- self._make_bus_connect()

- @staticmethod

- def _get_sink_source(porta, portb):

- source = sink = None

- # Separate the source and sink

- for port in (porta, portb):

- if port.is_source:

- source = port

- if port.is_sink:

- sink = port

- if not source:

- raise ValueError('Connection could not isolate source')

- if not sink:

- raise ValueError('Connection could not isolate sink')

- return source, sink

- def __str__(self):

- return 'Connection (\n\t{}\n\t\t{}\n\t{}\n\t\t{}\n)'.format(

- self.source_block, self.source_port, self.sink_block, self.sink_port,

- )

-

- def is_bus(self):

- return self.source_port.get_type() == 'bus'

-

- source_domain = self.source_port.domain

- sink_domain = self.sink_port.domain

- if (source_domain, sink_domain) not in platform.connection_templates:

- self.add_error_message('No connection known for domains "{}", "{}"'.format(

- source_domain, sink_domain))

- too_many_other_sinks = (

- not platform.domains.get(source_domain, []).get('multiple_sinks', False) and

- len(self.source_port.get_enabled_connections()) > 1

- )

- too_many_other_sources = (

- not platform.domains.get(sink_domain, []).get('multiple_sources', False) and

- len(self.sink_port.get_enabled_connections()) > 1

- )

- if too_many_other_sinks:

- self.add_error_message(

- 'Domain "{}" can have only one downstream block'.format(source_domain))

- if too_many_other_sources:

- self.add_error_message(

- 'Domain "{}" can have only one upstream block'.format(sink_domain))

-

- source_size = Constants.TYPE_TO_SIZEOF[self.source_port.get_type()] * self.source_port.get_vlen()

- sink_size = Constants.TYPE_TO_SIZEOF[self.sink_port.get_type()] * self.sink_port.get_vlen()

- n = collections.OrderedDict()

- n['source_block_id'] = self.source_block.get_id()

- n['sink_block_id'] = self.sink_block.get_id()

- n['source_key'] = self.source_port.key

- n['sink_key'] = self.sink_port.key

- return n

-

- def _make_bus_connect(self):

- source, sink = self.source_port, self.sink_port

-

- if source.get_type() == sink.get_type() == 'bus':

- raise ValueError('busses must get with busses')

-

- sources = source.get_associated_ports()

- sinks = sink.get_associated_ports()

- if len(sources) != len(sinks):

- raise ValueError('port connections must have same cardinality')

-

- for ports in zip(sources, sinks):

- self.parent_flowgraph.connect(*ports)

-import six

-FLOW_GRAPH_DTD = os.path.join(DATA_DIR, 'flow_graph.dtd')

-BLOCK_TREE_DTD = os.path.join(DATA_DIR, 'block_tree.dtd')

-DOMAIN_DTD = os.path.join(DATA_DIR, 'domain.dtd')

-GR_STREAM_DOMAIN = "gr_stream"

-GR_MESSAGE_DOMAIN = "gr_message"

-BLOCK_FLAG_THROTTLE = 'throttle'

-BLOCK_FLAG_DISABLE_BYPASS = 'disable_bypass'

-BLOCK_FLAG_NEED_QT_GUI = 'need_qt_gui'

-BLOCK_FLAG_DEPRECATED = 'deprecated'

-

-import imp

-import time

-import re

-from operator import methodcaller

-from . import Messages

-from .Element import Element

-from .utils import expr_utils, shlex

-

-_parameter_matcher = re.compile('^(parameter)$')

-_monitors_searcher = re.compile('(ctrlport_monitor)')

-_bussink_searcher = re.compile('^(bus_sink)$')

-_bussrc_searcher = re.compile('^(bus_source)$')

-_bus_struct_sink_searcher = re.compile('^(bus_structure_sink)$')

-_bus_struct_src_searcher = re.compile('^(bus_structure_source)$')

- self._timestamp = time.ctime()

- self._options_block = self.parent_platform.get_new_block(self, 'options')

- self.connections = []

- def get_imports(self):