nginx/src/http/ngx_http_upstream_round_robin.h

   1
   2 /*
   3  * Copyright (C) Igor Sysoev
   4  */
   5
   6
   7 #ifndef _NGX_HTTP_UPSTREAM_ROUND_ROBIN_H_INCLUDED_
   8 #define _NGX_HTTP_UPSTREAM_ROUND_ROBIN_H_INCLUDED_
   9
  10
  11 #include <ngx_config.h>
  12 #include <ngx_core.h>
  13 #include <ngx_http.h>
  14
  15
  16 typedef struct {
  17     struct sockaddr                *sockaddr;
  18     socklen_t                       socklen;
  19     ngx_str_t                       name;
  20
  21     ngx_int_t                       current_weight;
  22     ngx_int_t                       weight;
  23
  24     ngx_uint_t                      fails;
  25     time_t                          accessed;
  26
  27     ngx_uint_t                      max_fails;
  28     time_t                          fail_timeout;
  29
  30     ngx_uint_t                      down;          /* unsigned  down:1; */
  31
  32 #if (NGX_HTTP_SSL)
  33     ngx_ssl_session_t              *ssl_session;   /* local to a process */
  34 #endif
  35 } ngx_http_upstream_rr_peer_t;
  36
  37
  38 typedef struct ngx_http_upstream_rr_peers_s  ngx_http_upstream_rr_peers_t;
  39
  40 struct ngx_http_upstream_rr_peers_s {
  41     ngx_uint_t                      single;        /* unsigned  single:1; */
  42     ngx_uint_t                      number;
  43     ngx_uint_t                      last_cached;
  44
  45  /* ngx_mutex_t                    *mutex; */
  46     ngx_connection_t              **cached;
  47
  48     ngx_str_t                      *name;
  49
  50     ngx_http_upstream_rr_peers_t   *next;
  51
  52     ngx_http_upstream_rr_peer_t     peer[1];
  53 };
  54
  55
  56 typedef struct {
  57     ngx_http_upstream_rr_peers_t   *peers;
  58     ngx_uint_t                      current;
  59     uintptr_t                      *tried;
  60     uintptr_t                       data;
  61 } ngx_http_upstream_rr_peer_data_t;
  62
  63
  64 ngx_int_t ngx_http_upstream_init_round_robin(ngx_conf_t *cf,
  65     ngx_http_upstream_srv_conf_t *us);
  66 ngx_int_t ngx_http_upstream_init_round_robin_peer(ngx_http_request_t *r,
  67     ngx_http_upstream_srv_conf_t *us);
  68 ngx_int_t ngx_http_upstream_create_round_robin_peer(ngx_http_request_t *r,
  69     ngx_http_upstream_resolved_t *ur);
  70 ngx_int_t ngx_http_upstream_get_round_robin_peer(ngx_peer_connection_t *pc,
  71     void *data);
  72 void ngx_http_upstream_free_round_robin_peer(ngx_peer_connection_t *pc,
  73     void *data, ngx_uint_t state);
  74
  75 #if (NGX_HTTP_SSL)
  76 ngx_int_t
  77     ngx_http_upstream_set_round_robin_peer_session(ngx_peer_connection_t *pc,
  78     void *data);
  79 void ngx_http_upstream_save_round_robin_peer_session(ngx_peer_connection_t *pc,
  80     void *data);
  81 #endif
  82
  83
  84
  85 #endif /* _NGX_HTTP_UPSTREAM_ROUND_ROBIN_H_INCLUDED_ */