dunedaq::dpdklibs::nicreader Namespace Reference

Classes
struct	Conf
struct	Interface
struct	Source
struct	SrcGeoInfo
struct	StatsReporting
struct	StreamMap

Typedefs
using	BigCount = int64_t
using	Choice = bool
using	pci = std::string
using	mac = std::string
using	ipv4 = std::string
using	Count = uint32_t
using	Identifier = int32_t
using	SrcStreamsMapping = std::vector<dunedaq::dpdklibs::nicreader::StreamMap>
using	Sources = std::vector<dunedaq::dpdklibs::nicreader::Source>
using	IfaceList = std::vector<dunedaq::dpdklibs::nicreader::Interface>
using	Float = float

Functions
void	to_json (data_t &j, const SrcGeoInfo &obj)
void	from_json (const data_t &j, SrcGeoInfo &obj)
void	to_json (data_t &j, const StreamMap &obj)
void	from_json (const data_t &j, StreamMap &obj)
void	to_json (data_t &j, const Source &obj)
void	from_json (const data_t &j, Source &obj)
void	to_json (data_t &j, const StatsReporting &obj)
void	from_json (const data_t &j, StatsReporting &obj)
void	to_json (data_t &j, const Interface &obj)
void	from_json (const data_t &j, Interface &obj)
void	to_json (data_t &j, const Conf &obj)
void	from_json (const data_t &j, Conf &obj)

Typedef Documentation

BigCount

using dunedaq::dpdklibs::nicreader::BigCount = int64_t

Definition at line 18 of file Structs.hpp.

Choice

using dunedaq::dpdklibs::nicreader::Choice = bool

Definition at line 22 of file Structs.hpp.

Count

using dunedaq::dpdklibs::nicreader::Count = uint32_t

Definition at line 34 of file Structs.hpp.

Float

using dunedaq::dpdklibs::nicreader::Float = float

Definition at line 177 of file Structs.hpp.

Identifier

using dunedaq::dpdklibs::nicreader::Identifier = int32_t

Definition at line 38 of file Structs.hpp.

IfaceList

using dunedaq::dpdklibs::nicreader::IfaceList = std::vector<dunedaq::dpdklibs::nicreader::Interface>

Definition at line 160 of file Structs.hpp.

ipv4

using dunedaq::dpdklibs::nicreader::ipv4 = std::string

Definition at line 31 of file Structs.hpp.

mac

using dunedaq::dpdklibs::nicreader::mac = std::string

Definition at line 28 of file Structs.hpp.

pci

using dunedaq::dpdklibs::nicreader::pci = std::string

Definition at line 25 of file Structs.hpp.

Sources

using dunedaq::dpdklibs::nicreader::Sources = std::vector<dunedaq::dpdklibs::nicreader::Source>

Definition at line 93 of file Structs.hpp.

SrcStreamsMapping

using dunedaq::dpdklibs::nicreader::SrcStreamsMapping = std::vector<dunedaq::dpdklibs::nicreader::StreamMap>

Definition at line 67 of file Structs.hpp.

Function Documentation

from_json() [1/6]

void dunedaq::dpdklibs::nicreader::from_json ( const data_t & j, Conf & obj )

inline

Definition at line 142 of file Nljs.hpp.

                                                      {
        if (j.contains("ifaces"))
            j.at("ifaces").get_to(obj.ifaces);    
        if (j.contains("eal_arg_list"))
            j.at("eal_arg_list").get_to(obj.eal_arg_list);    
    }

from_json() [2/6]

void dunedaq::dpdklibs::nicreader::from_json ( const data_t & j, Interface & obj )

inline

Definition at line 106 of file Nljs.hpp.

                                                           {
        if (j.contains("pci_addr"))
            j.at("pci_addr").get_to(obj.pci_addr);    
        if (j.contains("mac_addr"))
            j.at("mac_addr").get_to(obj.mac_addr);    
        if (j.contains("ip_addr"))
            j.at("ip_addr").get_to(obj.ip_addr);    
        if (j.contains("with_flow_control"))
            j.at("with_flow_control").get_to(obj.with_flow_control);    
        if (j.contains("promiscuous_mode"))
            j.at("promiscuous_mode").get_to(obj.promiscuous_mode);    
        if (j.contains("mtu"))
            j.at("mtu").get_to(obj.mtu);    
        if (j.contains("rx_ring_size"))
            j.at("rx_ring_size").get_to(obj.rx_ring_size);    
        if (j.contains("tx_ring_size"))
            j.at("tx_ring_size").get_to(obj.tx_ring_size);    
        if (j.contains("num_mbufs"))
            j.at("num_mbufs").get_to(obj.num_mbufs);    
        if (j.contains("mbuf_cache_size"))
            j.at("mbuf_cache_size").get_to(obj.mbuf_cache_size);    
        if (j.contains("burst_size"))
            j.at("burst_size").get_to(obj.burst_size);    
        if (j.contains("lcore_sleep_us"))
            j.at("lcore_sleep_us").get_to(obj.lcore_sleep_us);    
        if (j.contains("expected_sources"))
            j.at("expected_sources").get_to(obj.expected_sources);    
        if (j.contains("stats_reporting_cfg"))
            j.at("stats_reporting_cfg").get_to(obj.stats_reporting_cfg);    
    }

from_json() [3/6]

void dunedaq::dpdklibs::nicreader::from_json ( const data_t & j, Source & obj )

inline

Definition at line 56 of file Nljs.hpp.

                                                        {
        if (j.contains("id"))
            j.at("id").get_to(obj.id);    
        if (j.contains("ip_addr"))
            j.at("ip_addr").get_to(obj.ip_addr);    
        if (j.contains("lcore"))
            j.at("lcore").get_to(obj.lcore);    
        if (j.contains("rx_q"))
            j.at("rx_q").get_to(obj.rx_q);    
        if (j.contains("src_info"))
            j.at("src_info").get_to(obj.src_info);    
        if (j.contains("src_streams_mapping"))
            j.at("src_streams_mapping").get_to(obj.src_streams_mapping);    
    }

from_json() [4/6]

void dunedaq::dpdklibs::nicreader::from_json ( const data_t & j, SrcGeoInfo & obj )

inline

Definition at line 26 of file Nljs.hpp.

                                                            {
        if (j.contains("det_id"))
            j.at("det_id").get_to(obj.det_id);    
        if (j.contains("crate_id"))
            j.at("crate_id").get_to(obj.crate_id);    
        if (j.contains("slot_id"))
            j.at("slot_id").get_to(obj.slot_id);    
    }

from_json() [5/6]

void dunedaq::dpdklibs::nicreader::from_json ( const data_t & j, StatsReporting & obj )

inline

Definition at line 78 of file Nljs.hpp.

                                                                {
        if (j.contains("expected_seq_id_step"))
            j.at("expected_seq_id_step").get_to(obj.expected_seq_id_step);    
        if (j.contains("expected_timestamp_step"))
            j.at("expected_timestamp_step").get_to(obj.expected_timestamp_step);    
        if (j.contains("expected_packet_size"))
            j.at("expected_packet_size").get_to(obj.expected_packet_size);    
        if (j.contains("analyze_nth_packet"))
            j.at("analyze_nth_packet").get_to(obj.analyze_nth_packet);    
    }

from_json() [6/6]

void dunedaq::dpdklibs::nicreader::from_json ( const data_t & j, StreamMap & obj )

inline

Definition at line 40 of file Nljs.hpp.

                                                           {
        if (j.contains("source_id"))
            j.at("source_id").get_to(obj.source_id);    
        if (j.contains("stream_id"))
            j.at("stream_id").get_to(obj.stream_id);    
    }

to_json() [1/6]

void dunedaq::dpdklibs::nicreader::to_json ( data_t & j, const Conf & obj )

inline

Definition at line 137 of file Nljs.hpp.

                                                    {
        j["ifaces"] = obj.ifaces;
        j["eal_arg_list"] = obj.eal_arg_list;
    }

to_json() [2/6]

void dunedaq::dpdklibs::nicreader::to_json ( data_t & j, const Interface & obj )

inline

Definition at line 89 of file Nljs.hpp.

                                                         {
        j["pci_addr"] = obj.pci_addr;
        j["mac_addr"] = obj.mac_addr;
        j["ip_addr"] = obj.ip_addr;
        j["with_flow_control"] = obj.with_flow_control;
        j["promiscuous_mode"] = obj.promiscuous_mode;
        j["mtu"] = obj.mtu;
        j["rx_ring_size"] = obj.rx_ring_size;
        j["tx_ring_size"] = obj.tx_ring_size;
        j["num_mbufs"] = obj.num_mbufs;
        j["mbuf_cache_size"] = obj.mbuf_cache_size;
        j["burst_size"] = obj.burst_size;
        j["lcore_sleep_us"] = obj.lcore_sleep_us;
        j["expected_sources"] = obj.expected_sources;
        j["stats_reporting_cfg"] = obj.stats_reporting_cfg;
    }

to_json() [3/6]

void dunedaq::dpdklibs::nicreader::to_json ( data_t & j, const Source & obj )

inline

Definition at line 47 of file Nljs.hpp.

                                                      {
        j["id"] = obj.id;
        j["ip_addr"] = obj.ip_addr;
        j["lcore"] = obj.lcore;
        j["rx_q"] = obj.rx_q;
        j["src_info"] = obj.src_info;
        j["src_streams_mapping"] = obj.src_streams_mapping;
    }

to_json() [4/6]

void dunedaq::dpdklibs::nicreader::to_json ( data_t & j, const SrcGeoInfo & obj )

inline

Definition at line 20 of file Nljs.hpp.

                                                          {
        j["det_id"] = obj.det_id;
        j["crate_id"] = obj.crate_id;
        j["slot_id"] = obj.slot_id;
    }

to_json() [5/6]

void dunedaq::dpdklibs::nicreader::to_json ( data_t & j, const StatsReporting & obj )

inline

Definition at line 71 of file Nljs.hpp.

                                                              {
        j["expected_seq_id_step"] = obj.expected_seq_id_step;
        j["expected_timestamp_step"] = obj.expected_timestamp_step;
        j["expected_packet_size"] = obj.expected_packet_size;
        j["analyze_nth_packet"] = obj.analyze_nth_packet;
    }

to_json() [6/6]

void dunedaq::dpdklibs::nicreader::to_json ( data_t & j, const StreamMap & obj )

inline

Definition at line 35 of file Nljs.hpp.

                                                         {
        j["source_id"] = obj.source_id;
        j["stream_id"] = obj.stream_id;
    }