wireshark: blocking in wait is evil

2013-06-28 14:39:08 +02:00
parent 76a3328b3f
commit 46c9041f9c
1 changed files with 4 additions and 1 deletions
@@ -154,7 +154,10 @@ 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_blocking(pmt::mp("in")));
+		pmt::pmt_t msg = delete_head_nowait(pmt::mp("in"));
+		if(msg.get() == NULL) {
+			return 0;
+		}

 		if(pmt::is_eof_object(msg)) {
 			dout << "WIRESHARK: exiting" << std::endl;