Method initialize

libminifi/src/io/ClientSocket.cpp:373–411

}

int Socket::initialize() {
  addrinfo hints{};
  memset(&hints, 0, sizeof hints);  // make sure the struct is empty
  hints.ai_family = AF_UNSPEC;
  hints.ai_socktype = SOCK_STREAM;
  hints.ai_flags = AI_CANONNAME;
  if (listeners_ > 0 && !is_loopback_only_)
    hints.ai_flags = AI_PASSIVE;
  hints.ai_protocol = 0; /* any protocol */

  const char* const gai_node = [this]() -> const char* {
    if (is_loopback_only_) return "localhost";
    if (!is_loopback_only_ && listeners_ > 0) return nullptr;  // all non-localhost server sockets listen on wildcard address
    if (!requested_hostname_.empty()) return requested_hostname_.c_str();
    return nullptr;
  }();
  const auto gai_service = std::to_string(port_);
  addrinfo* getaddrinfo_result = nullptr;
  const int errcode = getaddrinfo(gai_node, gai_service.c_str(), &hints, &getaddrinfo_result);
  const std::unique_ptr<addrinfo, util::addrinfo_deleter> addr_info{ getaddrinfo_result };
  getaddrinfo_result = nullptr;
  if (errcode != 0) {
    logger_->log_error("getaddrinfo: %s", get_last_getaddrinfo_err_str(errcode));
    return -1;
  }
  socket_file_descriptor_ = INVALID_SOCKET;

  // AI_CANONNAME always sets ai_canonname of the first addrinfo structure
  canonical_hostname_ = !IsNullOrEmpty(addr_info->ai_canonname) ? addr_info->ai_canonname : requested_hostname_;

  const auto conn_result = port_ > 0 ? createConnection(addr_info.get()) : -1;
  if (conn_result == 0 && nonBlocking_) {
    // Put the socket in non-blocking mode:
    const auto err = set_non_blocking(socket_file_descriptor_);
    if (err) logger_->log_info("Couldn't make socket non-blocking: %s", err.message());
    else logger_->log_debug("Successfully applied O_NONBLOCK to fd");
  }
  return conn_result;
}

int16_t Socket::select_descriptor(const uint16_t msec) {
  if (listeners_ == 0) {