tcp_socket.h

// Copyright 2025 The Aerospace Corporation.
// This file is a part of SatCat5, licensed under CERN-OHL-W v2 or later.
// Connect a SatCat5 byte-stream to a Linux or Windows TCP socket.
 
#pragma once
 
#include <satcat5/io_buffer.h>
#include <satcat5/polling.h>
#include <satcat5/timeref.h>
 
namespace satcat5 {
    namespace tcp {
        class SocketPosix
            : public satcat5::io::BufferedIO
            , public satcat5::poll::Timer
        {
        public:
            explicit SocketPosix(unsigned txbytes=8192, unsigned rxbytes=8192);
            virtual ~SocketPosix();
 
            void close();
 
            bool bind(const satcat5::ip::Port& port);
 
            bool connect(
                const char* hostname,
                const satcat5::ip::Port& port);
            bool connect(
                const satcat5::ip::Addr& addr,
                const satcat5::ip::Port& port);
 
            bool ready();
 
            inline void set_rate_kbps(unsigned kbps)
                { m_rate_kbps = kbps; }
 
        private:
            // Internal event handlers:
            void data_rcvd(satcat5::io::Readable* src) override;
            void timer_event() override;
            int open_nonblock_socket();
            unsigned rate_limit(satcat5::util::TimeVal& tv);
 
            // Internal state:
            u32 m_flags;                
            util::TimeVal m_last_rx;    
            util::TimeVal m_last_tx;    
            int m_sock_listen;          
            int m_sock_data;            
            unsigned m_rate_kbps;      
        };
    }
}