listener.h

 
#pragma once
 
#include <memory>
#include <string>
 
#include <ucp/api/ucp.h>
 
#include <ucxx/component.h>
#include <ucxx/endpoint_builder.h>
#include <ucxx/listener_builder.h>
#include <ucxx/worker.h>
 
namespace ucxx {
 
class Listener;
class Listener : public Component {
 private:
  ucp_listener_h _handle{nullptr};  
  std::string _ip{};                
  uint16_t _port{0};                
 
  Listener(std::shared_ptr<Worker> worker,
           std::string host,
           uint16_t port,
           ucp_listener_conn_callback_t callback,
           void* callbackArgs);
 
 public:
  Listener()                           = delete;
  Listener(const Listener&)            = delete;
  Listener& operator=(Listener const&) = delete;
  Listener(Listener&& o)               = delete;
  Listener& operator=(Listener&& o)    = delete;
 
  ~Listener();
 
  // Allow internal construction without exposing factory functions.
  friend class detail::ConstructorFactory;
 
  [[nodiscard]] EndpointBuilder endpointBuilder(ucp_conn_request_h connRequest);
 
  [[nodiscard]] ucp_listener_h getHandle();
 
  [[nodiscard]] uint16_t getPort();
 
  [[nodiscard]] std::string getIp();
};
 
}  // namespace ucxx