IpcComms.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 "../CommsInterface.hpp"
 
#include <atomic>
#include <string>
 
namespace helics {
namespace ipc {
    class IpcComms final: public CommsInterface {
      public:
        IpcComms();
        ~IpcComms();
 
        virtual void loadNetworkInfo(const NetworkBrokerData& netInfo) override;
 
      private:
        std::atomic<int> ipcbackchannel{
            0};  
        virtual void queue_rx_function() override;  
        virtual void queue_tx_function() override;  
        virtual void closeReceiver() override;  
 
      public:
        int getPort() const { return -1; }
 
        std::string getAddress() const;
    };
 
#define IPC_BACKCHANNEL_TRY_RESET 2
#define IPC_BACKCHANNEL_DISCONNECT 4
 
}  // namespace ipc
}  // namespace helics