packet_txrx_dpdk.h

Go to the documentation of this file.

 
#ifndef PACKETTXRX_DPDK_H_
#define PACKETTXRX_DPDK_H_
 
#if !defined(USE_DPDK)
static_assert(false, "Packet tx rx dpdk defined but DPDK is not enabled");
#endif
 
#include "dpdk_transport.h"
#include "packet_txrx.h"
 
//Removed support for copy free dpdk memory due to slowdown issue.
//#define USE_DPDK_MEMORY
 
#if defined(USE_DPDK_MEMORY)
class DPDKRxPacket : public RxPacket {
 public:
  DPDKRxPacket() : RxPacket() { mem_ = nullptr; }
  explicit DPDKRxPacket(const DPDKRxPacket& copy) : RxPacket(copy) {
    mem_ = copy.mem_;
  }
  ~DPDKRxPacket() = default;
  inline bool Set(rte_mbuf* mem, Packet* in_pkt) {
    mem_ = mem;
    return RxPacket::Set(in_pkt);
  }
 
 private:
  rte_mbuf* mem_;
  inline void GcPacket() override {
    //std::printf("Garbage collecting the memory for DPDKRxPacket\n");
    rte_pktmbuf_free(mem_);
    this->Set(nullptr, nullptr);
  }
};
#endif  // defined(USE_DPDK_MEMORY)
 
class PacketTxRxDpdk : public PacketTxRx {
 public:
  PacketTxRxDpdk(Config* const cfg, size_t core_offset,
                 moodycamel::ConcurrentQueue<EventData>* event_notify_q,
                 moodycamel::ConcurrentQueue<EventData>* tx_pending_q,
                 moodycamel::ProducerToken** notify_producer_tokens,
                 moodycamel::ProducerToken** tx_producer_tokens,
                 Table<char>& rx_buffer, size_t packet_num_in_buffer,
                 Table<size_t>& frame_start, char* tx_buffer);
  ~PacketTxRxDpdk() final;
 
 private:
  void DoTxRx(size_t tid);  // The thread function for thread [tid]
 
  bool CreateWorker(size_t tid, size_t interface_count, size_t interface_offset,
                    size_t* rx_frame_start, std::vector<RxPacket>& rx_memory,
                    std::byte* const tx_memory) final;
 
  uint32_t bs_rru_addr_;     // IPv4 address of the simulator sender
  uint32_t bs_server_addr_;  // IPv4 address of the Agora server
  rte_mempool* mbuf_pool_;
 
  // Worker x (dpdk dev : queueid)
  std::vector<std::vector<std::pair<uint16_t, uint16_t>>>
      worker_dev_queue_assignment_;
 
  // Dimension 1: socket_thread
  // Dimension 2: rx_packet
#if defined(USE_DPDK_MEMORY)
  std::vector<std::vector<DPDKRxPacket>> rx_packets_dpdk_;
#endif
};
 
#endif  // PACKETTXRX_DPDK_H_