uhd: mpm: apply clang-format to all files

Applying formatting changes to all .cpp and .hpp files in the following
directories:
```
find host/examples/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/tests/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/lib/usrp/dboard/neon/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/lib/usrp/dboard/magnesium/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/lib/usrp/device3/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/lib/usrp/mpmd/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/lib/usrp/x300/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find host/utils/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
find mpm/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
```

Also formatted host/include/, except Cpp03 was used as a the language
standard instead of Cpp11.
```
sed -i 's/ Cpp11/ Cpp03/g' .clang-format
find host/include/ -iname *.hpp -o -iname *.cpp | \
    xargs clang-format -i -style=file
```

Formatting style was designated by the .clang-format file.

1 files changed, 112 insertions, 104 deletions

diff --git a/host/tests/dpdk_test.cpp b/host/tests/dpdk_test.cpp
index 8a4e51af7..43ef3d388 100644
--- a/host/tests/dpdk_test.cpp
+++ b/host/tests/dpdk_test.cpp
@@ -8,18 +8,18 @@
  */
 
 
-#include <cstdio>
-#include <cstdbool>
-#include <cstring>
-#include <unistd.h>
-#include <sys/time.h>
-#include <errno.h>
+#include "../transport/dpdk_zero_copy.hpp"
 #include <arpa/inet.h>
+#include <errno.h>
 #include <sched.h>
 #include <sys/syscall.h>
-#include "../transport/dpdk_zero_copy.hpp"
+#include <sys/time.h>
+#include <unistd.h>
 #include <boost/program_options.hpp>
 #include <boost/regex.hpp>
+#include <cstdbool>
+#include <cstdio>
+#include <cstring>
 #include <iostream>
 
 static const boost::regex colons(":");
@@ -27,28 +27,30 @@ static const boost::regex colons(":");
 namespace po = boost::program_options;
 
 namespace {
-    constexpr unsigned int NUM_MBUFS       = 4095; /* Total number of mbufs in pool */
-    constexpr unsigned int MBUF_CACHE_SIZE = 315; /* Size of cpu-local mbuf cache */
-    constexpr unsigned int BURST_SIZE      = 64; /* Maximum burst size for RX */
-
-    constexpr unsigned int NUM_PORTS       = 2; /* Number of NIC ports */
-    constexpr unsigned int TX_CREDITS      = 28; /* Number of TX credits */
-    constexpr unsigned int RX_CREDITS      = 64; /* Number of RX credits */
-    constexpr unsigned int BENCH_SPP       = 700; /* "Samples" per packet */
-}
+constexpr unsigned int NUM_MBUFS       = 4095; /* Total number of mbufs in pool */
+constexpr unsigned int MBUF_CACHE_SIZE = 315; /* Size of cpu-local mbuf cache */
+constexpr unsigned int BURST_SIZE      = 64; /* Maximum burst size for RX */
+
+constexpr unsigned int NUM_PORTS  = 2; /* Number of NIC ports */
+constexpr unsigned int TX_CREDITS = 28; /* Number of TX credits */
+constexpr unsigned int RX_CREDITS = 64; /* Number of RX credits */
+constexpr unsigned int BENCH_SPP  = 700; /* "Samples" per packet */
+} // namespace
 
-struct dpdk_test_args {
+struct dpdk_test_args
+{
     unsigned int portid;
     std::string src_port;
     std::string dst_ip;
     std::string dst_port;
-    pthread_cond_t *cond;
+    pthread_cond_t* cond;
     pthread_mutex_t mutex;
     bool started;
     int cpu;
 };
 
-struct dpdk_test_stats {
+struct dpdk_test_stats
+{
     uint32_t last_seqno;
     uint32_t dropped_packets;
     uint32_t lasts[16];
@@ -59,7 +61,7 @@ struct dpdk_test_stats {
 };
 
 
-static void process_udp(int id, uint32_t *udp_data, struct dpdk_test_stats *stats)
+static void process_udp(int id, uint32_t* udp_data, struct dpdk_test_stats* stats)
 {
     if (udp_data[0] != stats[id].last_seqno + 1) {
         stats[id].lasts[stats[id].dropped_packets & 0xf] = stats[id].last_seqno;
@@ -71,22 +73,24 @@ static void process_udp(int id, uint32_t *udp_data, struct dpdk_test_stats *stat
     stats[id].last_ackno = udp_data[1];
 }
 
-static void send_udp(uhd::transport::dpdk_zero_copy::sptr &stream, int id,
-                     bool fc_only, struct dpdk_test_stats *stats)
+static void send_udp(uhd::transport::dpdk_zero_copy::sptr& stream,
+    int id,
+    bool fc_only,
+    struct dpdk_test_stats* stats)
 {
     uhd::transport::managed_send_buffer::sptr mbuf = stream->get_send_buff(0);
     if (mbuf.get() == nullptr) {
         printf("Could not get TX buffer!\n");
         return;
     }
-    auto *tx_data = mbuf->cast<uint32_t *>();
-    tx_data[0] = fc_only ? stats[id].tx_seqno - 1 : stats[id].tx_seqno;
-    tx_data[1] = stats[id].last_seqno;
+    auto* tx_data = mbuf->cast<uint32_t*>();
+    tx_data[0]    = fc_only ? stats[id].tx_seqno - 1 : stats[id].tx_seqno;
+    tx_data[1]    = stats[id].last_seqno;
     if (!fc_only) {
-        memset(&tx_data[2], stats[id].last_seqno, 8*BENCH_SPP);
-        stats[id].tx_xfer += 8*BENCH_SPP;
+        memset(&tx_data[2], stats[id].last_seqno, 8 * BENCH_SPP);
+        stats[id].tx_xfer += 8 * BENCH_SPP;
     }
-    size_t num_bytes = 8 + (fc_only ? 0 : 8*BENCH_SPP);
+    size_t num_bytes = 8 + (fc_only ? 0 : 8 * BENCH_SPP);
     mbuf->commit(num_bytes);
     mbuf.reset();
 
@@ -95,18 +99,20 @@ static void send_udp(uhd::transport::dpdk_zero_copy::sptr &stream, int id,
     }
 }
 
-static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_ports, double timeout)
+static void bench(
+    uhd::transport::dpdk_zero_copy::sptr* stream, uint32_t nb_ports, double timeout)
 {
     uint64_t total_xfer[NUM_PORTS];
     uint32_t id;
-    struct dpdk_test_stats *stats = (struct dpdk_test_stats *) malloc(sizeof(*stats)*nb_ports);
+    struct dpdk_test_stats* stats =
+        (struct dpdk_test_stats*)malloc(sizeof(*stats) * nb_ports);
     for (id = 0; id < nb_ports; id++) {
-        stats[id].tx_seqno = 1;
-        stats[id].tx_xfer = 0;
-        stats[id].last_ackno = 0;
-        stats[id].last_seqno = 0;
+        stats[id].tx_seqno        = 1;
+        stats[id].tx_xfer         = 0;
+        stats[id].last_ackno      = 0;
+        stats[id].last_seqno      = 0;
         stats[id].dropped_packets = 0;
-        total_xfer[id] = 0;
+        total_xfer[id]            = 0;
     }
     sleep(1);
     struct timeval bench_start, bench_end;
@@ -115,8 +121,8 @@ static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_port
      * The test...
      */
     uint64_t total_received = 0;
-    uint32_t consec_no_rx = 0;
-    while ((total_received / nb_ports) < 1000000 ) { //&& consec_no_rx < 10000) {
+    uint32_t consec_no_rx   = 0;
+    while ((total_received / nb_ports) < 1000000) { //&& consec_no_rx < 10000) {
         for (id = 0; id < nb_ports; id++) {
             unsigned int nb_rx = 0;
             uhd::transport::managed_recv_buffer::sptr bufs[BURST_SIZE];
@@ -132,7 +138,9 @@ static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_port
                 consec_no_rx++;
                 if (consec_no_rx >= 100000) {
                     uint32_t skt_drops = stream[id]->get_drop_count();
-                    //printf("TX seq %d, TX ack %d, RX seq %d, %d drops!\n", stats[id].tx_seqno, stats[id].last_ackno, stats[id].last_seqno, skt_drops);
+                    // printf("TX seq %d, TX ack %d, RX seq %d, %d drops!\n",
+                    // stats[id].tx_seqno, stats[id].last_ackno, stats[id].last_seqno,
+                    // skt_drops);
                     consec_no_rx = 0;
                     break;
                 }
@@ -143,7 +151,7 @@ static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_port
 
             for (unsigned int buf = 0; buf < nb_rx; buf++) {
                 total_xfer[id] += bufs[buf]->size();
-                auto data = bufs[buf]->cast<uint32_t *>();
+                auto data = bufs[buf]->cast<uint32_t*>();
                 process_udp(id, data, stats);
             }
 
@@ -153,15 +161,17 @@ static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_port
         for (id = 0; id < nb_ports; id++) {
             /* TX portion */
             uint32_t window_end = stats[id].last_ackno + TX_CREDITS;
-            //uint32_t window_end = last_seqno[port] + TX_CREDITS;
+            // uint32_t window_end = last_seqno[port] + TX_CREDITS;
             if (window_end <= stats[id].tx_seqno) {
                 if (consec_no_rx == 9999) {
                     send_udp(stream[id], id, true, stats);
                 }
-                //send_udp(tx[id], id, true);
+                // send_udp(tx[id], id, true);
                 ;
             } else {
-                for (unsigned int pktno = 0; (pktno < BURST_SIZE) && (stats[id].tx_seqno < window_end); pktno++) {
+                for (unsigned int pktno = 0;
+                     (pktno < BURST_SIZE) && (stats[id].tx_seqno < window_end);
+                     pktno++) {
                     send_udp(stream[id], id, false, stats);
                 }
             }
@@ -174,13 +184,16 @@ static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_port
         printf("\n");
         printf("Bytes received = %ld\n", total_xfer[id]);
         printf("Bytes sent = %ld\n", stats[id].tx_xfer);
-        printf("Time taken = %ld us\n", (bench_end.tv_sec - bench_start.tv_sec)*1000000 + (bench_end.tv_usec - bench_start.tv_usec));
-        double elapsed_time = (bench_end.tv_sec - bench_start.tv_sec)*1000000 + (bench_end.tv_usec - bench_start.tv_usec);
+        printf("Time taken = %ld us\n",
+            (bench_end.tv_sec - bench_start.tv_sec) * 1000000
+                + (bench_end.tv_usec - bench_start.tv_usec));
+        double elapsed_time = (bench_end.tv_sec - bench_start.tv_sec) * 1000000
+                              + (bench_end.tv_usec - bench_start.tv_usec);
         elapsed_time *= 1.0e-6;
         double elapsed_bytes = total_xfer[id];
-        printf("RX Performance = %e Gbps\n", elapsed_bytes*8.0/1.0e9/elapsed_time);
+        printf("RX Performance = %e Gbps\n", elapsed_bytes * 8.0 / 1.0e9 / elapsed_time);
         elapsed_bytes = stats[id].tx_xfer;
-        printf("TX Performance = %e Gbps\n", elapsed_bytes*8.0/1.0e9/elapsed_time);
+        printf("TX Performance = %e Gbps\n", elapsed_bytes * 8.0 / 1.0e9 / elapsed_time);
         uint32_t skt_drops = stream[id]->get_drop_count();
         printf("Dropped %d packets\n", stats[id].dropped_packets);
         printf("Socket reports dropped %d packets\n", skt_drops);
@@ -189,11 +202,10 @@ static void bench(uhd::transport::dpdk_zero_copy::sptr *stream, uint32_t nb_port
                 break;
             printf("Last(%u), Recv(%u)\n", stats[id].lasts[i], stats[id].drops[i]);
         }
-        //printf("%d missed/dropped packets\n", errors);
+        // printf("%d missed/dropped packets\n", errors);
         printf("\n");
     }
     free(stats);
-
 }
 
 static inline void set_cpu(pthread_t t, int cpu)
@@ -209,31 +221,29 @@ static inline void set_cpu(pthread_t t, int cpu)
     }
 }
 
-void *prepare_and_bench_blocking(void *arg)
+void* prepare_and_bench_blocking(void* arg)
 {
-    struct dpdk_test_args *args = (struct dpdk_test_args *) arg;
+    struct dpdk_test_args* args = (struct dpdk_test_args*)arg;
     pthread_mutex_lock(&args->mutex);
     pthread_t t = pthread_self();
     set_cpu(t, args->cpu);
     args->started = true;
     pthread_cond_wait(args->cond, &args->mutex);
-    auto &ctx = uhd::transport::uhd_dpdk_ctx::get();
+    auto& ctx = uhd::transport::uhd_dpdk_ctx::get();
     uhd::transport::dpdk_zero_copy::sptr eth_data[1];
     uhd::transport::zero_copy_xport_params buff_args;
     buff_args.recv_frame_size = 8000;
     buff_args.send_frame_size = 8000;
     buff_args.num_send_frames = 8;
     buff_args.num_recv_frames = 8;
-    auto dev_addr = uhd::device_addr_t();
-    eth_data[0] = uhd::transport::dpdk_zero_copy::make(
-        ctx,
+    auto dev_addr             = uhd::device_addr_t();
+    eth_data[0]               = uhd::transport::dpdk_zero_copy::make(ctx,
         args->portid,
         args->dst_ip,
         args->src_port,
         args->dst_port,
         buff_args,
-        dev_addr
-    );
+        dev_addr);
 
     bench(eth_data, 1, 0.1);
     return 0;
@@ -241,19 +251,19 @@ void *prepare_and_bench_blocking(void *arg)
 
 void prepare_and_bench_polling(void)
 {
-    auto &ctx = uhd::transport::uhd_dpdk_ctx::get();
+    auto& ctx = uhd::transport::uhd_dpdk_ctx::get();
     struct dpdk_test_args bench_args[2];
-    bench_args[0].cond = NULL;
-    bench_args[0].started = true;
-    bench_args[0].portid = 0;
+    bench_args[0].cond     = NULL;
+    bench_args[0].started  = true;
+    bench_args[0].portid   = 0;
     bench_args[0].src_port = "0xBEE7";
-    bench_args[0].dst_ip = "192.168.0.4";
+    bench_args[0].dst_ip   = "192.168.0.4";
     bench_args[0].dst_port = "0xBEE7";
-    bench_args[1].cond = NULL;
-    bench_args[1].started = true;
-    bench_args[1].portid = 1;
+    bench_args[1].cond     = NULL;
+    bench_args[1].started  = true;
+    bench_args[1].portid   = 1;
     bench_args[1].src_port = "0xBEE7";
-    bench_args[1].dst_ip = "192.168.0.3";
+    bench_args[1].dst_ip   = "192.168.0.3";
     bench_args[1].dst_port = "0xBEE7";
 
     uhd::transport::dpdk_zero_copy::sptr eth_data[NUM_PORTS];
@@ -262,45 +272,43 @@ void prepare_and_bench_polling(void)
     buff_args.send_frame_size = 8000;
     buff_args.num_send_frames = 8;
     buff_args.num_recv_frames = 8;
-    auto dev_addr = uhd::device_addr_t();
+    auto dev_addr             = uhd::device_addr_t();
     for (unsigned int i = 0; i < NUM_PORTS; i++) {
-        eth_data[i] = uhd::transport::dpdk_zero_copy::make(
-            ctx,
+        eth_data[i] = uhd::transport::dpdk_zero_copy::make(ctx,
             bench_args[i].portid,
             bench_args[i].dst_ip,
             bench_args[i].src_port,
             bench_args[i].dst_port,
             buff_args,
-            dev_addr
-        );
+            dev_addr);
     }
 
     bench(eth_data, NUM_PORTS, 0.0);
 }
 
-int main(int argc, char **argv)
+int main(int argc, char** argv)
 {
     int retval, io0_cpu = 1, io1_cpu = 1, user0_cpu = 0, user1_cpu = 2;
     std::string args, cpusets;
     po::options_description desc("Allowed options");
-    desc.add_options()
-        ("help", "help message")
-        ("args", po::value<std::string>(&args)->default_value(""), "UHD-DPDK args")
-        ("polling-mode", "Use polling mode (single thread on own core)")
-        ("cpusets", po::value<std::string>(&cpusets)->default_value(""), "which core(s) to use for a given thread (specify something like \"io0=1,io1=1,user0=0,user1=2\")")
-    ;
+    desc.add_options()("help", "help message")(
+        "args", po::value<std::string>(&args)->default_value(""), "UHD-DPDK args")(
+        "polling-mode", "Use polling mode (single thread on own core)")("cpusets",
+        po::value<std::string>(&cpusets)->default_value(""),
+        "which core(s) to use for a given thread (specify something like "
+        "\"io0=1,io1=1,user0=0,user1=2\")");
     po::variables_map vm;
     po::store(po::parse_command_line(argc, argv, desc), vm);
     po::notify(vm);
 
     if (vm.count("help")) {
-       std::cout << desc << std::endl;
-       return 0;
+        std::cout << desc << std::endl;
+        return 0;
     }
 
 
     auto dpdk_args = uhd::device_addr_t(args);
-    for (std::string &key : dpdk_args.keys()) {
+    for (std::string& key : dpdk_args.keys()) {
         /* device_addr_t splits on commas, so we use colons and replace */
         if (key == "corelist" || key == "coremap") {
             dpdk_args[key] = boost::regex_replace(dpdk_args[key], colons, ",");
@@ -308,7 +316,7 @@ int main(int argc, char **argv)
     }
 
     auto cpuset_map = uhd::device_addr_t(cpusets);
-    for (std::string &key : cpuset_map.keys()) {
+    for (std::string& key : cpuset_map.keys()) {
         if (key == "io0") {
             io0_cpu = std::stoi(cpuset_map[key], NULL, 0);
         } else if (key == "io1") {
@@ -321,12 +329,12 @@ int main(int argc, char **argv)
     }
 
     int port_thread_mapping[2] = {io0_cpu, io1_cpu};
-    auto &ctx = uhd::transport::uhd_dpdk_ctx::get();
+    auto& ctx                  = uhd::transport::uhd_dpdk_ctx::get();
     ctx.init(dpdk_args, 2, &port_thread_mapping[0], NUM_MBUFS, MBUF_CACHE_SIZE, 9000);
 
-    uint32_t eth_ip = htonl(0xc0a80003);
+    uint32_t eth_ip   = htonl(0xc0a80003);
     uint32_t eth_mask = htonl(0xffffff00);
-    int status = ctx.set_ipv4_addr(0, eth_ip, eth_mask);
+    int status        = ctx.set_ipv4_addr(0, eth_ip, eth_mask);
     if (status) {
         printf("Error while setting IP0: %d\n", status);
         return status;
@@ -346,19 +354,19 @@ int main(int argc, char **argv)
         struct dpdk_test_args bench_args[2];
         pthread_mutex_init(&bench_args[0].mutex, NULL);
         pthread_mutex_init(&bench_args[1].mutex, NULL);
-        bench_args[0].cpu = user0_cpu;
-        bench_args[0].cond = &cond;
-        bench_args[0].started = false;
-        bench_args[0].portid = 0;
+        bench_args[0].cpu      = user0_cpu;
+        bench_args[0].cond     = &cond;
+        bench_args[0].started  = false;
+        bench_args[0].portid   = 0;
         bench_args[0].src_port = "0xBEE7";
-        bench_args[0].dst_ip = "192.168.0.4";
+        bench_args[0].dst_ip   = "192.168.0.4";
         bench_args[0].dst_port = "0xBEE7";
-        bench_args[1].cpu = user1_cpu;
-        bench_args[1].cond = &cond;
-        bench_args[1].started = false;
-        bench_args[1].portid = 1;
+        bench_args[1].cpu      = user1_cpu;
+        bench_args[1].cond     = &cond;
+        bench_args[1].started  = false;
+        bench_args[1].portid   = 1;
         bench_args[1].src_port = "0xBEE7";
-        bench_args[1].dst_ip = "192.168.0.3";
+        bench_args[1].dst_ip   = "192.168.0.3";
         bench_args[1].dst_port = "0xBEE7";
 
         pthread_t threads[2];
@@ -366,29 +374,29 @@ int main(int argc, char **argv)
         pthread_create(&threads[1], NULL, prepare_and_bench_blocking, &bench_args[1]);
 
         do {
-           pthread_mutex_lock(&bench_args[0].mutex);
-           if (bench_args[0].started)
-               break;
-           pthread_mutex_unlock(&bench_args[0].mutex);
+            pthread_mutex_lock(&bench_args[0].mutex);
+            if (bench_args[0].started)
+                break;
+            pthread_mutex_unlock(&bench_args[0].mutex);
         } while (true);
         pthread_mutex_unlock(&bench_args[0].mutex);
 
         do {
-           pthread_mutex_lock(&bench_args[1].mutex);
-           if (bench_args[1].started)
-               break;
-           pthread_mutex_unlock(&bench_args[1].mutex);
+            pthread_mutex_lock(&bench_args[1].mutex);
+            if (bench_args[1].started)
+                break;
+            pthread_mutex_unlock(&bench_args[1].mutex);
         } while (true);
         pthread_mutex_unlock(&bench_args[1].mutex);
 
         pthread_cond_broadcast(&cond);
 
-        status = pthread_join(threads[0], (void **) &retval);
+        status = pthread_join(threads[0], (void**)&retval);
         if (status) {
             perror("Error while joining thread");
             return status;
         }
-        status = pthread_join(threads[1], (void **) &retval);
+        status = pthread_join(threads[1], (void**)&retval);
         if (status) {
             perror("Error while joining thread");
             return status;