wireshark: revert no blocking for now
This commit is contained in:
@@ -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;
|
||||
|
||||
Reference in New Issue
Block a user