diff options
| author | Bastian Bloessl <bloessl@ccs-labs.org> | 2016-09-30 06:52:22 +0200 |
|---|---|---|
| committer | Bastian Bloessl <bloessl@ccs-labs.org> | 2016-09-30 06:52:22 +0200 |
| commit | cce68f26f1641c0a97b0bbc9a4608903aed493c7 (patch) | |
| tree | a9d999bcec96f94b105bc5c9197150629c7b8804 /gnuradio-runtime/lib/flat_flowgraph.cc | |
| parent | 90c88a94945f889445f79c610a5e7d6fc6221310 (diff) | |
runtime: connect message ports after unlock()
Diffstat (limited to 'gnuradio-runtime/lib/flat_flowgraph.cc')
| -rw-r--r-- | gnuradio-runtime/lib/flat_flowgraph.cc | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/gnuradio-runtime/lib/flat_flowgraph.cc b/gnuradio-runtime/lib/flat_flowgraph.cc index 434a92fb3d..b7e949127a 100644 --- a/gnuradio-runtime/lib/flat_flowgraph.cc +++ b/gnuradio-runtime/lib/flat_flowgraph.cc @@ -316,6 +316,15 @@ namespace gr { setup_buffer_alignment(block); } + // Connect message ports connetions + for(msg_edge_viter_t i = d_msg_edges.begin(); i != d_msg_edges.end(); i++) { + if(FLAT_FLOWGRAPH_DEBUG) + std::cout << boost::format("flat_fg connecting msg primitives: (%s, %s)->(%s, %s)\n") % + i->src().block() % i->src().port() % + i->dst().block() % i->dst().port(); + i->src().block()->message_port_sub(i->src().port(), pmt::cons(i->dst().block()->alias_pmt(), i->dst().port())); + } + // Now deal with the fact that the block details might have // changed numbers of inputs and outputs vs. in the old // flowgraph. |