TcpCommsSS.h

/*
Copyright (c) 2017-2024,
Battelle Memorial Institute; Lawrence Livermore National Security, LLC; Alliance for Sustainable
Energy, LLC.  See the top-level NOTICE for additional details. All rights reserved.
SPDX-License-Identifier: BSD-3-Clause
*/
#pragma once
 
#include "../NetworkCommsInterface.hpp"
 
#include <atomic>
#include <set>
#include <string>
#include <vector>
 
namespace gmlc::networking {
class TcpConnection;
}
 
namespace helics {
namespace tcp {
 
    class TcpCommsSS final: public NetworkCommsInterface {
      public:
        TcpCommsSS() noexcept;
        ~TcpCommsSS();
 
        void addConnection(std::string_view newConn);
        void addConnections(const std::vector<std::string>& newConnections);
        virtual void setFlag(std::string_view flag, bool val) override;
 
        virtual void loadNetworkInfo(const NetworkBrokerData& netInfo) override;
 
      private:
        bool outgoingConnectionsAllowed{true};
        bool reuse_address{false};
        std::string encryption_config;
        std::vector<std::string> connections;  
        virtual int getDefaultBrokerPort() const override;
        virtual void queue_rx_function() override;  
        virtual void queue_tx_function() override;  
 
        int processIncomingMessage(ActionMessage&& cmd);
 
        size_t dataReceive(gmlc::networking::TcpConnection* connection,
                           const char* data,
                           size_t bytes_received);
        //  bool errorHandle()
    };
 
}  // namespace tcp
}  // namespace helics