From 85de8f71dcb91624289eb68931f2e9288f5e8e8f Mon Sep 17 00:00:00 2001 From: Bastian Bloessl Date: Sat, 24 Oct 2015 01:09:31 +0200 Subject: [PATCH] message source: notify shutdown also w/ EOF --- lib/periodic_msg_source_impl.cc | 2 ++ 1 file changed, 2 insertions(+) diff --git a/lib/periodic_msg_source_impl.cc b/lib/periodic_msg_source_impl.cc index 1ba47c9..3d6293e 100644 --- a/lib/periodic_msg_source_impl.cc +++ b/lib/periodic_msg_source_impl.cc @@ -67,6 +67,7 @@ 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))); } break; @@ -91,6 +92,7 @@ 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))); } }