Packetizer.h

#ifndef INCLUDED_LIBCYBERRADIO_NDR651_PACKETIZER_H
#define INCLUDED_LIBCYBERRADIO_NDR651_PACKETIZER_H

#define DAC_RATE 102400000

#include <sys/socket.h>
#include <netinet/in.h>
#include <linux/if_ether.h>
#include <netinet/ip.h>
#include <netinet/udp.h>
#include <arpa/inet.h>
#include <linux/filter.h>
#include "LibCyberRadio/NDR651/TransmitSocket.h"
#include <netpacket/packet.h>
#include <net/ethernet.h>
#include <net/if.h>
#include <sys/types.h>
#include <sys/ioctl.h>
#include <stdio.h>
#include <unistd.h>
#include <ifaddrs.h>
#include <sys/types.h>
#include <sys/uio.h>
#include <unistd.h>

#include "LibCyberRadio/Common/Debuggable.h"
#include "LibCyberRadio/NDR651/PacketTypes.h"

namespace LibCyberRadio
{
    namespace NDR651
    {

        class Packetizer : public Debuggable
        {

            private:
                std::string txInterfaceName;
                unsigned short txUdpPort;
                unsigned int samplesPerFrame;
                unsigned long long sampleRate;
                int txSocket;
                struct iovec txVec[3];  // Will hold Vita Header, Payload of Samples, Vita Footer
                uint32_t fracTimestampIncrement;

                /* Instance methods */
                void setVitaHeader(unsigned short streamId);
                void incrementVitaHeader();
                void initBroadcastTxSocket(const std::string &txInterfaceName, unsigned short port);
                unsigned long long calculateSampleRate(unsigned int ducRateIndex);


            public:
                Packetizer(const std::string &txInterfaceName, unsigned short port, unsigned int ducRateIndex, bool debug = false);
                ~Packetizer();

                int getSocketFd();
                void start();
                void sendFrame(short * samples);
                void setSamplesPerFrame(unsigned int samplesPerFrame);


        };
    }
}

#endif /* INCLUDED_LIBCYBERRADIO_NDR651_PACKETIZER_H */