message_buffer.h

// Copyright 2024-2025 The Aerospace Corporation.
// This file is a part of SatCat5, licensed under CERN-OHL-W v2 or later.
// PacketBuffer to MessageBuffer adapter.
 
#pragma once
 
extern "C" {
    #include <FreeRTOS.h>
    #include <message_buffer.h>
    #include <semphr.h>
};
 
#include <satcat5/eth_switch.h>
#include <satcat5/io_readable.h>
#include <satcat5/io_writeable.h>
#include <satcat5/pkt_buffer.h>
 
namespace satcat5 {
    namespace freertos {
        class MessageCopy final : public satcat5::io::EventListener {
        public:
            MessageCopy(
                satcat5::io::Readable* src,
                MessageBufferHandle_t* msg_buff_handle,
                SemaphoreHandle_t* msg_buff_semphr
                );
            ~MessageCopy() SATCAT5_OPTIONAL_DTOR;
        protected:
            // Override io::EventListener handlers.
            void data_rcvd(satcat5::io::Readable* src) override;
            void data_unlink(satcat5::io::Readable* src) override;
 
            // Pointers to source, message buffer, and semaphore.
            satcat5::io::Readable* m_src;
            MessageBufferHandle_t* const m_handle;
            SemaphoreHandle_t* const m_mutex;
        };
 
        class MessageBuffer : public satcat5::io::WriteableRedirect {
        public:
            MessageBuffer(
                u8* txbuff, unsigned txbytes,
                MessageBufferHandle_t* msg_buff_handle,
                SemaphoreHandle_t* msg_buff_semphr);
 
        private:
            // Working buffer accumulates each packet.
            satcat5::io::PacketBuffer m_tx;
 
            // Copy complete packets to the FreeRTOS buffer.
            satcat5::freertos::MessageCopy m_copy;
        };
 
        class MessageBufferPort : public satcat5::eth::SwitchPort {
        public:
            MessageBufferPort(
                satcat5::eth::SwitchCore* sw,
                MessageBufferHandle_t* msg_buff_handle,
                SemaphoreHandle_t* msg_buff_semphr);
 
        protected:
            // Copy complete packets to the FreeRTOS buffer.
            satcat5::freertos::MessageCopy m_copy;
        };
    }  // namespace freertos
}  // namespace satcat5