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

period msg source: less output

Browse Source
This commit is contained in:
Bastian Bloessl
2014-08-25 18:41:12 +02:00
parent 8e4caf6205
commit 0af0f5750f
1 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/periodic_msg_source_impl.cc
+4 -12
View File
@@ -56,15 +56,13 @@ periodic_msg_source_impl::~periodic_msg_source_impl() {
void void
periodic_msg_source_impl::eof_in (pmt::pmt_t msg) { periodic_msg_source_impl::eof_in (pmt::pmt_t msg) {
std::cout << "EOF IN CALLED" << std::endl;
if(pmt::is_eof_object(msg)) { if(pmt::is_eof_object(msg)) {
detail().get()->set_done(true); detail().get()->set_done(true);
dout << "stopping msg source" << std::endl; dout << "PMS: stopping msg source" << std::endl;
message_port_pub(pmt::mp("out"), pmt::PMT_EOF); message_port_pub(pmt::mp("out"), pmt::PMT_EOF);
return; return;
} else { } else {
dout << "non EOF message at eof port!" << std::endl; dout << "PMS: non EOF message at eof port!" << std::endl;
} }
} }
@@ -76,21 +74,16 @@ periodic_msg_source_impl::run(periodic_msg_source_impl *instance) {
// flow graph startup delay // flow graph startup delay
boost::this_thread::sleep(boost::posix_time::milliseconds(500)); boost::this_thread::sleep(boost::posix_time::milliseconds(500));
std::cout << "starting thread" << std::endl;
while(1) { while(1) {
std::cout << "in while loop" << std::endl;
float delay; float delay;
{ {
std::cout << "in scope" << std::endl;
gr::thread::scoped_lock(d_mutex); gr::thread::scoped_lock(d_mutex);
std::cout << "got lock" << std::endl;
if(d_finished || !d_nmsg_left) { if(d_finished || !d_nmsg_left) {
d_finished = true; d_finished = true;
break; break;
} }
dout << "number of messages left: " << d_nmsg_left << std::endl; dout << "PMS: number of messages left: " << d_nmsg_left << std::endl;
message_port_pub( pmt::mp("out"), d_msg ); message_port_pub( pmt::mp("out"), d_msg );
@@ -104,10 +97,9 @@ periodic_msg_source_impl::run(periodic_msg_source_impl *instance) {
} }
} catch(boost::thread_interrupted) { } catch(boost::thread_interrupted) {
std::cout << "interrupted start" << std::endl;
gr::thread::scoped_lock(d_mutex); gr::thread::scoped_lock(d_mutex);
dout << "PMS: thread interrupted" << std::endl;
d_finished = true; d_finished = true;
std::cout << "interrupted end" << std::endl;
} }
} }