message source: notify shutdown also w/ EOF
This commit is contained in:
@@ -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)));
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user