UdpSenderComponentImpl.hpp

Go to the documentation of this file.

// ======================================================================
// \title  UdpSenderImpl.hpp
// \author tcanham
// \brief  hpp file for UdpSender component implementation class
//
// \copyright
// Copyright 2009-2015, by the California Institute of Technology.
// ALL RIGHTS RESERVED.  United States Government Sponsorship
// acknowledged.
//
// ======================================================================
 
#ifndef UdpSender_HPP
#define UdpSender_HPP
 
#include <Svc/UdpSender/UdpSenderComponentAc.hpp>
#include <UdpSenderComponentImplCfg.hpp>
#include <sys/socket.h>
#include <arpa/inet.h>
 
 
namespace Svc {
 
  class UdpSenderComponentImpl :
    public UdpSenderComponentBase
  {
 
    public:
 
      // ----------------------------------------------------------------------
      // Construction, initialization, and destruction
      // ----------------------------------------------------------------------
 
      UdpSenderComponentImpl(
          const char *const compName 
      );
 
      void init(
          const NATIVE_INT_TYPE queueDepth, 
          const NATIVE_INT_TYPE msgSize, 
          const NATIVE_INT_TYPE instance = 0 
      );
 
 
      ~UdpSenderComponentImpl();
 
      void open(
              const char* addr,  
              const char* port 
      );
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Handler implementations for user-defined typed input ports
      // ----------------------------------------------------------------------
 
      void Sched_handler(
          const NATIVE_INT_TYPE portNum, 
          NATIVE_UINT_TYPE context 
      );
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Handler implementations for user-defined serial input ports
      // ----------------------------------------------------------------------
 
      void PortsIn_handler(
        NATIVE_INT_TYPE portNum, 
        Fw::SerializeBufferBase &Buffer 
      );
 
      NATIVE_INT_TYPE m_fd; 
      NATIVE_UINT_TYPE m_packetsSent; 
      NATIVE_UINT_TYPE m_bytesSent; 
      U8 m_seq; 
 
      struct sockaddr_in m_servAddr;  
 
      class UdpSerialBuffer :
        public Fw::SerializeBufferBase
      {
 
        public:
 
#ifdef BUILD_UT
          UdpSerialBuffer& operator=(const UdpSerialBuffer& other);
          UdpSerialBuffer(const Fw::SerializeBufferBase& other);
          UdpSerialBuffer(const UdpSerialBuffer& other);
          UdpSerialBuffer();
#endif
 
          NATIVE_UINT_TYPE getBuffCapacity() const {
            return sizeof(m_buff);
          }
 
          // Get the max number of bytes that can be serialized
          NATIVE_UINT_TYPE getBuffSerLeft() const {
 
            const NATIVE_UINT_TYPE size  = getBuffCapacity();
            const NATIVE_UINT_TYPE loc = getBuffLength();
 
            if (loc >= (size-1) ) {
                return 0;
            }
            else {
                return (size - loc - 1);
            }
          }
 
          U8* getBuffAddr() {
            return m_buff;
          }
 
          const U8* getBuffAddr() const {
            return m_buff;
          }
 
        private:
          // Should be the max of all the input ports serialized sizes...
          U8 m_buff[UDP_SENDER_MSG_SIZE];
 
      } m_sendBuff;
 
    };
 
} // end namespace Svc
 
#endif