UdpComms.h

/*
Copyright (c) 2017-2025,
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 "helics/helics-config.h"
 
#include <future>
#include <set>
 
namespace helics::udp {
class UdpComms final: public NetworkCommsInterface {
  public:
    UdpComms();
    ~UdpComms();
 
    virtual void loadNetworkInfo(const NetworkBrokerData& netInfo) override;
 
  private:
    virtual int getDefaultBrokerPort() const override;
    virtual void queue_rx_function() override;  
    virtual void queue_tx_function() override;  
    virtual void closeReceiver() override;  
 
    // promise and future for communicating port number from tx_thread to rx_thread
    std::promise<int> promisePort;
    std::future<int> futurePort;
 
  public:
};
 
}  // namespace helics::udp