snapshot_vector_source_impl.h

Go to the documentation of this file.

/* -*- c++ -*- */
/*
 * Copyright 2022 G3.
 *
 * SPDX-License-Identifier: GPL-3.0-or-later
 */
 
#ifndef INCLUDED_CYBERRADIO_SNAPSHOT_VECTOR_SOURCE_IMPL_H
#define INCLUDED_CYBERRADIO_SNAPSHOT_VECTOR_SOURCE_IMPL_H
 
#include <CyberRadio/snapshot_vector_source.h>
 
#include <arpa/inet.h>
#include <errno.h>
#include <fcntl.h>
#include <inttypes.h>
#include <linux/if_ether.h>
#include <linux/if_packet.h>
#include <netinet/ip.h>
#include <netinet/udp.h>
#include <net/ethernet.h>
#include <net/if.h>
#include <netinet/in.h>
#include <netdb.h>
#include <poll.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/mman.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <sys/un.h>
#include <unistd.h>
#include <boost/bind/bind.hpp>
#include <iostream>
#include <vector>
#include <volk/volk.h>
#include <poll.h>
#include <sys/uio.h>
 
#include "packet_types.h"
 
 
namespace gr {
  namespace CyberRadio {
 
    class snapshot_vector_source_impl : public snapshot_vector_source
    {
     private:
 
      std::string d_radio_type;
      std::string d_ip;
      unsigned int d_port;
      unsigned int d_block_rate;
      unsigned int d_block_size;
      bool d_tag_frame;
      
      std::string ip;
      unsigned int port;
      unsigned int block_rate;
      unsigned int block_size;
      unsigned int packets_per_block;
 
      bool d_byteSwap, d_iqSwap;
      bool d_bswap32, d_bswap16;
      int d_samples_per_frame;
      bool initializing, running;
 
 
      int stream_counter, sample_counter;
      bool program_starting;
      int sock_fd;
      std::vector<gr_complex> sampleVector;
      struct iovec rxVec[3];
      int expectedRxSize;
      struct pollfd pfd;
      
      int32_t thisCount,lastCount,countDiff;
      bool d_iq_swap, d_byte_swap;
      
      void (*_parseHeader)(char *, int);
 
      void set_bswap_flags(void);
      void set_byteSwap(bool byteSwap);
      void set_iqSwap(bool iqSwap);
      
      static void _parseHeaderNull(char * hdr, int hdr_len) {std::cout << "_parseHeaderNull" << std::endl;};
      static void _parseHeaderNdr308(char * hdr, int hdr_len) {std::cout << "_parseHeaderNdr308" << std::endl;};
      static void _parseHeaderNdr551(char * hdr, int hdr_len) {std::cout << "_parseHeaderNdr551" << std::endl;};
 
      void rxControlMsg(pmt::pmt_t msg);
      void txStatusMsg(void);
      
      void determine_radio_type( void );
 
     public:
      snapshot_vector_source_impl(const std::string radio_type, const std::string &ip, unsigned int port, unsigned int block_size, unsigned int block_rate);
      ~snapshot_vector_source_impl();
      int initSocket(const std::string ip, unsigned short port);
      void pause();
      
      bool start(void);
      bool stop(void);
 
      int work(
              int noutput_items,
              gr_vector_const_void_star &input_items,
              gr_vector_void_star &output_items
      );
    };
 
  } // namespace CyberRadio
} // namespace gr
 
#endif /* INCLUDED_CYBERRADIO_SNAPSHOT_VECTOR_SOURCE_IMPL_H */