wireshark: don't block waiting for messages
This commit is contained in:
@@ -181,11 +181,7 @@ wireshark_connector_impl::general_work(int noutput, gr_vector_int& ninput_items,
|
|||||||
gr_complex *out = (gr_complex*)output_items[0];
|
gr_complex *out = (gr_complex*)output_items[0];
|
||||||
|
|
||||||
if(!d_msg_len) {
|
if(!d_msg_len) {
|
||||||
#ifdef GR_FOO_NEW_API
|
pmt::pmt_t msg(delete_head_nowait(pmt::mp("in")));
|
||||||
pmt::pmt_t msg(delete_head_blocking(pmt::mp("in"), 100));
|
|
||||||
#else
|
|
||||||
pmt::pmt_t msg(delete_head_blocking(pmt::mp("in")));
|
|
||||||
#endif
|
|
||||||
|
|
||||||
if(!msg) {
|
if(!msg) {
|
||||||
return 0;
|
return 0;
|
||||||
|
|||||||
Reference in New Issue
Block a user