Connections.hpp

Go to the documentation of this file.

#pragma once
 
#include "ConnectionBase.hpp"
#include "srs/connections/ConnectionTypeDef.hpp"
#include "srs/utils/CommonAlias.hpp"
#include <array>
#include <gsl/gsl-lite.hpp>
#include <span>
#include <spdlog/spdlog.h>
#include <string_view>
 
namespace srs::workflow
{
    class Handler;
}
 
namespace srs::connection
{
    class FecCommandSocket;
    class Starter : public CommandBase
    {
      public:
        explicit Starter(std::string_view name);
        Starter();
        void close();
        static auto get_send_suffix() -> const auto& { return send_suffix_; }
        static auto get_suffix() -> std::span<const CommunicateEntryType>
        {
            return std::span{ send_suffix_.cbegin(), send_suffix_.cend() };
        }
 
      private:
        static constexpr std::array<CommunicateEntryType, 3> send_suffix_ = { 0, 15, 1 };
    };
 
    class Stopper : public CommandBase
    {
      public:
        Stopper(const Stopper&) = delete;

        Stopper(Stopper&&) = delete;

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

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

        explicit Stopper(std::string_view name);
 
        Stopper();

        ~Stopper() = default;
 
        static auto get_send_suffix() -> const auto& { return send_suffix_; }
        static auto get_suffix() -> std::span<const CommunicateEntryType>
        {
            return std::span{ send_suffix_.cbegin(), send_suffix_.cend() };
        }
 
      private:
        static constexpr std::array<CommunicateEntryType, 3> send_suffix_ = { 0, 15, 0 };
    };
} // namespace srs::connection