diff options
author | Piotr Krysik <ptrkrysik@gmail.com> | 2017-11-11 11:14:26 +0100 |
---|---|---|
committer | Piotr Krysik <ptrkrysik@gmail.com> | 2017-11-11 11:14:26 +0100 |
commit | f849fafd92c254a6f3897b08c6655f1cace90398 (patch) | |
tree | ea580c1bf757d0f04ee43126abce0342bb57cad9 /lib/flow_control | |
parent | 2c004741d684f252c0b130080d9ea882995916e9 (diff) |
Changed input and output name for burst_type_filter
Diffstat (limited to 'lib/flow_control')
-rw-r--r-- | lib/flow_control/burst_type_filter_impl.cc | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/lib/flow_control/burst_type_filter_impl.cc b/lib/flow_control/burst_type_filter_impl.cc index 542a004..c8bbd7e 100644 --- a/lib/flow_control/burst_type_filter_impl.cc +++ b/lib/flow_control/burst_type_filter_impl.cc @@ -52,10 +52,10 @@ namespace gr { { set_selected_burst_types(selected_burst_types); - message_port_register_in(pmt::mp("in")); - message_port_register_out(pmt::mp("out")); + message_port_register_in(pmt::mp("bursts_in")); + message_port_register_out(pmt::mp("bursts_out")); - set_msg_handler(pmt::mp("in"), boost::bind(&burst_type_filter_impl::process_burst, this, _1)); + set_msg_handler(pmt::mp("bursts_in"), boost::bind(&burst_type_filter_impl::process_burst, this, _1)); } /* @@ -69,15 +69,14 @@ namespace gr { return; if (d_filter_policy == FILTER_POLICY_PASS_ALL) { - message_port_pub(pmt::mp("out"), msg); + message_port_pub(pmt::mp("bursts_out"), msg); return; } gsmtap_hdr * header = (gsmtap_hdr *)pmt::blob_data(pmt::cdr(msg)); -// std::cout << "header->type: " << (int)(header->sub_type) << std::endl; if (std::find(d_selected_burst_types.begin(), d_selected_burst_types.end(), header->sub_type) != d_selected_burst_types.end()) //check if burst type is listed in burst types to pass { - message_port_pub(pmt::mp("out"), msg); + message_port_pub(pmt::mp("bursts_out"), msg); } } |