One Level Up Top Level

src/event/ngx_event_connect.c - nginx-1.7.10

Functions defined

Source code


  2. /*
  3. * Copyright (C) Igor Sysoev
  4. * Copyright (C) Nginx, Inc.
  5. */


  8. #include <ngx_config.h>
  9. #include <ngx_core.h>
  10. #include <ngx_event.h>
  11. #include <ngx_event_connect.h>


  14. ngx_int_t
  15. ‌ngx_event_connect_peer(ngx_peer_connection_t *pc)
  16. {
  17.     int                rc;
  18.     ngx_int_t          event;
  19.     ngx_err_t          err;
  20.     ngx_uint_t         level;
  21.     ngx_socket_t       s;
  22.     ngx_event_t       *rev, *wev;
  23.     ngx_connection_t  *c;

  25.     rc = pc->get(pc, pc->data);
  26.     if (rc != NGX_OK) {
  27.         return rc;
  28.     }

  30.     s = ngx_socket(pc->sockaddr->sa_family, SOCK_STREAM, 0);

  32.     ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, 0, "socket %d", s);

  34.     if (s == (ngx_socket_t) -1) {
  35.         ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
  36.                       ngx_socket_n " failed");
  37.         return NGX_ERROR;
  38.     }


  41.     c = ngx_get_connection(s, pc->log);

  43.     if (c == NULL) {
  44.         if (ngx_close_socket(s) == -1) {
  45.             ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
  46.                           ngx_close_socket_n "failed");
  47.         }

  49.         return NGX_ERROR;
  50.     }

  52.     if (pc->rcvbuf) {
  53.         if (setsockopt(s, SOL_SOCKET, SO_RCVBUF,
  54.                        (const void *) &pc->rcvbuf, sizeof(int)) == -1)
  55.         {
  56.             ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
  57.                           "setsockopt(SO_RCVBUF) failed");
  58.             goto failed;
  59.         }
  60.     }

  62.     if (ngx_nonblocking(s) == -1) {
  63.         ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
  64.                       ngx_nonblocking_n " failed");

  66.         goto failed;
  67.     }

  69.     if (pc->local) {
  70.         if (bind(s, pc->local->sockaddr, pc->local->socklen) == -1) {
  71.             ngx_log_error(NGX_LOG_CRIT, pc->log, ngx_socket_errno,
  72.                           "bind(%V) failed", &pc->local->name);

  74.             goto failed;
  75.         }
  76.     }

  78.     c->recv = ngx_recv;
  79.     c->send = ngx_send;
  80.     c->recv_chain = ngx_recv_chain;
  81.     c->send_chain = ngx_send_chain;

  83.     c->sendfile = 1;

  85.     c->log_error = pc->log_error;

  87.     if (pc->sockaddr->sa_family == AF_UNIX) {
  88.         c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED;
  89.         c->tcp_nodelay = NGX_TCP_NODELAY_DISABLED;

  91. #if (NGX_SOLARIS)
  92.         /* Solaris's sendfilev() supports AF_NCA, AF_INET, and AF_INET6 */
  93.         c->sendfile = 0;
  94. #endif
  95.     }

  97.     rev = c->read;
  98.     wev = c->write;

  100.     rev->log = pc->log;
  101.     wev->log = pc->log;

  103.     pc->connection = c;

  105.     c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);

  107.     if (ngx_add_conn) {
  108.         if (ngx_add_conn(c) == NGX_ERROR) {
  109.             goto failed;
  110.         }
  111.     }

  113.     ngx_log_debug3(NGX_LOG_DEBUG_EVENT, pc->log, 0,
  114.                    "connect to %V, fd:%d #%uA", pc->name, s, c->number);

  116.     rc = connect(s, pc->sockaddr, pc->socklen);

  118.     if (rc == -1) {
  119.         err = ngx_socket_errno;


  122.         if (err != NGX_EINPROGRESS
  123. #if (NGX_WIN32)
  124.             /* Winsock returns WSAEWOULDBLOCK (NGX_EAGAIN) */
  125.             && err != NGX_EAGAIN
  126. #endif
  127.             )
  128.         {
  129.             if (err == NGX_ECONNREFUSED
  130. #if (NGX_LINUX)
  131.                 /*
  132.                  * Linux returns EAGAIN instead of ECONNREFUSED
  133.                  * for unix sockets if listen queue is full
  134.                  */
  135.                 || err == NGX_EAGAIN
  136. #endif
  137.                 || err == NGX_ECONNRESET
  138.                 || err == NGX_ENETDOWN
  139.                 || err == NGX_ENETUNREACH
  140.                 || err == NGX_EHOSTDOWN
  141.                 || err == NGX_EHOSTUNREACH)
  142.             {
  143.                 level = NGX_LOG_ERR;

  145.             } else {
  146.                 level = NGX_LOG_CRIT;
  147.             }

  149.             ngx_log_error(level, c->log, err, "connect() to %V failed",
  150.                           pc->name);

  152.             ngx_close_connection(c);
  153.             pc->connection = NULL;

  155.             return NGX_DECLINED;
  156.         }
  157.     }

  159.     if (ngx_add_conn) {
  160.         if (rc == -1) {

  162.             /* NGX_EINPROGRESS */

  164.             return NGX_AGAIN;
  165.         }

  167.         ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");

  169.         wev->ready = 1;

  171.         return NGX_OK;
  172.     }

  174.     if (ngx_event_flags & NGX_USE_AIO_EVENT) {

  176.         ngx_log_debug1(NGX_LOG_DEBUG_EVENT, pc->log, ngx_socket_errno,
  177.                        "connect(): %d", rc);

  179.         /* aio, iocp */

  181.         if (ngx_blocking(s) == -1) {
  182.             ngx_log_error(NGX_LOG_ALERT, pc->log, ngx_socket_errno,
  183.                           ngx_blocking_n " failed");
  184.             goto failed;
  185.         }

  187.         /*
  188.          * FreeBSD's aio allows to post an operation on non-connected socket.
  189.          * NT does not support it.
  190.          *
  191.          * TODO: check in Win32, etc. As workaround we can use NGX_ONESHOT_EVENT
  192.          */

  194.         rev->ready = 1;
  195.         wev->ready = 1;

  197.         return NGX_OK;
  198.     }

  200.     if (ngx_event_flags & NGX_USE_CLEAR_EVENT) {

  202.         /* kqueue */

  204.         event = NGX_CLEAR_EVENT;

  206.     } else {

  208.         /* select, poll, /dev/poll */

  210.         event = NGX_LEVEL_EVENT;
  211.     }

  213.     if (ngx_add_event(rev, NGX_READ_EVENT, event) != NGX_OK) {
  214.         goto failed;
  215.     }

  217.     if (rc == -1) {

  219.         /* NGX_EINPROGRESS */

  221.         if (ngx_add_event(wev, NGX_WRITE_EVENT, event) != NGX_OK) {
  222.             goto failed;
  223.         }

  225.         return NGX_AGAIN;
  226.     }

  228.     ngx_log_debug0(NGX_LOG_DEBUG_EVENT, pc->log, 0, "connected");

  230.     wev->ready = 1;

  232.     return NGX_OK;

  234. failed:

  236.     ngx_close_connection(c);
  237.     pc->connection = NULL;

  239.     return NGX_ERROR;
  240. }


  243. ngx_int_t
  244. ‌ngx_event_get_peer(ngx_peer_connection_t *pc, void *data)
  245. {
  246.     return NGX_OK;
  247. }

One Level Up Top Level