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-zeromq/lib/sub_source_impl.cc | 89 +++++++++++++++++++---------------------
1 file changed, 43 insertions(+), 46 deletions(-)
(limited to 'gr-zeromq/lib/sub_source_impl.cc')
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
--
cgit v1.2.3