listener.h

 
#pragma once
 
#include <memory>
#include <string>
 
#include <ucp/api/ucp.h>
 
#include <ucxx/component.h>
#include <ucxx/worker.h>
 
namespace ucxx {
 
class Listener : public Component {
 private:
  ucp_listener_h _handle{nullptr};  
  std::string _ip{};                
  uint16_t _port{0};                
 
  Listener(std::shared_ptr<Worker> worker,
           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();
 
  [[nodiscard]] friend std::shared_ptr<Listener> createListener(
    std::shared_ptr<Worker> worker,
    uint16_t port,
    ucp_listener_conn_callback_t callback,
    void* callbackArgs);
 
  [[nodiscard]] std::shared_ptr<Endpoint> createEndpointFromConnRequest(
    ucp_conn_request_h connRequest, bool endpointErrorHandling = true);
 
  [[nodiscard]] ucp_listener_h getHandle();
 
  [[nodiscard]] uint16_t getPort();
 
  [[nodiscard]] std::string getIp();
};
 
}  // namespace ucxx