From f7bbf2c1d8d780294f3e016aff239ca35eb6516e Mon Sep 17 00:00:00 2001
From: Marcus Müller <mmueller@gnuradio.org>
Date: Wed, 7 Aug 2019 21:45:12 +0200
Subject: Tree: clang-format without the include sorting
---
gr-blocks/lib/message_strobe_impl.cc | 95 +++++++++++++++++-------------------
1 file changed, 44 insertions(+), 51 deletions(-)
(limited to 'gr-blocks/lib/message_strobe_impl.cc')
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 */
--
cgit v1.2.3