Nljs.hpp

Go to the documentation of this file.

/*
 * This file is 100% generated.  Any manual edits will likely be lost.
 *
 * This contains functions struct and other type definitions for shema in 
 * namespace dunedaq::dpdklibs::nicreader to be serialized via nlohmann::json.
 */
#ifndef DUNEDAQ_DPDKLIBS_NICREADER_NLJS_HPP
#define DUNEDAQ_DPDKLIBS_NICREADER_NLJS_HPP
 
// My structs
#include "dpdklibs/nicreader/Structs.hpp"
 
 
#include <nlohmann/json.hpp>
 
namespace dunedaq::dpdklibs::nicreader {
 
    using data_t = nlohmann::json;
    
    inline void to_json(data_t& j, const SrcGeoInfo& obj) {
        j["det_id"] = obj.det_id;
        j["crate_id"] = obj.crate_id;
        j["slot_id"] = obj.slot_id;
    }
    
    inline void from_json(const data_t& j, SrcGeoInfo& obj) {
        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);    
    }
    
    inline void to_json(data_t& j, const StreamMap& obj) {
        j["source_id"] = obj.source_id;
        j["stream_id"] = obj.stream_id;
    }
    
    inline void from_json(const data_t& j, StreamMap& obj) {
        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);    
    }
    
    inline void to_json(data_t& j, const Source& obj) {
        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;
    }
    
    inline void from_json(const data_t& j, Source& obj) {
        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);    
    }
    
    inline void to_json(data_t& j, const StatsReporting& obj) {
        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;
    }
    
    inline void from_json(const data_t& j, StatsReporting& obj) {
        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);    
    }
    
    inline void to_json(data_t& j, const Interface& obj) {
        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;
    }
    
    inline void from_json(const data_t& j, Interface& obj) {
        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);    
    }
    
    inline void to_json(data_t& j, const Conf& obj) {
        j["ifaces"] = obj.ifaces;
        j["eal_arg_list"] = obj.eal_arg_list;
    }
    
    inline void from_json(const data_t& j, Conf& obj) {
        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);    
    }
    
} // namespace dunedaq::dpdklibs::nicreader
 
#endif // DUNEDAQ_DPDKLIBS_NICREADER_NLJS_HPP