TransmitPacketizer.h

/***************************************************************************
 * \file TransmitPacketizer.h
 *
 * \brief NDR651 transmit packetizer class.
 *
 * \author NH/DA
 * \copyright Copyright (c) 2015-2021 CyberRadio Solutions, Inc.
 *
 */

#ifndef INCLUDED_LIBCYBERRADIO_NDR651_TRANSMITPACKETIZER_H
#define INCLUDED_LIBCYBERRADIO_NDR651_TRANSMITPACKETIZER_H

#include "LibCyberRadio/Common/Debuggable.h"
#include "LibCyberRadio/NDR651/FlowControlClient.h"
#include "LibCyberRadio/NDR651/PacketTypes.h"
#include "LibCyberRadio/NDR651/TransmitSocket.h"
#include "LibCyberRadio/NDR651/UdpStatusReceiver.h"

bool setCpuAffinity(int cpu);

namespace LibCyberRadio
{
    namespace NDR651
    {

        class TransmitPacketizer : public Debuggable
        {
            public:
                TransmitPacketizer(const std::string& radioHostName = "",
                        int radioTcpPort = 8617,
                        unsigned int ducChannel = 1,
                        const std::string& ifname = "eth0",
                        unsigned int tenGigIndex = 1,
                        int dipIndex = -1,
                        unsigned int ducRate = 0,
                        unsigned int ducTxChannels = 0,
                        float ducFreq = 900e6,
                        float ducAtten = 0,
                        double txFreq = 900,
                        float txAtten = 0,
                        unsigned int streamId = 40001,
                        bool config_tx = false,
                        bool debug = false);
                virtual ~TransmitPacketizer();
                bool setRadioHostName(const std::string& radioHostName);
                bool setRadioTcpPort(int radioTcpPort);
                bool setDucChannel(unsigned int ducChannel);
                bool setDucInterface(const std::string& ifname,
                        unsigned int tenGigIndex);
                bool setDucRate(unsigned int ducRate);
                bool setDucTxChannels(unsigned int ducTxChannels);
                bool setDucFreq(float ducFreq);
                bool setDucTxinvMode(unsigned int txinvMode);
                bool setDucAtten(float ducAtten);
                bool setTxFreq(double txFreq);
                bool setTxAtten(float txAtten);
                bool setStreamId(unsigned int streamId);
                bool setDebug(bool debug);
                bool setRadioParameters(
                        const std::string& radioHostName,
                        int radioTcpPort);
                bool setDucParameters(unsigned int tenGigIndex,
                        unsigned int ducRate,
                        unsigned int ducTxChannels,
                        float ducFreq,
                        float ducAtten,
                        double txFreq,
                        float txAtten,
                        unsigned int streamId);
                void start();
                void stop();
                unsigned int sendFrame(short * samples);
                bool isConnected(void);
                bool isReadyToReceive(void);

                void setDuchsParameters(unsigned int duchsPfThresh, unsigned int duchsPeThresh, unsigned int duchsPeriod, bool updatePE);
                unsigned int getDuchsPfThresh(void) { return _duchsPfThresh; };
                unsigned int getDuchsPeThresh(void) { return _duchsPeThresh; };
                unsigned int getDuchsPeriod(void) { return _duchsPeriod; };
                bool getUpdatePE(void) { return _updatePE; };

            private:
                unsigned int _waitLoop(void);
                void _incrementVitaHeader(void);
                bool setEthernetHeader(const std::string& sourceMac,
                        const std::string& destMac);
                bool setIpHeader(const std::string& sourceIp,
                        const std::string& destIp);
                bool setUdpHeader(unsigned short sourcePort,
                        unsigned short destPort);
                bool setVitaHeader(unsigned int streamId);

            private:
                unsigned int _frameCount, _pauseCount;
                /* Radio parameters */
                std::string _radioHostName;
                int _radioTcpPort;
                /* DUC parameters */
                unsigned int _ducChannel;
                std::string _ifname;
                unsigned int _tenGigIndex;
                int _dipIndex;
                unsigned int _ducRate;
                unsigned int _ducTxChannels;
                float _ducFreq;
                float _ducAtten;
                double _txFreq;
                float _txAtten;
                unsigned int _streamId;
                bool _config_tx;
                bool _firstFrame;
                /* Control objects */
                TransmitSocket * _txSock;
                std::vector<TransmitSocket *> _txSockVec;
                unsigned int _numSock, _currentSockIndex;
                FlowControlClient * _fcClient;
                UdpStatusReceiver * _statusRx;
                struct TxFrame _frame;
                unsigned char * _frameStart;
                unsigned int _frameLength;
                /* State data */
                unsigned int _samplesSent;
                std::string _sMac;
                std::string _dMac;
                std::string _sIp;
                std::string _dIp;
                unsigned short _sPort;
                unsigned short _dPort;
                bool _configuring;
                bool _constructing;
                bool _running;
                struct timespec _delayTime;
                unsigned int _samplesPerFrame;
                unsigned int _duchsPeriod, _duchsPfThresh, _duchsPeThresh;
                bool _updatePE;
                unsigned int _txinvMode;

        };

    } /* namespace NDR651 */
}

#endif /* INCLUDED_LIBCYBERRADIO_NDR651_TRANSMITPACKETIZER_H */