diff options
Diffstat (limited to 'grc/src')
-rw-r--r-- | grc/src/grc_gnuradio/blks2/packet.py | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/grc/src/grc_gnuradio/blks2/packet.py b/grc/src/grc_gnuradio/blks2/packet.py index a305b961e..50de99ac9 100644 --- a/grc/src/grc_gnuradio/blks2/packet.py +++ b/grc/src/grc_gnuradio/blks2/packet.py @@ -193,10 +193,9 @@ class packet_mod_base(gr.hier_block2): #create blocks msgq = gr.msg_queue(DEFAULT_MSGQ_LIMIT) msg_sink = gr.message_sink(self._item_size_in, msgq, False) #False -> blocking - copy = gr.kludge_copy(packet_source._hb.output_signature().sizeof_stream_item(0)) #connect self.connect(self, msg_sink) - self.connect(packet_source, copy, self) + self.connect(packet_source, self) #start thread _packet_encoder_thread(msgq, payload_length, packet_source.send_pkt) @@ -225,9 +224,8 @@ class packet_demod_base(gr.hier_block2): #create blocks msg_source = gr.message_source(self._item_size_out, DEFAULT_MSGQ_LIMIT) self._msgq_out = msg_source.msgq() - copy = gr.kludge_copy(packet_sink._hb.input_signature().sizeof_stream_item(0)) #connect - self.connect(self, copy, packet_sink) + self.connect(self, packet_sink) self.connect(msg_source, self) if packet_sink._hb.output_signature().sizeof_stream_item(0): self.connect(packet_sink, gr.null_sink(packet_sink._hb.output_signature().sizeof_stream_item(0))) |