diff --git a/op25/gr-op25_repeater/apps/rx.py b/op25/gr-op25_repeater/apps/rx.py index 2524aaf..7feff32 100755 --- a/op25/gr-op25_repeater/apps/rx.py +++ b/op25/gr-op25_repeater/apps/rx.py @@ -684,6 +684,8 @@ class p25_rx_block (gr.top_block): def process_ajax(self): if not self.is_http_term(): return + if self.input_q.full_p(): + return filenames = [sink.gnuplot.filename for sink in self.plot_sinks if sink.gnuplot.filename] error = None if self.options.demod_type == 'cqpsk': @@ -697,12 +699,16 @@ class p25_rx_block (gr.top_block): now = time.time() if self.options.freq_error_tracking: self.error_tracking() + if self.input_q.full_p(): + return if now < self.last_process_update + UPDATE_INTERVAL: return self.last_process_update = now self.freq_update() if self.trunk_rx is None: return ## possible race cond - just ignore + if self.input_q.full_p(): + return js = self.trunk_rx.to_json() msg = gr.message().make_from_string(js, -4, 0, 0) self.input_q.insert_tail(msg)