diff options
| author | Bastian Bloessl <bloessl@ccs-labs.org> | 2016-04-21 07:37:02 +0200 |
|---|---|---|
| committer | Bastian Bloessl <bloessl@ccs-labs.org> | 2016-06-29 09:10:21 +0200 |
| commit | 1c76c59a41a1da0a0eff7bbfeb3da7502b47ad14 (patch) | |
| tree | 69c349a919ac9488af9676ebcd28953bdec73060 /gnuradio-runtime/lib | |
| parent | a88230786e04d8cb8dd169cefe9b7491be5cc6d0 (diff) | |
runtime: whitespace
Diffstat (limited to 'gnuradio-runtime/lib')
| -rw-r--r-- | gnuradio-runtime/lib/tpb_thread_body.cc | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/gnuradio-runtime/lib/tpb_thread_body.cc b/gnuradio-runtime/lib/tpb_thread_body.cc index ab374f3e5d..ac553c4f31 100644 --- a/gnuradio-runtime/lib/tpb_thread_body.cc +++ b/gnuradio-runtime/lib/tpb_thread_body.cc @@ -135,20 +135,20 @@ namespace gr { } switch(s){ - case block_executor::READY: // Tell neighbors we made progress. + case block_executor::READY: // Tell neighbors we made progress. d->d_tpb.notify_neighbors(d); break; - case block_executor::READY_NO_OUTPUT: // Notify upstream only + case block_executor::READY_NO_OUTPUT: // Notify upstream only d->d_tpb.notify_upstream(d); break; - case block_executor::DONE: // Game over. + case block_executor::DONE: // Game over. block->notify_msg_neighbors(); d->d_tpb.notify_neighbors(d); return; - case block_executor::BLKD_IN: // Wait for input. + case block_executor::BLKD_IN: // Wait for input. { gr::thread::scoped_lock guard(d->d_tpb.mutex); while(!d->d_tpb.input_changed) { @@ -183,15 +183,15 @@ namespace gr { } break; - case block_executor::BLKD_OUT: // Wait for output buffer space. + case block_executor::BLKD_OUT: // Wait for output buffer space. { - gr::thread::scoped_lock guard(d->d_tpb.mutex); - while(!d->d_tpb.output_changed) { - // wait for output room or message - while(!d->d_tpb.output_changed && block->empty_handled_p()) - d->d_tpb.output_cond.wait(guard); + gr::thread::scoped_lock guard(d->d_tpb.mutex); + while(!d->d_tpb.output_changed) { + // wait for output room or message + while(!d->d_tpb.output_changed && block->empty_handled_p()) + d->d_tpb.output_cond.wait(guard); - // handle all pending messages + // handle all pending messages BOOST_FOREACH(basic_block::msg_queue_map_t::value_type &i, block->msg_queue) { if(block->has_msg_handler(i.first)) { while((msg = block->delete_head_nowait(i.first))) { |