StreamCrossover.cpp

Go to the documentation of this file.

// ======================================================================
// \title  StreamCrossover.cpp
// \author ethanchee
// \brief  cpp file for StreamCrossover component implementation class
// ======================================================================


#include <Drv/StreamCrossover/StreamCrossover.hpp>
#include <FpConfig.hpp>

namespace Drv {

  // ----------------------------------------------------------------------
  // Construction, initialization, and destruction
  // ----------------------------------------------------------------------

  StreamCrossover ::
    StreamCrossover(
        const char *const compName
    ) : StreamCrossoverComponentBase(compName)
  {

  }

  StreamCrossover ::
    ~StreamCrossover()
  {

  }

  // ----------------------------------------------------------------------
  // Handler implementations for user-defined typed input ports
  // ----------------------------------------------------------------------

  void StreamCrossover ::
    streamIn_handler(
        const NATIVE_INT_TYPE portNum,
        Fw::Buffer &recvBuffer,
        const Drv::RecvStatus &recvStatus
    )
  {
    if(recvStatus == Drv::RecvStatus::RECV_ERROR || recvBuffer.getSize() == 0)
    {
      this->log_WARNING_HI_StreamOutError(Drv::SendStatus::SEND_ERROR);
      this->errorDeallocate_out(0, recvBuffer);
      return;
    }

    Drv::SendStatus sendStatus = this->streamOut_out(0, recvBuffer);

    if(sendStatus != Drv::SendStatus::SEND_OK)
    {
      this->log_WARNING_HI_StreamOutError(sendStatus);
    }
  }

} // end namespace Drv