UdpReceiverComponentImpl.hpp

Go to the documentation of this file.

// ======================================================================
// \title  UdpReceiverImpl.hpp
// \author tcanham
// \brief  hpp file for UdpReceiver component implementation class
//
// \copyright
// Copyright 2009-2015, by the California Institute of Technology.
// ALL RIGHTS RESERVED.  United States Government Sponsorship
// acknowledged.
//
// ======================================================================
 
#ifndef UdpReceiver_HPP
#define UdpReceiver_HPP
 
#include "Svc/UdpReceiver/UdpReceiverComponentAc.hpp"
#include "UdpReceiverComponentImplCfg.hpp"
 
namespace Svc {
 
  class UdpReceiverComponentImpl :
    public UdpReceiverComponentBase
  {
 
    public:
 
      // ----------------------------------------------------------------------
      // Construction, initialization, and destruction
      // ----------------------------------------------------------------------
 
      UdpReceiverComponentImpl(
          const char *const compName 
      );
 
      void init(
          const NATIVE_INT_TYPE instance = 0 
      );
 
      ~UdpReceiverComponentImpl();
 
      void open(
              const char* port
              );
 
      void startThread(
              NATIVE_UINT_TYPE priority, 
              NATIVE_UINT_TYPE stackSize, 
              NATIVE_UINT_TYPE affinity 
      );
 
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Handler implementations for user-defined typed input ports
      // ----------------------------------------------------------------------
 
      void Sched_handler(
          const NATIVE_INT_TYPE portNum, 
          U32 context 
      );
 
      static void workerTask(void* ptr); 
      void doRecv(); 
      Os::Task m_socketTask;
 
      NATIVE_INT_TYPE m_fd; 
 
      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_RECEIVER_MSG_SIZE];
 
      } m_recvBuff;
 
      UdpSerialBuffer m_portBuff; 
 
      U32 m_packetsReceived; 
      U32 m_bytesReceived; 
      U32 m_packetsDropped; 
      U32 m_decodeErrors; 
 
      bool m_firstSeq; 
      U8 m_currSeq; 
 
 
    };
 
} // end namespace Svc
 
#endif