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-zeromq/lib/sub_source_impl.cc | |
| parent | 78431dc6941e3acc67c858277dfe4a0ed583643c (diff) | |
Tree: clang-format without the include sorting
Diffstat (limited to 'gr-zeromq/lib/sub_source_impl.cc')
| -rw-r--r-- | gr-zeromq/lib/sub_source_impl.cc | 89 |
1 files changed, 43 insertions, 46 deletions
diff --git a/gr-zeromq/lib/sub_source_impl.cc b/gr-zeromq/lib/sub_source_impl.cc index 9a2e0bfe15..d55ca116f0 100644 --- a/gr-zeromq/lib/sub_source_impl.cc +++ b/gr-zeromq/lib/sub_source_impl.cc @@ -29,61 +29,58 @@ #include "tag_headers.h" namespace gr { - namespace zeromq { +namespace zeromq { - sub_source::sptr - sub_source::make(size_t itemsize, size_t vlen, char *address, int timeout, bool pass_tags, int hwm) - { - return gnuradio::get_initial_sptr - (new sub_source_impl(itemsize, vlen, address, timeout, pass_tags, hwm)); - } +sub_source::sptr sub_source::make( + size_t itemsize, size_t vlen, char* address, int timeout, bool pass_tags, int hwm) +{ + return gnuradio::get_initial_sptr( + new sub_source_impl(itemsize, vlen, address, timeout, pass_tags, hwm)); +} - sub_source_impl::sub_source_impl(size_t itemsize, size_t vlen, char *address, int timeout, bool pass_tags, int hwm) - : gr::sync_block("sub_source", - gr::io_signature::make(0, 0, 0), - gr::io_signature::make(1, 1, itemsize * vlen)), - base_source_impl(ZMQ_SUB, itemsize, vlen, address, timeout, pass_tags, hwm) - { - /* Subscribe */ - d_socket->setsockopt(ZMQ_SUBSCRIBE, "", 0); - } +sub_source_impl::sub_source_impl( + size_t itemsize, size_t vlen, char* address, int timeout, bool pass_tags, int hwm) + : gr::sync_block("sub_source", + gr::io_signature::make(0, 0, 0), + gr::io_signature::make(1, 1, itemsize * vlen)), + base_source_impl(ZMQ_SUB, itemsize, vlen, address, timeout, pass_tags, hwm) +{ + /* Subscribe */ + d_socket->setsockopt(ZMQ_SUBSCRIBE, "", 0); +} - int - sub_source_impl::work(int noutput_items, - gr_vector_const_void_star &input_items, - gr_vector_void_star &output_items) - { - uint8_t *out = (uint8_t *) output_items[0]; - bool first = true; - int done = 0; +int sub_source_impl::work(int noutput_items, + gr_vector_const_void_star& input_items, + gr_vector_void_star& output_items) +{ + uint8_t* out = (uint8_t*)output_items[0]; + bool first = true; + int done = 0; - /* Process as much as we can */ - while (1) - { - if (has_pending()) - { - /* Flush anything pending */ - done += flush_pending(out + (done * d_vsize), noutput_items - done, nitems_written(0) + done); + /* Process as much as we can */ + while (1) { + if (has_pending()) { + /* Flush anything pending */ + done += flush_pending( + out + (done * d_vsize), noutput_items - done, nitems_written(0) + done); - /* No more space ? */ - if (done == noutput_items) - break; - } - else - { - /* Try to get the next message */ - if (!load_message(first)) - break; /* No message, we're done for now */ + /* No more space ? */ + if (done == noutput_items) + break; + } else { + /* Try to get the next message */ + if (!load_message(first)) + break; /* No message, we're done for now */ - /* Not the first anymore */ - first = false; + /* Not the first anymore */ + first = false; } - } - - return done; } - } /* namespace zeromq */ + return done; +} + +} /* namespace zeromq */ } /* namespace gr */ // vim: ts=2 sw=2 expandtab |