XstatsHelper.hpp

Go to the documentation of this file.

#ifndef DPDKLIBS_INCLUDE_DPDKLIBS_XSTATSHELPER_HPP_
#define DPDKLIBS_INCLUDE_DPDKLIBS_XSTATSHELPER_HPP_
 
#include <rte_ethdev.h>
 
namespace dunedaq::dpdklibs {
 
  struct IfaceXstats {
    IfaceXstats(){}
    ~IfaceXstats() 
    {
      clear();
    }
 
    void clear() {
      if (m_xstats_values != nullptr) {
        free(m_xstats_values);
      }
      if (m_xstats_ids != nullptr) {
        free(m_xstats_ids);
      }
      if (m_xstats_names != nullptr) {
        free(m_xstats_names);
      }
      m_len = 0;
    }
 
    void setup(int iface) {
      m_iface_id = iface;
      rte_eth_stats_reset(m_iface_id);
      rte_eth_xstats_reset(m_iface_id);
 
      // Get number of stats
      m_len = rte_eth_xstats_get_names_by_id(m_iface_id, NULL, 0, NULL);
      if (m_len < 0) {
        printf("Cannot get xstats count\n");
      }
 
      // Get names of HW registered stat fields
      m_xstats_names = (rte_eth_xstat_name*)(malloc(sizeof(struct rte_eth_xstat_name) * m_len));
      if (m_xstats_names == nullptr) {
        printf("Cannot allocate memory for xstat names\n");
      }
 
      // Retrieve xstats names, passing NULL for IDs to return all statistics
      if (m_len != rte_eth_xstats_get_names(m_iface_id, m_xstats_names, m_len)) {
        printf("Cannot get xstat names\n");
      }
 
      // Allocate value fields
      m_xstats_values = (uint64_t*)(malloc(sizeof(m_xstats_values) * m_len));
      if (m_xstats_values == nullptr) {
        printf("Cannot allocate memory for xstats\n");
      }
 
      // Getting xstats values (this is that we call in a loop/get_info
      if (m_len != rte_eth_xstats_get_by_id(m_iface_id, nullptr, m_xstats_values, m_len)) {
        printf("Cannot get xstat values\n");
      }
 
      // Print all xstats names and values to be amazed (WOW!)
      TLOG() << "Registered HW based metrics: ";        
      for (int i = 0; i < m_len; i++) {
        TLOG() << "  XName: " << m_xstats_names[i].name;
      }
 
      m_enabled = true;
    };
 
    void reset_counters() {
      if (m_enabled) {
        rte_eth_xstats_reset(m_iface_id); //{
        //  TLOG() << "Cannot reset xstat values!";
        //} else { 
        //}
      }
    }
 
    void poll() {
      if (m_enabled) {
        if (m_len != rte_eth_xstats_get_by_id(m_iface_id, nullptr, m_xstats_values, m_len)) {
          TLOG() << "Cannot get xstat values!";
        //} else { 
        }
 
        rte_eth_stats_get(m_iface_id, &m_eth_stats);
      }
    }
 
    void stop() {
      m_enabled = false;
      clear();
      TLOG() << "XstatsHelper disabled.";
    }
    
    int m_iface_id;
    bool m_enabled = false;
    struct rte_eth_stats m_eth_stats;
    struct rte_eth_xstat_name *m_xstats_names;
    uint64_t *m_xstats_ids;
    uint64_t *m_xstats_values;
    int m_len;
 
  };
 
}
 
#endif // DPDKLIBS_INCLUDE_DPDKLIBS_XSTATSHELPER_HPP_