diff options
| author | Marcus Müller <mmueller@gnuradio.org> | 2019-08-07 21:45:12 +0200 |
|---|---|---|
| committer | Marcus Müller <marcus@hostalia.de> | 2019-08-09 23:04:28 +0200 |
| commit | f7bbf2c1d8d780294f3e016aff239ca35eb6516e (patch) | |
| tree | e09ab6112e02b2215b2d59ac24d3d6ea2edac745 /gr-blocks/lib/message_strobe_impl.cc | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-blocks/lib/message_strobe_impl.cc')
| -rw-r--r-- | gr-blocks/lib/message_strobe_impl.cc | 95 |
1 files changed, 44 insertions, 51 deletions
diff --git a/gr-blocks/lib/message_strobe_impl.cc b/gr-blocks/lib/message_strobe_impl.cc index bedec78a57..cf06448ecb 100644 --- a/gr-blocks/lib/message_strobe_impl.cc +++ b/gr-blocks/lib/message_strobe_impl.cc @@ -36,69 +36,62 @@ #include <iostream> namespace gr { - namespace blocks { +namespace blocks { - message_strobe::sptr - message_strobe::make(pmt::pmt_t msg, long period_ms) - { - return gnuradio::get_initial_sptr - (new message_strobe_impl(msg, period_ms)); - } +message_strobe::sptr message_strobe::make(pmt::pmt_t msg, long period_ms) +{ + return gnuradio::get_initial_sptr(new message_strobe_impl(msg, period_ms)); +} - message_strobe_impl::message_strobe_impl(pmt::pmt_t msg, long period_ms) - : block("message_strobe", - io_signature::make(0, 0, 0), - io_signature::make(0, 0, 0)), - d_finished(false), - d_period_ms(period_ms), - d_msg(msg), - d_port(pmt::mp("strobe")) - { - message_port_register_out(d_port); +message_strobe_impl::message_strobe_impl(pmt::pmt_t msg, long period_ms) + : block("message_strobe", io_signature::make(0, 0, 0), io_signature::make(0, 0, 0)), + d_finished(false), + d_period_ms(period_ms), + d_msg(msg), + d_port(pmt::mp("strobe")) +{ + message_port_register_out(d_port); - message_port_register_in(pmt::mp("set_msg")); - set_msg_handler(pmt::mp("set_msg"), - boost::bind(&message_strobe_impl::set_msg, this, _1)); - } + message_port_register_in(pmt::mp("set_msg")); + set_msg_handler(pmt::mp("set_msg"), + boost::bind(&message_strobe_impl::set_msg, this, _1)); +} - message_strobe_impl::~message_strobe_impl() - { - } +message_strobe_impl::~message_strobe_impl() {} - bool - message_strobe_impl::start() - { - // NOTE: d_finished should be something explicitly thread safe. But since - // nothing breaks on concurrent access, I'll just leave it as bool. - d_finished = false; - d_thread = boost::shared_ptr<gr::thread::thread> - (new gr::thread::thread(boost::bind(&message_strobe_impl::run, this))); +bool message_strobe_impl::start() +{ + // NOTE: d_finished should be something explicitly thread safe. But since + // nothing breaks on concurrent access, I'll just leave it as bool. + d_finished = false; + d_thread = boost::shared_ptr<gr::thread::thread>( + new gr::thread::thread(boost::bind(&message_strobe_impl::run, this))); - return block::start(); - } + return block::start(); +} - bool - message_strobe_impl::stop() - { - // Shut down the thread - d_finished = true; - d_thread->interrupt(); - d_thread->join(); +bool message_strobe_impl::stop() +{ + // Shut down the thread + d_finished = true; + d_thread->interrupt(); + d_thread->join(); - return block::stop(); - } + return block::stop(); +} - void message_strobe_impl::run() - { - while(!d_finished) { - boost::this_thread::sleep(boost::posix_time::milliseconds(static_cast<long>(d_period_ms))); - if(d_finished) { - return; +void message_strobe_impl::run() +{ + while (!d_finished) { + boost::this_thread::sleep( + boost::posix_time::milliseconds(static_cast<long>(d_period_ms))); + if (d_finished) { + return; } message_port_pub(d_port, d_msg); - } } +} - } /* namespace blocks */ +} /* namespace blocks */ } /* namespace gr */ |