UdpComponentImpl.cpp

Go to the documentation of this file.

// ======================================================================
// \title  UdpComponentImpl.cpp
// \author mstarch
// \brief  cpp file for UdpComponentImpl component implementation class
//
// \copyright
// Copyright 2009-2020, by the California Institute of Technology.
// ALL RIGHTS RESERVED.  United States Government Sponsorship
// acknowledged.
//
// ======================================================================
 
#include <Drv/Udp/UdpComponentImpl.hpp>
#include <IpCfg.hpp>
#include "Fw/Types/BasicTypes.hpp"
 
 
namespace Drv {
 
// ----------------------------------------------------------------------
// Construction, initialization, and destruction
// ----------------------------------------------------------------------
 
UdpComponentImpl::UdpComponentImpl(const char* const compName)
    : ByteStreamDriverModelComponentBase(compName),
      SocketReadTask() {}
 
void UdpComponentImpl::init(const NATIVE_INT_TYPE instance) {
    ByteStreamDriverModelComponentBase::init(instance);
}
 
SocketIpStatus UdpComponentImpl::configureSend(const char* hostname,
                                                 const U16 port,
                                                 const U32 send_timeout_seconds,
                                                 const U32 send_timeout_microseconds) {
    return m_socket.configureSend(hostname, port, send_timeout_seconds, send_timeout_microseconds);
}
 
SocketIpStatus UdpComponentImpl::configureRecv(const char* hostname, const U16 port) {
    return m_socket.configureRecv(hostname, port);
}
 
UdpComponentImpl::~UdpComponentImpl(void) {}
 
// ----------------------------------------------------------------------
// Implementations for socket read task virtual methods
// ----------------------------------------------------------------------
 
IpSocket& UdpComponentImpl::getSocketHandler() {
    return m_socket;
}
 
Fw::Buffer UdpComponentImpl::getBuffer() {
    return allocate_out(0, 1024);
}
 
void UdpComponentImpl::sendBuffer(Fw::Buffer buffer, SocketIpStatus status) {
    this->recv_out(0, buffer, (status == SOCK_SUCCESS) ? RECV_OK : RECV_ERROR);
}
 
// ----------------------------------------------------------------------
// Handler implementations for user-defined typed input ports
// ----------------------------------------------------------------------
 
Drv::SendStatus UdpComponentImpl::send_handler(const NATIVE_INT_TYPE portNum, Fw::Buffer& fwBuffer) {
    Drv::SocketIpStatus status = m_socket.send(fwBuffer.getData(), fwBuffer.getSize());
    // Always return the buffer
    deallocate_out(0, fwBuffer);
    if ((status == SOCK_DISCONNECTED) || (status == SOCK_INTERRUPTED_TRY_AGAIN)) {
        return SEND_RETRY;
    } else if (status != SOCK_SUCCESS) {
        return SEND_ERROR;
    }
    return SEND_OK;
}
 
Drv::PollStatus UdpComponentImpl::poll_handler(const NATIVE_INT_TYPE portNum, Fw::Buffer& fwBuffer) {
    FW_ASSERT(0); // It is an error to call this handler on IP drivers
    return Drv::POLL_ERROR;
}
 
}  // end namespace Drv