mudpiPubCfg.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_REUSABLECOMPONENT_MUDPIGENPUB_MUDPI_PUB_CFG_HPP
#define RTCTK_REUSABLECOMPONENT_MUDPIGENPUB_MUDPI_PUB_CFG_HPP
 
#include <numapp/numapolicies.hpp>
 
#include <optional>
#include <string>
#include <tuple>
#include <vector>
 
namespace rtctk::mudpiPub {
 
struct PubCfg {
    // The destination hostname where MUDPI packets are sent.
    std::string hostname = "localhost";
 
    // The multicast group where MUDPI packets are sent.
    std::string multicast_group;
 
    // The destination port where packets are sent.
    uint16_t port = 6000;
 
    // The topic ID to encode into the packets.
    int32_t topic_id = 0;
 
    // The MUDPI component id
    uint16_t component_id = 25;
 
    // The MUDPI application tag
    uint16_t application_tag = 0;
 
    // The size of the buffer for a single MUDPI packet in bytes (incl. MUDPI header and checksum).
    uint32_t buffer_size = 8972;  // 9000 (ESO MTU) - 20 (IP header) - 8 (UDP header)
 
    // The total sample size in bytes, i.e. the total size of the payloads across all frames.
    uint32_t sample_size = 47000;
 
    // how much to increment the sample id each cycle
    uint32_t sample_id_increment = 1;
 
    // An identifier indicating the payload pattern to generate.
    std::string payload_pattern = "alternating_uint8_ramp";
 
    // Pathname of the FITS file to load (goes together with data_column)
    std::string data_file;
 
    // Name of the FITS column to load (goes together with data_file)
    std::string data_column;
 
    // Flag if MUDPI frame checksum should be calculated
    bool calculate_checksum = true;
 
    // thread policies
    std::optional<numapp::NumaPolicies> thread_policies = std::nullopt;
};
 
struct AppCfg {
    // Delay between samples in nanoseconds.
    int64_t period = 1'000'000'000;
 
    // The maximum number of samples to generate. Negative numbers indicate no maximum.
    int64_t max_samples = -1;
 
    // By how much to increment sample id every cycle
    uint32_t sample_id_increment = 1;
 
    // config of individual channels
    std::vector<std::tuple<std::string, PubCfg>> pubs;
};
 
}  // namespace rtctk::mudpiPub
 
#endif  // RTCTK_REUSABLECOMPONENT_MUDPIGENPUB_MUDPI_PUB_CFG_HPP