diff options
Diffstat (limited to 'gnuradio-runtime/lib/tpb_detail.cc')
-rw-r--r-- | gnuradio-runtime/lib/tpb_detail.cc | 45 |
1 files changed, 21 insertions, 24 deletions
diff --git a/gnuradio-runtime/lib/tpb_detail.cc b/gnuradio-runtime/lib/tpb_detail.cc index cf05c2b102..f5963fc491 100644 --- a/gnuradio-runtime/lib/tpb_detail.cc +++ b/gnuradio-runtime/lib/tpb_detail.cc @@ -30,42 +30,39 @@ namespace gr { - /* - * We assume that no worker threads are ever running when the graph - * structure is being manipulated, thus it's safe for us to poke - * around in our neighbors w/o holding any locks. - */ - void - tpb_detail::notify_upstream(block_detail *d) - { +/* + * We assume that no worker threads are ever running when the graph + * structure is being manipulated, thus it's safe for us to poke + * around in our neighbors w/o holding any locks. + */ +void tpb_detail::notify_upstream(block_detail* d) +{ // For each of our inputs, tell the guy upstream that we've // consumed some input, and that he most likely has more output // buffer space available. - for(size_t i = 0; i < d->d_input.size(); i++) { - // Can you say, "pointer chasing?" - d->d_input[i]->buffer()->link()->detail()->d_tpb.set_output_changed(); + for (size_t i = 0; i < d->d_input.size(); i++) { + // Can you say, "pointer chasing?" + d->d_input[i]->buffer()->link()->detail()->d_tpb.set_output_changed(); } - } +} - void - tpb_detail::notify_downstream(block_detail *d) - { +void tpb_detail::notify_downstream(block_detail* d) +{ // For each of our outputs, tell the guys downstream that they // have new input available. - for(size_t i = 0; i < d->d_output.size(); i++) { - buffer_sptr buf = d->d_output[i]; - for(size_t j = 0, k = buf->nreaders(); j < k; j++) - buf->reader(j)->link()->detail()->d_tpb.set_input_changed(); + for (size_t i = 0; i < d->d_output.size(); i++) { + buffer_sptr buf = d->d_output[i]; + for (size_t j = 0, k = buf->nreaders(); j < k; j++) + buf->reader(j)->link()->detail()->d_tpb.set_input_changed(); } - } +} - void - tpb_detail::notify_neighbors(block_detail *d) - { +void tpb_detail::notify_neighbors(block_detail* d) +{ notify_downstream(d); notify_upstream(d); - } +} } /* namespace gr */ |