One Level Up Top Level

src/stream/ngx_stream_upstream.h - nginx

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
  29. ‌#define NGX_STREAM_UPSTREAM_NOTIFY_FIRST_BYTE  0x2


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


  38. ‌typedef struct ngx_stream_upstream_srv_conf_s  ngx_stream_upstream_srv_conf_t;


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


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


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

  65.     unsigned                           backup:1;

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


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

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

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

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


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

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


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

  112.     ngx_uint_t                         naddrs;
  113.     ngx_resolver_addr_t               *addrs;

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

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


  123. ‌typedef struct {
  124.     ngx_peer_connection_t              peer;

  126.     ngx_buf_t                          downstream_buf;
  127.     ngx_buf_t                          upstream_buf;

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

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

  141.     size_t                             upload_rate;
  142.     size_t                             download_rate;

  144.     ngx_str_t                          ssl_name;

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


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


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


  163. extern ngx_module_t  ngx_stream_upstream_module;


  166. #endif /* _NGX_STREAM_UPSTREAM_H_INCLUDED_ */

One Level Up Top Level