diff --git a/lib/periodic_msg_source_impl.cc b/lib/periodic_msg_source_impl.cc index 5ff8381..c716a26 100644 --- a/lib/periodic_msg_source_impl.cc +++ b/lib/periodic_msg_source_impl.cc @@ -67,7 +67,6 @@ periodic_msg_source_impl::run(periodic_msg_source_impl *instance) { d_finished = true; if(d_quit) { boost::this_thread::sleep(boost::posix_time::milliseconds(500)); - message_port_pub( pmt::mp("out"), pmt::PMT_EOF); post(pmt::mp("system"), pmt::cons(pmt::mp("done"), pmt::PMT_T)); } break; @@ -92,7 +91,6 @@ periodic_msg_source_impl::run(periodic_msg_source_impl *instance) { d_finished = true; if(d_quit) { boost::this_thread::sleep(boost::posix_time::milliseconds(500)); - message_port_pub( pmt::mp("out"), pmt::PMT_EOF); post(pmt::mp("system"), pmt::cons(pmt::mp("done"), pmt::from_long(1))); } }