diff options
| author | Bastian Bloessl <bloessl@ccs-labs.org> | 2016-04-28 15:33:59 +0200 |
|---|---|---|
| committer | Bastian Bloessl <bloessl@ccs-labs.org> | 2016-06-29 09:10:22 +0200 |
| commit | c7c6820cb823042accab0dddf031c55acb108d62 (patch) | |
| tree | 2dbe2ae20da6e55547af4181dcac5211b048c155 | |
| parent | bad298fe973c581312bfd609717404484c67ea3f (diff) | |
blocks: don't block waiting for messages
| -rw-r--r-- | gr-blocks/lib/pdu_to_tagged_stream_impl.cc | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/gr-blocks/lib/pdu_to_tagged_stream_impl.cc b/gr-blocks/lib/pdu_to_tagged_stream_impl.cc index aec5d335c4..0c48442fa7 100644 --- a/gr-blocks/lib/pdu_to_tagged_stream_impl.cc +++ b/gr-blocks/lib/pdu_to_tagged_stream_impl.cc @@ -52,10 +52,7 @@ namespace gr { int pdu_to_tagged_stream_impl::calculate_output_stream_length(const gr_vector_int &) { if (d_curr_len == 0) { - /* FIXME: This blocking call is far from ideal but is the best we - * can do at the moment - */ - pmt::pmt_t msg(delete_head_blocking(PDU_PORT_ID, 100)); + pmt::pmt_t msg(delete_head_nowait(PDU_PORT_ID)); if (msg.get() == NULL) { return 0; } |