t/gr-foo
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

pms: delay eof a bit

Browse Source
This commit is contained in:
Bastian Bloessl
2014-08-26 13:47:33 +02:00
parent 04dc223f05
commit 71d3c74e90
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/periodic_msg_source_impl.cc
+8 -2
View File
@@ -65,7 +65,10 @@ periodic_msg_source_impl::run(periodic_msg_source_impl *instance) {
gr::thread::scoped_lock(d_mutex); gr::thread::scoped_lock(d_mutex);
if(d_finished || !d_nmsg_left) { if(d_finished || !d_nmsg_left) {
d_finished = true; d_finished = true;
if(d_quit) post(pmt::mp("system"), pmt::cons(pmt::mp("done"), pmt::from_long(1))); if(d_quit) {
boost::this_thread::sleep(boost::posix_time::milliseconds(500));
post(pmt::mp("system"), pmt::cons(pmt::mp("done"), pmt::from_long(1)));
}
break; break;
} }
@@ -86,7 +89,10 @@ periodic_msg_source_impl::run(periodic_msg_source_impl *instance) {
gr::thread::scoped_lock(d_mutex); gr::thread::scoped_lock(d_mutex);
dout << "PMS: thread interrupted" << std::endl; dout << "PMS: thread interrupted" << std::endl;
d_finished = true; d_finished = true;
if(d_quit) post(pmt::mp("system"), pmt::cons(pmt::mp("done"), pmt::from_long(1))); if(d_quit) {
boost::this_thread::sleep(boost::posix_time::milliseconds(500));
post(pmt::mp("system"), pmt::cons(pmt::mp("done"), pmt::from_long(1)));
}
} }
} }