BrokerServer.hpp

/*
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 "../core/Broker.hpp"
 
#include <atomic>
#include <memory>
#include <string>
#include <thread>
#include <tuple>
#include <vector>
 
namespace Json {
class Value;
}
 
namespace helics {
class ActionMessage;
class helicsCLI11App;
 
using portData = std::vector<std::tuple<int, bool, std::shared_ptr<Broker>>>;
 
namespace apps {
    class TypedBrokerServer;
    class BrokerServer {
      protected:
      public:
        BrokerServer() noexcept;
        BrokerServer(int argc, char* argv[]);
        explicit BrokerServer(std::vector<std::string> args);
        explicit BrokerServer(std::string_view configFile);
        ~BrokerServer();
        void startServers();
        static bool hasActiveBrokers();
        void forceTerminate();
        void closeServers();
 
      private:
        std::unique_ptr<helicsCLI11App> generateArgProcessing();
 
      private:
        bool zmq_server{false};  
        bool zmq_ss_server{false};  
        bool tcp_server{false};  
        bool udp_server{false};  
        // bool mpi_server{false}; //!< activate the MPI broker server
        bool http_server{false};  
        bool websocket_server{false};  
        std::atomic<bool> exitall{false};
        std::vector<std::shared_ptr<TypedBrokerServer>> servers;
        std::string configFile_;
        std::string server_name_;
        std::unique_ptr<Json::Value> config_;
        std::string mHttpArgs;
        std::string mWebSocketArgs;
        std::string mZmqArgs;
        std::string mTcpArgs;
        std::string mUdpArgs;
        std::string mMpiArgs;
 
      public:
    };
}  // namespace apps
}  // namespace helics