aboutsummaryrefslogtreecommitdiffstats
path: root/lib/flow_control
diff options
context:
space:
mode:
authorPiotr Krysik <ptrkrysik@gmail.com>2017-11-11 11:14:26 +0100
committerPiotr Krysik <ptrkrysik@gmail.com>2017-11-11 11:14:26 +0100
commitf849fafd92c254a6f3897b08c6655f1cace90398 (patch)
treeea580c1bf757d0f04ee43126abce0342bb57cad9 /lib/flow_control
parent2c004741d684f252c0b130080d9ea882995916e9 (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.cc11
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);
}
}