diff options
Diffstat (limited to 'gr-zeromq/lib/sub_msg_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/sub_msg_source_impl.cc | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/gr-zeromq/lib/sub_msg_source_impl.cc b/gr-zeromq/lib/sub_msg_source_impl.cc index a8fd0a9117..3ead4025f1 100644 --- a/gr-zeromq/lib/sub_msg_source_impl.cc +++ b/gr-zeromq/lib/sub_msg_source_impl.cc @@ -89,9 +89,12 @@ void sub_msg_source_impl::readloop() #endif std::string buf(static_cast<char*>(msg.data()), msg.size()); std::stringbuf sb(buf); - pmt::pmt_t m = pmt::deserialize(sb); - - message_port_pub(d_port, m); + try { + pmt::pmt_t m = pmt::deserialize(sb); + message_port_pub(d_port, m); + } catch (pmt::exception& e) { + GR_LOG_ERROR(d_logger, std::string("Invalid PMT message: ") + e.what()); + } } else { boost::this_thread::sleep(boost::posix_time::microseconds(100)); } |