From 58ee03299aac2ea8fd279cd032ce635e33f2f9b3 Mon Sep 17 00:00:00 2001 From: Bastian Bloessl Date: Wed, 31 Jul 2013 10:21:17 +0200 Subject: [PATCH] wireshark: revert no blocking for now --- lib/wireshark_connector_impl.cc | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/lib/wireshark_connector_impl.cc b/lib/wireshark_connector_impl.cc index eff6b89..54f7a7e 100644 --- a/lib/wireshark_connector_impl.cc +++ b/lib/wireshark_connector_impl.cc @@ -154,10 +154,7 @@ wireshark_connector_impl::general_work(int noutput, gr_vector_int& ninput_items, gr_complex *out = (gr_complex*)output_items[0]; while(!d_msg_len) { - pmt::pmt_t msg = delete_head_nowait(pmt::mp("in")); - if(msg.get() == NULL) { - return 0; - } + pmt::pmt_t msg(delete_head_blocking(pmt::mp("in"))); if(pmt::is_eof_object(msg)) { dout << "WIRESHARK: exiting" << std::endl;