One Level Up Top Level

src/core/ngx_connection.h - nginx-1.7.10

Data types defined

Macros defined

Source code


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


  8. #ifndef _NGX_CONNECTION_H_INCLUDED_
  9. ‌#define _NGX_CONNECTION_H_INCLUDED_


  12. #include <ngx_config.h>
  13. #include <ngx_core.h>


  16. ‌typedef struct ngx_listening_s  ngx_listening_t;

  18. ‌struct ngx_listening_s {
  19.     ngx_socket_t        fd;

  21.     struct sockaddr    *sockaddr;
  22.     socklen_t           socklen;    /* size of sockaddr */
  23.     size_t              addr_text_max_len;
  24.     ngx_str_t           addr_text;

  26.     int                 type;

  28.     int                 backlog;
  29.     int                 rcvbuf;
  30.     int                 sndbuf;
  31. #if (NGX_HAVE_KEEPALIVE_TUNABLE)
  32.     int                 keepidle;
  33.     int                 keepintvl;
  34.     int                 keepcnt;
  35. #endif

  37.     /* handler of accepted connection */
  38.     ngx_connection_handler_pt   handler;

  40.     void               *servers;  /* array of ngx_http_in_addr_t, for example */

  42.     ngx_log_t           log;
  43.     ngx_log_t          *logp;

  45.     size_t              pool_size;
  46.     /* should be here because of the AcceptEx() preread */
  47.     size_t              post_accept_buffer_size;
  48.     /* should be here because of the deferred accept */
  49.     ngx_msec_t          post_accept_timeout;

  51.     ngx_listening_t    *previous;
  52.     ngx_connection_t   *connection;

  54.     unsigned            open:1;
  55.     unsigned            remain:1;
  56.     unsigned            ignore:1;

  58.     unsigned            bound:1;       /* already bound */
  59.     unsigned            inherited:1;   /* inherited from previous process */
  60.     unsigned            nonblocking_accept:1;
  61.     unsigned            listen:1;
  62.     unsigned            nonblocking:1;
  63.     unsigned            shared:1;    /* shared between threads or processes */
  64.     unsigned            addr_ntop:1;

  66. #if (NGX_HAVE_INET6 && defined IPV6_V6ONLY)
  67.     unsigned            ipv6only:1;
  68. #endif
  69.     unsigned            keepalive:2;

  71. #if (NGX_HAVE_DEFERRED_ACCEPT)
  72.     unsigned            deferred_accept:1;
  73.     unsigned            delete_deferred:1;
  74.     unsigned            add_deferred:1;
  75. #ifdef SO_ACCEPTFILTER
  76.     char               *accept_filter;
  77. #endif
  78. #endif
  79. #if (NGX_HAVE_SETFIB)
  80.     int                 setfib;
  81. #endif

  83. #if (NGX_HAVE_TCP_FASTOPEN)
  84.     int                 fastopen;
  85. #endif

  87. };


  90. typedef enum {
  91.      NGX_ERROR_ALERT = 0,
  92.      NGX_ERROR_ERR,
  93.      NGX_ERROR_INFO,
  94.      NGX_ERROR_IGNORE_ECONNRESET,
  95.      NGX_ERROR_IGNORE_EINVAL
  96. ‌} ngx_connection_log_error_e;


  99. typedef enum {
  100.      NGX_TCP_NODELAY_UNSET = 0,
  101.      NGX_TCP_NODELAY_SET,
  102.      NGX_TCP_NODELAY_DISABLED
  103. ‌} ngx_connection_tcp_nodelay_e;


  106. typedef enum {
  107.      NGX_TCP_NOPUSH_UNSET = 0,
  108.      NGX_TCP_NOPUSH_SET,
  109.      NGX_TCP_NOPUSH_DISABLED
  110. ‌} ngx_connection_tcp_nopush_e;


  113. ‌#define NGX_LOWLEVEL_BUFFERED  0x0f
  114. ‌#define NGX_SSL_BUFFERED       0x01
  115. ‌#define NGX_SPDY_BUFFERED      0x02


  118. ‌struct ngx_connection_s {
  119.     void               *data;
  120.     ngx_event_t        *read;
  121.     ngx_event_t        *write;

  123.     ngx_socket_t        fd;

  125.     ngx_recv_pt         recv;
  126.     ngx_send_pt         send;
  127.     ngx_recv_chain_pt   recv_chain;
  128.     ngx_send_chain_pt   send_chain;

  130.     ngx_listening_t    *listening;

  132.     off_t               sent;

  134.     ngx_log_t          *log;

  136.     ngx_pool_t         *pool;

  138.     struct sockaddr    *sockaddr;
  139.     socklen_t           socklen;
  140.     ngx_str_t           addr_text;

  142.     ngx_str_t           proxy_protocol_addr;

  144. #if (NGX_SSL)
  145.     ngx_ssl_connection_t  *ssl;
  146. #endif

  148.     struct sockaddr    *local_sockaddr;
  149.     socklen_t           local_socklen;

  151.     ngx_buf_t          *buffer;

  153.     ngx_queue_t         queue;

  155.     ngx_atomic_uint_t   number;

  157.     ngx_uint_t          requests;

  159.     unsigned            buffered:8;

  161.     unsigned            log_error:3;     /* ngx_connection_log_error_e */

  163.     unsigned            unexpected_eof:1;
  164.     unsigned            timedout:1;
  165.     unsigned            error:1;
  166.     unsigned            destroyed:1;

  168.     unsigned            idle:1;
  169.     unsigned            reusable:1;
  170.     unsigned            close:1;

  172.     unsigned            sendfile:1;
  173.     unsigned            sndlowat:1;
  174.     unsigned            tcp_nodelay:2;   /* ngx_connection_tcp_nodelay_e */
  175.     unsigned            tcp_nopush:2;    /* ngx_connection_tcp_nopush_e */

  177.     unsigned            need_last_buf:1;

  179. #if (NGX_HAVE_IOCP)
  180.     unsigned            accept_context_updated:1;
  181. #endif

  183. #if (NGX_HAVE_AIO_SENDFILE)
  184.     unsigned            aio_sendfile:1;
  185.     unsigned            busy_count:2;
  186.     ngx_buf_t          *busy_sendfile;
  187. #endif

  189. #if (NGX_THREADS)
  190.     ngx_atomic_t        lock;
  191. #endif
  192. };


  195. ngx_listening_t *ngx_create_listening(ngx_conf_t *cf, void *sockaddr,
  196.     socklen_t socklen);
  197. ngx_int_t ngx_set_inherited_sockets(ngx_cycle_t *cycle);
  198. ngx_int_t ngx_open_listening_sockets(ngx_cycle_t *cycle);
  199. void ngx_configure_listening_sockets(ngx_cycle_t *cycle);
  200. void ngx_close_listening_sockets(ngx_cycle_t *cycle);
  201. void ngx_close_connection(ngx_connection_t *c);
  202. ngx_int_t ngx_connection_local_sockaddr(ngx_connection_t *c, ngx_str_t *s,
  203.     ngx_uint_t port);
  204. ngx_int_t ngx_connection_error(ngx_connection_t *c, ngx_err_t err, char *text);

  206. ngx_connection_t *ngx_get_connection(ngx_socket_t s, ngx_log_t *log);
  207. void ngx_free_connection(ngx_connection_t *c);

  209. void ngx_reusable_connection(ngx_connection_t *c, ngx_uint_t reusable);

  211. #endif /* _NGX_CONNECTION_H_INCLUDED_ */

One Level Up Top Level