One Level Up Top Level

src/stream/ngx_stream_upstream.h - nginx source code

Data types defined

Macros defined

Source code


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


  8. #ifndef _NGX_STREAM_UPSTREAM_H_INCLUDED_
  9. ‌#define _NGX_STREAM_UPSTREAM_H_INCLUDED_


  12. #include <ngx_config.h>
  13. #include <ngx_core.h>
  14. #include <ngx_stream.h>
  15. #include <ngx_event_connect.h>


  18. ‌#define NGX_STREAM_UPSTREAM_CREATE        0x0001
  19. ‌#define NGX_STREAM_UPSTREAM_WEIGHT        0x0002
  20. ‌#define NGX_STREAM_UPSTREAM_MAX_FAILS     0x0004
  21. ‌#define NGX_STREAM_UPSTREAM_FAIL_TIMEOUT  0x0008
  22. ‌#define NGX_STREAM_UPSTREAM_DOWN          0x0010
  23. ‌#define NGX_STREAM_UPSTREAM_BACKUP        0x0020
  24. ‌#define NGX_STREAM_UPSTREAM_MODIFY        0x0040
  25. ‌#define NGX_STREAM_UPSTREAM_MAX_CONNS     0x0100


  28. ‌#define NGX_STREAM_UPSTREAM_NOTIFY_CONNECT     0x1


  31. ‌typedef struct {
  32.     ngx_array_t                        upstreams;
  33.                                            /* ngx_stream_upstream_srv_conf_t */
  34. ‌} ngx_stream_upstream_main_conf_t;


  37. ‌typedef struct ngx_stream_upstream_srv_conf_s  ngx_stream_upstream_srv_conf_t;


  40. ‌typedef ngx_int_t (*ngx_stream_upstream_init_pt)(ngx_conf_t *cf,
  41.     ngx_stream_upstream_srv_conf_t *us);
  42. ‌typedef ngx_int_t (*ngx_stream_upstream_init_peer_pt)(ngx_stream_session_t *s,
  43.     ngx_stream_upstream_srv_conf_t *us);


  46. ‌typedef struct {
  47.     ngx_stream_upstream_init_pt        init_upstream;
  48.     ngx_stream_upstream_init_peer_pt   init;
  49.     void                              *data;
  50. ‌} ngx_stream_upstream_peer_t;


  53. ‌typedef struct {
  54.     ngx_str_t                          name;
  55.     ngx_addr_t                        *addrs;
  56.     ngx_uint_t                         naddrs;
  57.     ngx_uint_t                         weight;
  58.     ngx_uint_t                         max_conns;
  59.     ngx_uint_t                         max_fails;
  60.     time_t                             fail_timeout;
  61.     ngx_msec_t                         slow_start;
  62.     ngx_uint_t                         down;

  64.     unsigned                           backup:1;

  66. #if (NGX_STREAM_UPSTREAM_ZONE)
  67.     ngx_str_t                          host;
  68.     ngx_str_t                          service;
  69. #endif
  70. ‌} ngx_stream_upstream_server_t;


  73. ‌struct ngx_stream_upstream_srv_conf_s {
  74.     ngx_stream_upstream_peer_t         peer;
  75.     void                             **srv_conf;

  77.     ngx_array_t                       *servers;
  78.                                               /* ngx_stream_upstream_server_t */

  80.     ngx_uint_t                         flags;
  81.     ngx_str_t                          host;
  82.     u_char                            *file_name;
  83.     ngx_uint_t                         line;
  84.     in_port_t                          port;
  85.     ngx_uint_t                         no_port;  /* unsigned no_port:1 */

  87. #if (NGX_STREAM_UPSTREAM_ZONE)
  88.     ngx_shm_zone_t                    *shm_zone;
  89.     ngx_resolver_t                    *resolver;
  90.     ngx_msec_t                         resolver_timeout;
  91. #endif
  92. };


  95. ‌typedef struct {
  96.     ngx_msec_t                         response_time;
  97.     ngx_msec_t                         connect_time;
  98.     ngx_msec_t                         first_byte_time;
  99.     off_t                              bytes_sent;
  100.     off_t                              bytes_received;

  102.     ngx_str_t                         *peer;
  103. ‌} ngx_stream_upstream_state_t;


  106. ‌typedef struct {
  107.     ngx_str_t                          host;
  108.     in_port_t                          port;
  109.     ngx_uint_t                         no_port; /* unsigned no_port:1 */

  111.     ngx_uint_t                         naddrs;
  112.     ngx_resolver_addr_t               *addrs;

  114.     struct sockaddr                   *sockaddr;
  115.     socklen_t                          socklen;
  116.     ngx_str_t                          name;

  118.     ngx_resolver_ctx_t                *ctx;
  119. ‌} ngx_stream_upstream_resolved_t;


  122. ‌typedef struct {
  123.     ngx_peer_connection_t              peer;

  125.     ngx_buf_t                          downstream_buf;
  126.     ngx_buf_t                          upstream_buf;

  128.     ngx_chain_t                       *free;
  129.     ngx_chain_t                       *upstream_out;
  130.     ngx_chain_t                       *upstream_busy;
  131.     ngx_chain_t                       *downstream_out;
  132.     ngx_chain_t                       *downstream_busy;

  134.     off_t                              received;
  135.     time_t                             start_sec;
  136.     ngx_uint_t                         requests;
  137.     ngx_uint_t                         responses;
  138.     ngx_msec_t                         start_time;

  140.     size_t                             upload_rate;
  141.     size_t                             download_rate;

  143.     ngx_str_t                          ssl_name;

  145.     ngx_stream_upstream_srv_conf_t    *upstream;
  146.     ngx_stream_upstream_resolved_t    *resolved;
  147.     ngx_stream_upstream_state_t       *state;
  148.     unsigned                           connected:1;
  149.     unsigned                           proxy_protocol:1;
  150.     unsigned                           half_closed:1;
  151. ‌} ngx_stream_upstream_t;


  154. ngx_stream_upstream_srv_conf_t *ngx_stream_upstream_add(ngx_conf_t *cf,
  155.     ngx_url_t *u, ngx_uint_t flags);


  158. ‌#define ngx_stream_conf_upstream_srv_conf(uscf, module)                       \
  159.     uscf->srv_conf[module.ctx_index]


  162. extern ngx_module_t  ngx_stream_upstream_module;


  165. #endif /* _NGX_STREAM_UPSTREAM_H_INCLUDED_ */

One Level Up Top Level