VitaIqSource.h

/* -*- c++ -*- */
/***************************************************************************
 * \file VitaIqSource.h
 *
 * \brief Generic VITA 49-compatible I/Q data source block.
 *
 * \author DA
 * \copyright 2015 CyberRadio Solutions, Inc.
 */


#ifndef INCLUDED_LIBCYBERRADIO_VITAIQSOURCE_H_
#define INCLUDED_LIBCYBERRADIO_VITAIQSOURCE_H_

#include "LibCyberRadio/Common/Debuggable.h"
#include "LibCyberRadio/Common/Vita49Packet.h"
#include "LibCyberRadio/Common/VitaIqUdpPort.h"
#include <boost/thread.hpp>
#include <string>
#include <vector>


namespace LibCyberRadio
{
    typedef std::vector<Vita49Packet> Vita49PacketVector;

    class VitaIqSource : public Debuggable
    {
        public:

            VitaIqSource(const std::string& name = "VitaIqSource",
                    int vita_type = 0,
                    size_t payload_size = 8192,
                    size_t vita_header_size = 0,
                    size_t vita_tail_size = 0,
                    bool byte_swapped = false,
                    bool iq_swapped = false,
                    const std::string& host = "0.0.0.0",
                    unsigned short port = 0,
                    bool debug = false);
            virtual ~VitaIqSource();
            virtual int getPackets(int noutput_items, Vita49PacketVector& output_items);
            virtual int getPacketSize() const;
            virtual int getPacketsPayloadData(int noutput_items, void * buff);
            bool isByteSwapped() const;
            bool isIqSwapped() const;
            size_t getPayloadSize() const;
            size_t getVitaHeaderSize() const;
            size_t getVitaTailSize() const;
            int getVitaType() const;

        protected:
            // Packet size recalculator
            void recalc_packet_size();
            // Connect UDP port
            void connect_udp_port();
            // Disconnect UDP port
            void disconnect_udp_port();

        private:
            std::string d_name;
            int     d_vita_type;
            size_t  d_payload_size;  // maximum transmission unit (packet length)
            size_t  d_vita_header_size;
            size_t  d_vita_tail_size;
            bool    d_byte_swapped;
            bool    d_iq_swapped;
            std::string d_host;
            unsigned short d_port;
            size_t  d_packet_size;
            VitaIqUdpPort* d_udp_port;
            boost::mutex d_udp_port_mtx;
    };

} // namespace LibCyberRadio

#endif /* INCLUDED_LIBCYBERRADIO_VITAIQSOURCE_H_ */