Function start_socket

tools/http_load/http_load.c:991–1110

}

static void
start_socket(int url_num, int cnum, struct timeval *nowP)
{
  ClientData client_data;
  int        flags;
  int        sip_num;
  int        reusable = connections[cnum].reusable;

  /* Start filling in the connection slot. */
  connections[cnum].url_num        = url_num;
  connections[cnum].started_at     = *nowP;
  client_data.i                    = cnum;
  connections[cnum].did_connect    = 0;
  connections[cnum].did_response   = 0;
  connections[cnum].idle_timer     = tmr_create(nowP, idle_connection, client_data, idle_secs * 1000L, 0);
  connections[cnum].wakeup_timer   = (Timer *)0;
  connections[cnum].content_length = -1;
  connections[cnum].bytes          = 0;
  connections[cnum].checksum       = 0;
  connections[cnum].http_status    = -1;
  connections[cnum].reusable       = 0;
  connections[cnum].chunked        = 0;
  connections[cnum].unique_id      = 0;

  // set unique id
  if (unique_id == 1 && urls[url_num].unique_id_offset > 0) {
    char buffer[10];
    snprintf(buffer, 10, "%09u", ++unique_id_counter);
    //      fprintf(stderr, "%s %s\n", buffer, &urls[url_num].buf[unique_id_offset]);
    memcpy((void *)&urls[url_num].buf[urls[url_num].unique_id_offset], (void *)buffer, 9);
    connections[cnum].unique_id = unique_id_counter;
  }

  /* Make a socket. */
  if (!reusable) {
    struct epoll_event ev;

    connections[cnum].keep_alive = keep_alive;
    connections[cnum].conn_fd    = socket(urls[url_num].sock_family, urls[url_num].sock_type, urls[url_num].sock_protocol);
    if (connections[cnum].conn_fd < 0) {
      perror(urls[url_num].url_str);
      return;
    }
    connections[cnum].stats.connections++;

    /* Set the file descriptor to no-delay mode. */
    flags = fcntl(connections[cnum].conn_fd, F_GETFL, 0);
    if (flags == -1) {
      perror(urls[url_num].url_str);
      (void)close(connections[cnum].conn_fd);
      return;
    }
    if (fcntl(connections[cnum].conn_fd, F_SETFL, flags | O_NDELAY) < 0) {
      perror(urls[url_num].url_str);
      (void)close(connections[cnum].conn_fd);
      return;
    }