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

periodic source: add startup delay, restructure loop

Browse Source
This commit is contained in:
Bastian Bloessl
2013-06-05 10:20:16 +02:00
parent 4d252153c4
commit c903a70bc8
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/periodic_msg_source_impl.cc
+11 -8
View File
@@ -50,22 +50,25 @@ periodic_msg_source_impl(pmt::pmt_t msg, float interval, int num_msg, bool debug
void run(periodic_msg_source_impl *instance) { void run(periodic_msg_source_impl *instance) {
while(!d_finished) {
// flow graph startup delay
boost::this_thread::sleep(boost::posix_time::milliseconds(500));
while(!d_finished && d_num_msg) {
dout << "number of messages left: " << d_num_msg << std::endl; dout << "number of messages left: " << d_num_msg << std::endl;
if(!d_num_msg || d_finished) {
d_finished = true;
break;
}
message_port_pub( pmt::mp("out"), d_msg ); message_port_pub( pmt::mp("out"), d_msg );
boost::this_thread::sleep(boost::posix_time::milliseconds(d_interval));
if(d_num_msg > 0) { if(d_num_msg > 0) {
d_num_msg--; d_num_msg--;
} }
if(!d_num_msg) {
break;
}
boost::this_thread::sleep(boost::posix_time::milliseconds(d_interval));
} }
dout << "stopping msg source" << std::endl; dout << "stopping msg source" << std::endl;