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/qa_set_msg_handler.cc | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-blocks/lib/qa_set_msg_handler.cc')
| -rw-r--r-- | gr-blocks/lib/qa_set_msg_handler.cc | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/gr-blocks/lib/qa_set_msg_handler.cc b/gr-blocks/lib/qa_set_msg_handler.cc index 94bd6e4249..368643bfa7 100644 --- a/gr-blocks/lib/qa_set_msg_handler.cc +++ b/gr-blocks/lib/qa_set_msg_handler.cc @@ -41,31 +41,31 @@ */ BOOST_AUTO_TEST_CASE(t0) { - static const int NMSGS = 10; + static const int NMSGS = 10; - gr::top_block_sptr tb = gr::make_top_block("top"); - gr::block_sptr src = gr::blocks::null_source::make(sizeof(int)); - gr::blocks::nop::sptr nop = gr::blocks::nop::make(sizeof(int)); - gr::block_sptr dst = gr::blocks::null_sink::make(sizeof(int)); + gr::top_block_sptr tb = gr::make_top_block("top"); + gr::block_sptr src = gr::blocks::null_source::make(sizeof(int)); + gr::blocks::nop::sptr nop = gr::blocks::nop::make(sizeof(int)); + gr::block_sptr dst = gr::blocks::null_sink::make(sizeof(int)); - tb->connect(src, 0, nop, 0); - tb->connect(nop, 0, dst, 0); + tb->connect(src, 0, nop, 0); + tb->connect(nop, 0, dst, 0); - // Must start graph before sending messages - tb->start(); + // Must start graph before sending messages + tb->start(); - // Send them... - pmt::pmt_t port(pmt::intern("port")); - for (int i = 0; i < NMSGS; i++){ - send(nop, port, pmt::mp(pmt::mp("example-msg"), pmt::mp(i))); - } + // Send them... + pmt::pmt_t port(pmt::intern("port")); + for (int i = 0; i < NMSGS; i++) { + send(nop, port, pmt::mp(pmt::mp("example-msg"), pmt::mp(i))); + } - // Give the messages a chance to be processed - boost::this_thread::sleep(boost::posix_time::milliseconds(100)); + // Give the messages a chance to be processed + boost::this_thread::sleep(boost::posix_time::milliseconds(100)); - tb->stop(); - tb->wait(); + tb->stop(); + tb->wait(); - // Confirm that the nop block received the right number of messages. - BOOST_CHECK_EQUAL(NMSGS, nop->nmsgs_received()); + // Confirm that the nop block received the right number of messages. + BOOST_CHECK_EQUAL(NMSGS, nop->nmsgs_received()); } |