Connections.hpp

Go to the documentation of this file.

#pragma once
 
#include "ConnectionBase.hpp"
 
namespace srs::workflow
{
    class Handler;
}
 
namespace srs::connection
{
    class Starter : public Base<>
    {
      public:
        explicit Starter(const Info& info)
            : Base(info, "Starter")
        {
        }
 
        void close();
        void acq_on()
        {
            spdlog::info("Requesting data from the FEC with the IP: {}", get_remote_endpoint().address().to_string());
            const auto data = std::vector<CommunicateEntryType>{ 0, 15, 1 };
            communicate(data, common::NULL_ADDRESS);
        }
        void on_fail()
        {
            set_connection_bad();
            const auto& endpoint = get_remote_endpoint();
            spdlog::critical("Cannot establish a connection to the FEC with the IP: \"{}:{}\"!",
                             endpoint.address().to_string(),
                             endpoint.port());
        }
    };
 
    class Stopper : public Base<>
    {
      public:
        Stopper(const Stopper&) = delete;

        Stopper(Stopper&&) = delete;

        Stopper& operator=(const Stopper&) = delete;

        Stopper& operator=(Stopper&&) = delete;

        explicit Stopper(const Info& info)
            : Base(info, "Stopper")
        {
        }

        ~Stopper() = default;

        void on_fail()
        {
            spdlog::debug("on_fail of stopper is called");
            set_connection_bad();
        }

        void acq_off();
        // void close() {}
    };
 
    class DataReader : public Base<common::LARGE_READ_MSG_BUFFER_SIZE>
    {
      public:
        DataReader(const Info& info, workflow::Handler* processor)
            : workflow_handler_{ processor }
            , Base(info, "DataReader")
        {
            set_timeout_seconds(1);
            set_continuous();
        }
 
        DataReader(const DataReader&) = delete;
        DataReader(DataReader&&) = delete;
        DataReader& operator=(const DataReader&) = delete;
        DataReader& operator=(DataReader&&) = delete;
        ~DataReader() = default;
 
        void start(bool is_non_stop = true)
        {
            set_socket(new_shared_socket(get_local_port_number()));
            const auto& is_on_exit = get_app().get_status().is_on_exit;
            if (not is_on_exit.load())
            {
                get_app().set_status_is_reading(true);
                spdlog::info("UDP data reading has been started");
                listen(is_non_stop);
            }
            else
            {
                spdlog::debug("Program is alreay on exit!");
            }
        }
        void close();
 
        void read_data_handle(std::span<BufferElementType> read_data);
 
      private:
        gsl::not_null<workflow::Handler*> workflow_handler_;
    };
 
} // namespace srs::connection