mirror of
https://github.com/nasa/fprime.git
synced 2025-12-15 14:05:24 -06:00
84 lines
3.0 KiB
C++
84 lines
3.0 KiB
C++
// ======================================================================
|
|
// \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"
|
|
#include "Fw/Types/Assert.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() {}
|
|
|
|
// ----------------------------------------------------------------------
|
|
// 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) ? RecvStatus::RECV_OK : RecvStatus::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 SendStatus::SEND_RETRY;
|
|
} else if (status != SOCK_SUCCESS) {
|
|
return SendStatus::SEND_ERROR;
|
|
}
|
|
return SendStatus::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 PollStatus::POLL_ERROR;
|
|
}
|
|
|
|
} // end namespace Drv
|