DUCSink.h

/* -*- c++ -*- */
/***************************************************************************
 * \file DUCSink.h
 *
 * \brief Implementation of the digital upconverter (DUC) transmission
 *    sink block for the NDR651.
 *
 * \author DA
 * \copyright 2015 CyberRadio Solutions, Inc.
 */

#ifndef INCLUDED_LIBCYBERRADIO_NDR651_DUC_SINK_H
#define INCLUDED_LIBCYBERRADIO_NDR651_DUC_SINK_H

#include "LibCyberRadio/Common/Debuggable.h"
#include "LibCyberRadio/NDR651/TransmitPacketizer.h"
#include <stdio.h>
#include <time.h>
#include <sys/types.h>
#include <vector>
#include <complex>
#include <string>


namespace LibCyberRadio
{
    namespace NDR651
    {
        class DUCSink : public Debuggable
        {
            public:
                DUCSink(
                        const std::string& name = "DUCSink",
                        /* For the radio in general */
                        const std::string& radio_host_name = "",
                        unsigned int radio_tcp_port = 8617,
                        unsigned int tengig_iface_index = 1,
                        float iq_scale_factor = 1.0,
                        /* For an individual DUC on the radio */
                        unsigned int duc_channel = 1,
                        const std::string& duc_iface_string = "eth0",
                        unsigned int duc_rate_index = 0,
                        long duc_frequency = 0,
                        float duc_attenuation = 0,
                        unsigned int duc_tx_channels = 0,
                        double duc_tx_frequency = 900,
                        unsigned int duc_tx_attenuation = 0,
                        unsigned int duc_stream_id = 40001,
                        bool config_tx = false,
                        bool debug = false,
                        unsigned int fc_update_rate = 20,
                        bool use_udp = false,
                        bool use_ring_buffer = false,
                        unsigned int duchsPfThresh = 25,
                        unsigned int duchsPeThresh = 24,
                        unsigned int duchsPeriod = 10,
                        bool updatePE = false,
                        int txinv_mode = 0);
                ~DUCSink();
                std::string get_radio_host_name() const;
                int get_radio_tcp_port() const;
                std::vector<std::string> get_tengig_iface_list() const;
                void set_radio_params(const std::string& radio_host_name,
                        int radio_tcp_port,
                        const std::vector<std::string>& tengig_iface_list);
                float get_iq_scale_factor() const;
                void set_iq_scale_factor(float iq_scale_factor);
                int get_duc_channel() const;
                void set_duc_channel(int duc_channel);
                std::string get_duc_iface_string() const;
                int get_duc_iface_index() const;
                void set_duc_iface_string(const std::string& duc_iface_string);
                int get_duc_rate_index() const;
                void set_duc_rate_index(int duc_rate_index);
                long get_duc_frequency() const;
                void set_duc_frequency(long duc_frequency);
                void set_duc_txinv_mode(int duc_txinv_mode);
                float get_duc_attenuation() const;
                void set_duc_attenuation(float duc_attenuation);
                unsigned int get_duc_tx_channels() const;
                void set_duc_tx_channels(unsigned int duc_tx_channels);
                double get_duc_tx_frequency() const;
                void set_duc_tx_frequency(double duc_tx_frequency);
                unsigned int get_duc_tx_attenuation() const;
                void set_duc_tx_attenuation(unsigned int duc_tx_attenuation);
                unsigned int get_duc_stream_id() const;
                void set_duc_stream_id(unsigned int duc_stream_id);
                long get_duc_sample_rate() const;

                void set_duchs_pf_threshold(unsigned int duchsPfThresh);
                void set_duchs_pe_threshold(unsigned int duchsPeThresh);
                void set_duchs_period(unsigned int duchsPeriod);
                void set_duchs_update_pe(bool updatePE);

                bool start();
                bool stop();
                int sendFrames(int noutput_items,
                        std::complex<float>* input_items);

            protected:
                // Get the DUC interface index number from the interface
                // string
                void set_duc_iface_index_from_string();

            protected:
                std::string d_name;
                std::string d_radio_host_name;
                unsigned int d_radio_tcp_port;
                std::vector<std::string> d_tengig_iface_list;
                float d_iq_scale_factor;
                unsigned int d_duc_channel;
                std::string d_duc_iface_string;
                unsigned int d_duc_iface_index;
                unsigned int d_duc_rate_index;
                long d_duc_frequency;
                float d_duc_attenuation;
                unsigned int d_duc_tx_channels;
                double d_duc_tx_frequency;
                unsigned int d_duc_tx_attenuation;
                unsigned int d_duc_stream_id;
                int d_duc_txinv_mode;
                bool    d_config_tx;
                unsigned int d_fc_update_rate;
                bool d_use_udp;
                bool d_use_ring_buffer;
                TransmitPacketizer* d_tx;
                short d_sample_buffer[SAMPLES_PER_FRAME * 2];
                unsigned int d_duchsPfThresh, d_duchsPeThresh, d_duchsPeriod;
                bool d_updatePE;
        };

    } // namespace NDR651

} // namespace LibCyberRadio

#endif /* INCLUDED_LIBCYBERRADIO_NDR651_DUC_SINK_H */