dpdk: Add new DPDK stack to integrate with I/O services

docs: Update DPDK docs with new parameters:
Parameter names have had their hyphens changed to underscores, and
the I/O CPU argument is now named after the lcores and reflects
the naming used by DPDK.

transport: Add new udp_dpdk_link, based atop the new APIs:
This link is tightly coupled with the DPDK I/O service. The link class
carries all the address information to communicate with the other
host, and it can send packets directly through the DPDK NIC ports.

However, for receiving packets, the I/O service must pull the packets
from the DMA queue and attach them to the appropriate link object.
The link object merely formats the frame_buff object underneath, which
is embedded in the rte_mbuf container. For get_recv_buff, the link
will pull buffers only from its internal queue (the one filled by the
I/O service).

transport: Add DPDK-specific I/O service:
The I/O service is split into two parts, the user threads and the
I/O worker threads. The user threads submit requests through
various appropriate queues, and the I/O threads perform all the
I/O on their behalf. This includes routing UDP packets to the
correct receiver and getting the MAC address of a destination (by
performing the ARP request and handling the ARP replies).

The DPDK context stores I/O services. The context spawns all I/O
services on init(), and I/O services can be fetched from the dpdk_ctx
object by using a port ID.

I/O service clients:
The clients have two lockless ring buffers. One is to get a buffer
from the I/O service; the other is to release a buffer back to the
I/O service. Threads sleeping on buffer I/O are kept in a separate
list from the service queue and are processed in the course of doing
RX or TX.

The list nodes are embedded in the dpdk_io_if, and the head of the
list is on the dpdk_io_service. The I/O service will transfer the
embedded wait_req to the list if it cannot acquire the mutex to
complete the condition for waking.

Co-authored-by: Martin Braun <martin.braun@ettus.com>
Co-authored-by: Ciro Nishiguchi <ciro.nishiguchi@ni.com>
Co-authored-by: Brent Stapleton <brent.stapleton@ettus.com>

1 files changed, 4 insertions, 29 deletions

diff --git a/host/lib/include/uhdlib/transport/dpdk_simple.hpp b/host/lib/include/uhdlib/transport/dpdk_simple.hpp
index 86abaeff8..8420510ea 100644
--- a/host/lib/include/uhdlib/transport/dpdk_simple.hpp
+++ b/host/lib/include/uhdlib/transport/dpdk_simple.hpp
@@ -8,7 +8,6 @@
 #define INCLUDED_DPDK_SIMPLE_HPP
 
 #include <uhd/transport/udp_simple.hpp>
-#include <uhdlib/transport/dpdk_common.hpp>
 
 namespace uhd { namespace transport {
 
@@ -17,35 +16,11 @@ class dpdk_simple : public udp_simple
 public:
     virtual ~dpdk_simple(void) = 0;
 
-    /*!
-     * Make a new connected dpdk transport:
-     * This transport is for sending and receiving
-     * between this host and a single endpoint.
-     * The primary usage for this transport will be control transactions.
-     *
-     * The address must be an ipv4 address.
-     * The port must be a number.
-     *
-     * \param addr a string representing the destination address
-     * \param port a string representing the destination port
-     */
-    static udp_simple::sptr make_connected(struct uhd_dpdk_ctx &ctx,
-        const std::string &addr, const std::string &port);
+    static udp_simple::sptr make_connected(
+        const std::string& addr, const std::string& port);
 
-    /*!
-     * Make a new broadcasting dpdk transport:
-     * This transport can send broadcast datagrams
-     * and receive datagrams from multiple sources.
-     * The primary usage for this transport will be to discover devices.
-     *
-     * The address must be an ipv4 address.
-     * The port must be a number.
-     *
-     * \param addr a string representing the destination address
-     * \param port a string representing the destination port
-     */
-    static udp_simple::sptr make_broadcast(struct uhd_dpdk_ctx &ctx,
-        const std::string &addr, const std::string &port);
+    static udp_simple::sptr make_broadcast(
+        const std::string& addr, const std::string& port);
 
     /*!
      * Send a single buffer.