Method createConnection

libminifi/src/io/ClientSocket.cpp:250–300

}

int8_t Socket::createConnection(const addrinfo* const destination_addresses) {
  for (const auto *current_addr = destination_addresses; current_addr; current_addr = current_addr->ai_next) {
    if (!valid_socket(socket_file_descriptor_ = socket(current_addr->ai_family, current_addr->ai_socktype, current_addr->ai_protocol))) {
      logger_->log_warn("socket: %s", get_last_socket_error_message());
      continue;
    }
    setSocketOptions(socket_file_descriptor_);

    if (listeners_ > 0) {
      // server socket
      const auto bind_result = bind(socket_file_descriptor_, current_addr->ai_addr, current_addr->ai_addrlen);
      if (bind_result == SOCKET_ERROR) {
        logger_->log_warn("bind: %s", get_last_socket_error_message());
        close();
        continue;
      }

      const auto listen_result = listen(socket_file_descriptor_, listeners_);
      if (listen_result == SOCKET_ERROR) {
        logger_->log_warn("listen: %s", get_last_socket_error_message());
        close();
        continue;
      }

      logger_->log_info("Listening on %s:%" PRIu16 " with backlog %" PRIu16, sockaddr_ntop(current_addr->ai_addr), port_, listeners_);
    } else {
      // client socket
#ifndef WIN32
      if (!local_network_interface_.getInterface().empty()) {
        const auto err = bind_to_local_network_interface(socket_file_descriptor_, local_network_interface_);
        if (err) logger_->log_info("Bind to interface %s failed %s", local_network_interface_.getInterface(), err.message());
        else logger_->log_info("Bind to interface %s", local_network_interface_.getInterface());
      }
#endif /* !WIN32 */

      const auto connect_result = connect(socket_file_descriptor_, current_addr->ai_addr, current_addr->ai_addrlen);
      if (connect_result == SOCKET_ERROR) {
        logger_->log_warn("Couldn't connect to %s:%" PRIu16 ": %s", sockaddr_ntop(current_addr->ai_addr), port_, get_last_socket_error_message());
        close();
        continue;
      }

      logger_->log_info("Connected to %s:%" PRIu16, sockaddr_ntop(current_addr->ai_addr), port_);
    }

    FD_SET(socket_file_descriptor_, &total_list_);
    socket_max_ = socket_file_descriptor_;
    return 0;
  }
  return -1;
}

int8_t Socket::createConnection(const addrinfo *, ip4addr &addr) {
  if (!valid_socket(socket_file_descriptor_ = socket(AF_INET, SOCK_STREAM, 0))) {