summaryrefslogtreecommitdiff
path: root/gnuradio-runtime/lib/tpb_detail.cc
diff options
context:
space:
mode:
Diffstat (limited to 'gnuradio-runtime/lib/tpb_detail.cc')
-rw-r--r--gnuradio-runtime/lib/tpb_detail.cc45
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 */