ConfigClient.hpp

Go to the documentation of this file.

 
#ifndef IOMANAGER_INCLUDE_IOMANAGER_NETWORK_CONFIGCLIENT_HPP_
#define IOMANAGER_INCLUDE_IOMANAGER_NETWORK_CONFIGCLIENT_HPP_
 
#include "iomanager/SchemaUtils.hpp"
#include "iomanager/network/ConfigClientStructs.hpp"
 
#include "nlohmann/json.hpp"
 
#include <boost/asio/connect.hpp>
#include <boost/asio/ip/basic_resolver.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/beast/core.hpp>
#include <boost/beast/version.hpp>
 
#include <map>
#include <mutex>
#include <set>
#include <string>
#include <thread>
#include <vector>
 
namespace beast = boost::beast; // from <boost/beast.hpp>
namespace net = boost::asio;    // from <boost/asio.hpp>
 
namespace dunedaq::iomanager {
class ConfigClient
{
public:
  ConfigClient(const std::string& server,
               const std::string& port,
               const std::string& session_name,
               std::chrono::milliseconds publish_interval);

  ~ConfigClient();

  ConnectionResponse resolve_connection(const ConnectionRequest& query, std::string session = "");
 
  void publish(ConnectionRegistration const& connection);
 
  void publish(std::vector<ConnectionRegistration> const& connections);
 
  void retract(const ConnectionId& connectionId);

  void retract(const std::vector<ConnectionId>& connectionIds);

  void retract();
 
  bool is_connected() { return m_connected.load(); }
 
private:
  void publish();
  std::string m_session;
  net::io_context m_io_context;
  net::ip::basic_resolver<net::ip::tcp>::results_type m_addr;
 
  std::mutex m_mutex;
  std::set<ConnectionRegistration> m_registered_connections;
  std::thread m_thread;
  bool m_active;
  std::atomic<bool> m_connected{ false };
};
} // namespace dunedaq::iomanager
 
#endif // IOMANAGER_INCLUDE_IOMANAGER_NETWORK_CONFIGCLIENT_HPP_