summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--gr-analog/lib/sig_source_impl.cc2
-rw-r--r--gr-digital/lib/chunks_to_symbols_impl.cc6
-rw-r--r--gr-digital/lib/constellation_receiver_cb_impl.cc10
-rw-r--r--gr-digital/lib/costas_loop_cc_impl.cc2
-rw-r--r--gr-digital/lib/crc32_async_bb_impl.cc4
-rw-r--r--gr-digital/lib/header_payload_demux_impl.cc5
-rw-r--r--gr-digital/lib/protocol_formatter_async_impl.cc3
-rw-r--r--gr-fec/lib/async_decoder_impl.cc5
-rw-r--r--gr-fec/lib/async_encoder_impl.cc5
-rw-r--r--gr-fec/lib/depuncture_bb_impl.cc2
-rw-r--r--gr-fec/lib/puncture_bb_impl.cc2
-rw-r--r--gr-fec/lib/puncture_ff_impl.cc2
-rw-r--r--gr-filter/lib/freq_xlating_fir_filter_impl.cc8
-rw-r--r--gr-filter/lib/mmse_resampler_cc_impl.cc2
-rw-r--r--gr-filter/lib/mmse_resampler_ff_impl.cc2
-rw-r--r--gr-uhd/lib/usrp_block_impl.cc2
-rw-r--r--gr-zeromq/lib/pub_msg_sink_impl.cc2
-rw-r--r--gr-zeromq/lib/push_msg_sink_impl.cc2
18 files changed, 27 insertions, 39 deletions
diff --git a/gr-analog/lib/sig_source_impl.cc b/gr-analog/lib/sig_source_impl.cc
index c07c2696b1..34b5fc8886 100644
--- a/gr-analog/lib/sig_source_impl.cc
+++ b/gr-analog/lib/sig_source_impl.cc
@@ -55,7 +55,7 @@ sig_source_impl<T>::sig_source_impl(double sampling_freq,
this->set_phase(phase);
this->message_port_register_in(pmt::mp("freq"));
this->set_msg_handler(pmt::mp("freq"),
- boost::bind(&sig_source_impl<T>::set_frequency_msg, this, _1));
+ [this](pmt::pmt_t msg) { this->set_frequency_msg(msg); });
}
template <class T>
diff --git a/gr-digital/lib/chunks_to_symbols_impl.cc b/gr-digital/lib/chunks_to_symbols_impl.cc
index e13e2f14e6..2c582b0334 100644
--- a/gr-digital/lib/chunks_to_symbols_impl.cc
+++ b/gr-digital/lib/chunks_to_symbols_impl.cc
@@ -55,10 +55,8 @@ chunks_to_symbols_impl<IN_T, OUT_T>::chunks_to_symbols_impl(
d_symbol_table(symbol_table)
{
this->message_port_register_in(pmt::mp("set_symbol_table"));
- this->set_msg_handler(
- pmt::mp("set_symbol_table"),
- boost::bind(
- &chunks_to_symbols_impl<IN_T, OUT_T>::handle_set_symbol_table, this, _1));
+ this->set_msg_handler(pmt::mp("set_symbol_table"),
+ [this](pmt::pmt_t msg) { this->handle_set_symbol_table(msg); });
}
template <class IN_T, class OUT_T>
diff --git a/gr-digital/lib/constellation_receiver_cb_impl.cc b/gr-digital/lib/constellation_receiver_cb_impl.cc
index 5ea92c4676..7cb9da68e3 100644
--- a/gr-digital/lib/constellation_receiver_cb_impl.cc
+++ b/gr-digital/lib/constellation_receiver_cb_impl.cc
@@ -49,14 +49,12 @@ constellation_receiver_cb_impl::constellation_receiver_cb_impl(
"This receiver only works with constellations of dimension 1.");
message_port_register_in(pmt::mp("set_constellation"));
- set_msg_handler(
- pmt::mp("set_constellation"),
- boost::bind(&constellation_receiver_cb_impl::handle_set_constellation, this, _1));
+ set_msg_handler(pmt::mp("set_constellation"),
+ [this](pmt::pmt_t msg) { this->handle_set_constellation(msg); });
message_port_register_in(pmt::mp("rotate_phase"));
- set_msg_handler(
- pmt::mp("rotate_phase"),
- boost::bind(&constellation_receiver_cb_impl::handle_rotate_phase, this, _1));
+ set_msg_handler(pmt::mp("rotate_phase"),
+ [this](pmt::pmt_t msg) { this->handle_rotate_phase(msg); });
}
constellation_receiver_cb_impl::~constellation_receiver_cb_impl() {}
diff --git a/gr-digital/lib/costas_loop_cc_impl.cc b/gr-digital/lib/costas_loop_cc_impl.cc
index 5f2cba275e..704f120a1a 100644
--- a/gr-digital/lib/costas_loop_cc_impl.cc
+++ b/gr-digital/lib/costas_loop_cc_impl.cc
@@ -42,7 +42,7 @@ costas_loop_cc_impl::costas_loop_cc_impl(float loop_bw, unsigned int order, bool
{
message_port_register_in(pmt::mp("noise"));
set_msg_handler(pmt::mp("noise"),
- boost::bind(&costas_loop_cc_impl::handle_set_noise, this, _1));
+ [this](pmt::pmt_t msg) { this->handle_set_noise(msg); });
}
costas_loop_cc_impl::~costas_loop_cc_impl() {}
diff --git a/gr-digital/lib/crc32_async_bb_impl.cc b/gr-digital/lib/crc32_async_bb_impl.cc
index 971f69d485..d608d617f3 100644
--- a/gr-digital/lib/crc32_async_bb_impl.cc
+++ b/gr-digital/lib/crc32_async_bb_impl.cc
@@ -36,9 +36,9 @@ crc32_async_bb_impl::crc32_async_bb_impl(bool check)
message_port_register_out(d_out_port);
if (check)
- set_msg_handler(d_in_port, boost::bind(&crc32_async_bb_impl::check, this, _1));
+ set_msg_handler(d_in_port, [this](pmt::pmt_t msg) { this->check(msg); });
else
- set_msg_handler(d_in_port, boost::bind(&crc32_async_bb_impl::calc, this, _1));
+ set_msg_handler(d_in_port, [this](pmt::pmt_t msg) { this->calc(msg); });
}
crc32_async_bb_impl::~crc32_async_bb_impl() {}
diff --git a/gr-digital/lib/header_payload_demux_impl.cc b/gr-digital/lib/header_payload_demux_impl.cc
index 174c2f888d..5bca908038 100644
--- a/gr-digital/lib/header_payload_demux_impl.cc
+++ b/gr-digital/lib/header_payload_demux_impl.cc
@@ -138,9 +138,8 @@ header_payload_demux_impl::header_payload_demux_impl(
}
set_tag_propagation_policy(TPP_DONT);
message_port_register_in(msg_port_id());
- set_msg_handler(
- msg_port_id(),
- boost::bind(&header_payload_demux_impl::parse_header_data_msg, this, _1));
+ set_msg_handler(msg_port_id(),
+ [this](pmt::pmt_t msg) { this->parse_header_data_msg(msg); });
for (size_t i = 0; i < special_tags.size(); i++) {
d_special_tags.push_back(pmt::string_to_symbol(special_tags[i]));
d_special_tags_last_value.push_back(pmt::PMT_NIL);
diff --git a/gr-digital/lib/protocol_formatter_async_impl.cc b/gr-digital/lib/protocol_formatter_async_impl.cc
index 5235c59746..4a794ce680 100644
--- a/gr-digital/lib/protocol_formatter_async_impl.cc
+++ b/gr-digital/lib/protocol_formatter_async_impl.cc
@@ -42,8 +42,7 @@ protocol_formatter_async_impl::protocol_formatter_async_impl(
message_port_register_out(d_hdr_port);
message_port_register_out(d_pld_port);
- set_msg_handler(d_in_port,
- boost::bind(&protocol_formatter_async_impl::append, this, _1));
+ set_msg_handler(d_in_port, [this](pmt::pmt_t msg) { this->append(msg); });
}
protocol_formatter_async_impl::~protocol_formatter_async_impl() {}
diff --git a/gr-fec/lib/async_decoder_impl.cc b/gr-fec/lib/async_decoder_impl.cc
index 8848964f49..7188c23cc4 100644
--- a/gr-fec/lib/async_decoder_impl.cc
+++ b/gr-fec/lib/async_decoder_impl.cc
@@ -52,11 +52,10 @@ async_decoder_impl::async_decoder_impl(generic_decoder::sptr my_decoder,
if (d_packed) {
d_pack = new blocks::kernel::pack_k_bits(8);
- set_msg_handler(d_in_port,
- boost::bind(&async_decoder_impl::decode_packed, this, _1));
+ set_msg_handler(d_in_port, [this](pmt::pmt_t msg) { this->decode_packed(msg); });
} else {
set_msg_handler(d_in_port,
- boost::bind(&async_decoder_impl::decode_unpacked, this, _1));
+ [this](pmt::pmt_t msg) { this->decode_unpacked(msg); });
}
// The maximum frame size is set by the initial frame size of the decoder.
diff --git a/gr-fec/lib/async_encoder_impl.cc b/gr-fec/lib/async_encoder_impl.cc
index 8cb0992d5d..e8d24ad331 100644
--- a/gr-fec/lib/async_encoder_impl.cc
+++ b/gr-fec/lib/async_encoder_impl.cc
@@ -51,8 +51,7 @@ async_encoder_impl::async_encoder_impl(generic_encoder::sptr my_encoder,
message_port_register_out(d_out_port);
if (d_packed) {
- set_msg_handler(d_in_port,
- boost::bind(&async_encoder_impl::encode_packed, this, _1));
+ set_msg_handler(d_in_port, [this](pmt::pmt_t msg) { this->encode_packed(msg); });
d_unpack = new blocks::kernel::unpack_k_bits(8);
@@ -62,7 +61,7 @@ async_encoder_impl::async_encoder_impl(generic_encoder::sptr my_encoder,
} else {
set_msg_handler(d_in_port,
- boost::bind(&async_encoder_impl::encode_unpacked, this, _1));
+ [this](pmt::pmt_t msg) { this->encode_unpacked(msg); });
}
if (d_packed || (strncmp(d_encoder->get_input_conversion(), "pack", 4) == 0)) {
diff --git a/gr-fec/lib/depuncture_bb_impl.cc b/gr-fec/lib/depuncture_bb_impl.cc
index a6dc4fccfc..d5a765f2a2 100644
--- a/gr-fec/lib/depuncture_bb_impl.cc
+++ b/gr-fec/lib/depuncture_bb_impl.cc
@@ -66,7 +66,7 @@ depuncture_bb_impl::depuncture_bb_impl(int puncsize,
set_fixed_rate(true);
set_relative_rate((uint64_t)d_puncsize, (uint64_t)(d_puncsize - d_puncholes));
set_output_multiple(d_puncsize);
- // set_msg_handler(boost::bind(&depuncture_bb_impl::catch_msg, this, _1));
+ // set_msg_handler(<portname>, [this](pmt::pmt_t msg) { this->catch_msg(msg); });
}
depuncture_bb_impl::~depuncture_bb_impl() {}
diff --git a/gr-fec/lib/puncture_bb_impl.cc b/gr-fec/lib/puncture_bb_impl.cc
index 54271b66f4..49f1bcfb55 100644
--- a/gr-fec/lib/puncture_bb_impl.cc
+++ b/gr-fec/lib/puncture_bb_impl.cc
@@ -60,7 +60,7 @@ puncture_bb_impl::puncture_bb_impl(int puncsize, int puncpat, int delay)
set_fixed_rate(true);
set_relative_rate((uint64_t)(d_puncsize - d_puncholes), (uint64_t)d_puncsize);
set_output_multiple(d_puncsize - d_puncholes);
- // set_msg_handler(boost::bind(&puncture_bb_impl::catch_msg, this, _1));
+ // set_msg_handler(<portname>, [this](pmt::pmt_t msg) { this->catch_msg(msg); });
}
puncture_bb_impl::~puncture_bb_impl() {}
diff --git a/gr-fec/lib/puncture_ff_impl.cc b/gr-fec/lib/puncture_ff_impl.cc
index a8f6c69b21..4b8c74f014 100644
--- a/gr-fec/lib/puncture_ff_impl.cc
+++ b/gr-fec/lib/puncture_ff_impl.cc
@@ -60,7 +60,7 @@ puncture_ff_impl::puncture_ff_impl(int puncsize, int puncpat, int delay)
set_fixed_rate(true);
set_relative_rate((uint64_t)(d_puncsize - d_puncholes), (uint64_t)d_puncsize);
set_output_multiple(d_puncsize - d_puncholes);
- // set_msg_handler(boost::bind(&puncture_ff_impl::catch_msg, this, _1));
+ // set_msg_handler(<portname>, [this](pmt::pmt_t msg) { this->catch_msg(msg); });
}
puncture_ff_impl::~puncture_ff_impl() {}
diff --git a/gr-filter/lib/freq_xlating_fir_filter_impl.cc b/gr-filter/lib/freq_xlating_fir_filter_impl.cc
index c005aa7949..6bf9937f4e 100644
--- a/gr-filter/lib/freq_xlating_fir_filter_impl.cc
+++ b/gr-filter/lib/freq_xlating_fir_filter_impl.cc
@@ -56,12 +56,8 @@ freq_xlating_fir_filter_impl<IN_T, OUT_T, TAP_T>::freq_xlating_fir_filter_impl(
this->build_composite_fir();
this->message_port_register_in(pmt::mp("freq"));
- this->set_msg_handler(
- pmt::mp("freq"),
- boost::bind(
- &freq_xlating_fir_filter_impl<IN_T, OUT_T, TAP_T>::handle_set_center_freq,
- this,
- _1));
+ this->set_msg_handler(pmt::mp("freq"),
+ [this](pmt::pmt_t msg) { this->handle_set_center_freq(msg); });
}
template <class IN_T, class OUT_T, class TAP_T>
diff --git a/gr-filter/lib/mmse_resampler_cc_impl.cc b/gr-filter/lib/mmse_resampler_cc_impl.cc
index 2ae7b6d1d6..7cdd4ab93c 100644
--- a/gr-filter/lib/mmse_resampler_cc_impl.cc
+++ b/gr-filter/lib/mmse_resampler_cc_impl.cc
@@ -41,7 +41,7 @@ mmse_resampler_cc_impl::mmse_resampler_cc_impl(float phase_shift, float resamp_r
set_inverse_relative_rate(d_mu_inc);
message_port_register_in(pmt::intern("msg_in"));
set_msg_handler(pmt::intern("msg_in"),
- boost::bind(&mmse_resampler_cc_impl::handle_msg, this, _1));
+ [this](pmt::pmt_t msg) { this->handle_msg(msg); });
}
mmse_resampler_cc_impl::~mmse_resampler_cc_impl() { delete d_resamp; }
diff --git a/gr-filter/lib/mmse_resampler_ff_impl.cc b/gr-filter/lib/mmse_resampler_ff_impl.cc
index c451323f82..b034bb4d41 100644
--- a/gr-filter/lib/mmse_resampler_ff_impl.cc
+++ b/gr-filter/lib/mmse_resampler_ff_impl.cc
@@ -42,7 +42,7 @@ mmse_resampler_ff_impl::mmse_resampler_ff_impl(float phase_shift, float resamp_r
message_port_register_in(pmt::intern("msg_in"));
set_msg_handler(pmt::intern("msg_in"),
- boost::bind(&mmse_resampler_ff_impl::handle_msg, this, _1));
+ [this](pmt::pmt_t msg) { this->handle_msg(msg); });
}
mmse_resampler_ff_impl::~mmse_resampler_ff_impl() { delete d_resamp; }
diff --git a/gr-uhd/lib/usrp_block_impl.cc b/gr-uhd/lib/usrp_block_impl.cc
index 50edc82b5b..2ce7aa3b39 100644
--- a/gr-uhd/lib/usrp_block_impl.cc
+++ b/gr-uhd/lib/usrp_block_impl.cc
@@ -125,7 +125,7 @@ usrp_block_impl::usrp_block_impl(const ::uhd::device_addr_t& device_addr,
// Set up message ports:
message_port_register_in(pmt::mp("command"));
set_msg_handler(pmt::mp("command"),
- boost::bind(&usrp_block_impl::msg_handler_command, this, _1));
+ [this](pmt::pmt_t msg) { this->msg_handler_command(msg); });
// cuz we lazy:
#define REGISTER_CMD_HANDLER(key, _handler) \
diff --git a/gr-zeromq/lib/pub_msg_sink_impl.cc b/gr-zeromq/lib/pub_msg_sink_impl.cc
index ca78a8ea8d..924b68a436 100644
--- a/gr-zeromq/lib/pub_msg_sink_impl.cc
+++ b/gr-zeromq/lib/pub_msg_sink_impl.cc
@@ -50,7 +50,7 @@ pub_msg_sink_impl::pub_msg_sink_impl(char* address, int timeout, bool bind)
}
message_port_register_in(pmt::mp("in"));
- set_msg_handler(pmt::mp("in"), boost::bind(&pub_msg_sink_impl::handler, this, _1));
+ set_msg_handler(pmt::mp("in"), [this](pmt::pmt_t msg) { this->handler(msg); });
}
pub_msg_sink_impl::~pub_msg_sink_impl()
diff --git a/gr-zeromq/lib/push_msg_sink_impl.cc b/gr-zeromq/lib/push_msg_sink_impl.cc
index b9964ce6ab..f43cf9d487 100644
--- a/gr-zeromq/lib/push_msg_sink_impl.cc
+++ b/gr-zeromq/lib/push_msg_sink_impl.cc
@@ -50,7 +50,7 @@ push_msg_sink_impl::push_msg_sink_impl(char* address, int timeout, bool bind)
}
message_port_register_in(pmt::mp("in"));
- set_msg_handler(pmt::mp("in"), boost::bind(&push_msg_sink_impl::handler, this, _1));
+ set_msg_handler(pmt::mp("in"), [this](pmt::pmt_t msg) { this->handler(msg); });
}
push_msg_sink_impl::~push_msg_sink_impl()
generated by cgit v1.2.3 (git 2.39.1) at 2025-03-26 05:30:44 +0000