MpiCore.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 "../../core/CommonCore.hpp"
#include "../CommsBroker.hpp"
 
#include <memory>
#include <string>
 
namespace helics {
namespace mpi {
    class MpiComms;
    class MpiCore final: public CommsBroker<MpiComms, CommonCore> {
      public:
        MpiCore() noexcept;
        explicit MpiCore(std::string_view core_name);
        ~MpiCore();
 
      protected:
        virtual std::shared_ptr<helicsCLI11App> generateCLI() override;
 
      public:
        virtual std::string generateLocalAddressString() const override;
 
      private:
        mutable std::mutex dataMutex;  
        std::string brokerAddress;  
        int brokerRank{0};
        int brokerTag{0};
        virtual bool brokerConnect() override;
    };
 
}  // namespace mpi
}  // namespace helics