annotate src/http/ngx_http_upstream_round_robin.c @ 674:4dcaf40cc702 NGINX_1_3_0

nginx 1.3.0 *) Feature: the "debug_connection" directive now supports IPv6 addresses and the "unix:" parameter. *) Feature: the "set_real_ip_from" directive and the "proxy" parameter of the "geo" directive now support IPv6 addresses. *) Feature: the "real_ip_recursive", "geoip_proxy", and "geoip_proxy_recursive" directives. *) Feature: the "proxy_recursive" parameter of the "geo" directive. *) Bugfix: a segmentation fault might occur in a worker process if the "resolver" directive was used. *) Bugfix: a segmentation fault might occur in a worker process if the "fastcgi_pass", "scgi_pass", or "uwsgi_pass" directives were used and backend returned incorrect response. *) Bugfix: a segmentation fault might occur in a worker process if the "rewrite" directive was used and new request arguments in a replacement used variables. *) Bugfix: nginx might hog CPU if the open file resource limit was reached. *) Bugfix: nginx might loop infinitely over backends if the "proxy_next_upstream" directive with the "http_404" parameter was used and there were backup servers specified in an upstream block. *) Bugfix: adding the "down" parameter of the "server" directive might cause unneeded client redistribution among backend servers if the "ip_hash" directive was used. *) Bugfix: socket leak. Thanks to Yichun Zhang. *) Bugfix: in the ngx_http_fastcgi_module.
author Igor Sysoev <http://sysoev.ru>
date Tue, 15 May 2012 00:00:00 +0400
parents ad45b044f1e5
children bfa81a0490a2
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
1
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
2 /*
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
3 * Copyright (C) Igor Sysoev
660
d0f7a625f27c nginx 1.1.14
Igor Sysoev <http://sysoev.ru>
parents: 644
diff changeset
4 * Copyright (C) Nginx, Inc.
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
5 */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
6
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
7
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
8 #include <ngx_config.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
9 #include <ngx_core.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
10 #include <ngx_http.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
11
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
12
372
6639b93e81b2 nginx 0.6.30
Igor Sysoev <http://sysoev.ru>
parents: 364
diff changeset
13 static ngx_int_t ngx_http_upstream_cmp_servers(const void *one,
6639b93e81b2 nginx 0.6.30
Igor Sysoev <http://sysoev.ru>
parents: 364
diff changeset
14 const void *two);
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
15 static ngx_http_upstream_rr_peer_t *ngx_http_upstream_get_peer(
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
16 ngx_http_upstream_rr_peer_data_t *rrp);
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
17
632
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
18 #if (NGX_HTTP_SSL)
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
19
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
20 static ngx_int_t ngx_http_upstream_empty_set_session(ngx_peer_connection_t *pc,
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
21 void *data);
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
22 static void ngx_http_upstream_empty_save_session(ngx_peer_connection_t *pc,
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
23 void *data);
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
24
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
25 #endif
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
26
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
27
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
28 ngx_int_t
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
29 ngx_http_upstream_init_round_robin(ngx_conf_t *cf,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
30 ngx_http_upstream_srv_conf_t *us)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
31 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
32 ngx_url_t u;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
33 ngx_uint_t i, j, n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
34 ngx_http_upstream_server_t *server;
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
35 ngx_http_upstream_rr_peers_t *peers, *backup;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
36
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
37 us->peer.init = ngx_http_upstream_init_round_robin_peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
38
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
39 if (us->servers) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
40 server = us->servers->elts;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
41
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
42 n = 0;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
43
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
44 for (i = 0; i < us->servers->nelts; i++) {
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
45 if (server[i].backup) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
46 continue;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
47 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
48
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
49 n += server[i].naddrs;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
50 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
51
670
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
52 if (n == 0) {
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
53 ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
54 "no servers in upstream \"%V\" in %s:%ui",
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
55 &us->host, us->file_name, us->line);
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
56 return NGX_ERROR;
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
57 }
ad45b044f1e5 nginx 1.1.19
Igor Sysoev <http://sysoev.ru>
parents: 660
diff changeset
58
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
59 peers = ngx_pcalloc(cf->pool, sizeof(ngx_http_upstream_rr_peers_t)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
60 + sizeof(ngx_http_upstream_rr_peer_t) * (n - 1));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
61 if (peers == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
62 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
63 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
64
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
65 peers->single = (n == 1);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
66 peers->number = n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
67 peers->name = &us->host;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
68
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
69 n = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
70
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
71 for (i = 0; i < us->servers->nelts; i++) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
72 for (j = 0; j < server[i].naddrs; j++) {
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
73 if (server[i].backup) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
74 continue;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
75 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
76
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
77 peers->peer[n].sockaddr = server[i].addrs[j].sockaddr;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
78 peers->peer[n].socklen = server[i].addrs[j].socklen;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
79 peers->peer[n].name = server[i].addrs[j].name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
80 peers->peer[n].max_fails = server[i].max_fails;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
81 peers->peer[n].fail_timeout = server[i].fail_timeout;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
82 peers->peer[n].down = server[i].down;
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
83 peers->peer[n].weight = server[i].weight;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
84 peers->peer[n].effective_weight = server[i].weight;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
85 peers->peer[n].current_weight = 0;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
86 n++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
87 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
88 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
89
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
90 us->peer.data = peers;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
91
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
92 ngx_sort(&peers->peer[0], (size_t) n,
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
93 sizeof(ngx_http_upstream_rr_peer_t),
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
94 ngx_http_upstream_cmp_servers);
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
95
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
96 /* backup servers */
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
97
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
98 n = 0;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
99
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
100 for (i = 0; i < us->servers->nelts; i++) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
101 if (!server[i].backup) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
102 continue;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
103 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
104
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
105 n += server[i].naddrs;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
106 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
107
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
108 if (n == 0) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
109 return NGX_OK;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
110 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
111
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
112 backup = ngx_pcalloc(cf->pool, sizeof(ngx_http_upstream_rr_peers_t)
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
113 + sizeof(ngx_http_upstream_rr_peer_t) * (n - 1));
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
114 if (backup == NULL) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
115 return NGX_ERROR;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
116 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
117
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
118 peers->single = 0;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
119 backup->single = 0;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
120 backup->number = n;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
121 backup->name = &us->host;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
122
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
123 n = 0;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
124
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
125 for (i = 0; i < us->servers->nelts; i++) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
126 for (j = 0; j < server[i].naddrs; j++) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
127 if (!server[i].backup) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
128 continue;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
129 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
130
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
131 backup->peer[n].sockaddr = server[i].addrs[j].sockaddr;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
132 backup->peer[n].socklen = server[i].addrs[j].socklen;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
133 backup->peer[n].name = server[i].addrs[j].name;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
134 backup->peer[n].weight = server[i].weight;
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
135 backup->peer[n].effective_weight = server[i].weight;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
136 backup->peer[n].current_weight = 0;
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
137 backup->peer[n].max_fails = server[i].max_fails;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
138 backup->peer[n].fail_timeout = server[i].fail_timeout;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
139 backup->peer[n].down = server[i].down;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
140 n++;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
141 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
142 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
143
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
144 peers->next = backup;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
145
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
146 ngx_sort(&backup->peer[0], (size_t) n,
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
147 sizeof(ngx_http_upstream_rr_peer_t),
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
148 ngx_http_upstream_cmp_servers);
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
149
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
150 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
151 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
152
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
153
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
154 /* an upstream implicitly defined by proxy_pass, etc. */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
155
266
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
156 if (us->port == 0 && us->default_port == 0) {
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
157 ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
158 "no port in upstream \"%V\" in %s:%ui",
336
1c519aff5c0c nginx 0.6.12
Igor Sysoev <http://sysoev.ru>
parents: 334
diff changeset
159 &us->host, us->file_name, us->line);
266
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
160 return NGX_ERROR;
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
161 }
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
162
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
163 ngx_memzero(&u, sizeof(ngx_url_t));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
164
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
165 u.host = us->host;
266
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
166 u.port = (in_port_t) (us->port ? us->port : us->default_port);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
167
340
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
168 if (ngx_inet_resolve_host(cf->pool, &u) != NGX_OK) {
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
169 if (u.err) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
170 ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
262
e0b1d0a6c629 nginx 0.5.1
Igor Sysoev <http://sysoev.ru>
parents: 260
diff changeset
171 "%s in upstream \"%V\" in %s:%ui",
336
1c519aff5c0c nginx 0.6.12
Igor Sysoev <http://sysoev.ru>
parents: 334
diff changeset
172 u.err, &us->host, us->file_name, us->line);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
173 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
174
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
175 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
176 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
177
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
178 n = u.naddrs;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
179
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
180 peers = ngx_pcalloc(cf->pool, sizeof(ngx_http_upstream_rr_peers_t)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
181 + sizeof(ngx_http_upstream_rr_peer_t) * (n - 1));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
182 if (peers == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
183 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
184 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
185
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
186 peers->single = (n == 1);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
187 peers->number = n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
188 peers->name = &us->host;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
189
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
190 for (i = 0; i < u.naddrs; i++) {
340
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
191 peers->peer[i].sockaddr = u.addrs[i].sockaddr;
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
192 peers->peer[i].socklen = u.addrs[i].socklen;
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
193 peers->peer[i].name = u.addrs[i].name;
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
194 peers->peer[i].weight = 1;
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
195 peers->peer[i].effective_weight = 1;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
196 peers->peer[i].current_weight = 0;
340
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
197 peers->peer[i].max_fails = 1;
10cc350ed8a1 nginx 0.6.14
Igor Sysoev <http://sysoev.ru>
parents: 336
diff changeset
198 peers->peer[i].fail_timeout = 10;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
199 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
200
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
201 us->peer.data = peers;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
202
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
203 /* implicitly defined upstream has no backup servers */
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
204
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
205 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
206 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
207
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
208
372
6639b93e81b2 nginx 0.6.30
Igor Sysoev <http://sysoev.ru>
parents: 364
diff changeset
209 static ngx_int_t
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
210 ngx_http_upstream_cmp_servers(const void *one, const void *two)
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
211 {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
212 ngx_http_upstream_rr_peer_t *first, *second;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
213
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
214 first = (ngx_http_upstream_rr_peer_t *) one;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
215 second = (ngx_http_upstream_rr_peer_t *) two;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
216
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
217 return (first->weight < second->weight);
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
218 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
219
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
220
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
221 ngx_int_t
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
222 ngx_http_upstream_init_round_robin_peer(ngx_http_request_t *r,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
223 ngx_http_upstream_srv_conf_t *us)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
224 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
225 ngx_uint_t n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
226 ngx_http_upstream_rr_peer_data_t *rrp;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
227
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
228 rrp = r->upstream->peer.data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
229
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
230 if (rrp == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
231 rrp = ngx_palloc(r->pool, sizeof(ngx_http_upstream_rr_peer_data_t));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
232 if (rrp == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
233 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
234 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
235
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
236 r->upstream->peer.data = rrp;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
237 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
238
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
239 rrp->peers = us->peer.data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
240 rrp->current = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
241
634
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
242 n = rrp->peers->number;
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
243
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
244 if (rrp->peers->next && rrp->peers->next->number > n) {
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
245 n = rrp->peers->next->number;
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
246 }
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
247
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
248 if (n <= 8 * sizeof(uintptr_t)) {
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
249 rrp->tried = &rrp->data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
250 rrp->data = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
251
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
252 } else {
634
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
253 n = (n + (8 * sizeof(uintptr_t) - 1)) / (8 * sizeof(uintptr_t));
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
254
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
255 rrp->tried = ngx_pcalloc(r->pool, n * sizeof(uintptr_t));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
256 if (rrp->tried == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
257 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
258 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
259 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
261 r->upstream->peer.get = ngx_http_upstream_get_round_robin_peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
262 r->upstream->peer.free = ngx_http_upstream_free_round_robin_peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
263 r->upstream->peer.tries = rrp->peers->number;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
264 #if (NGX_HTTP_SSL)
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
265 r->upstream->peer.set_session =
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
266 ngx_http_upstream_set_round_robin_peer_session;
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
267 r->upstream->peer.save_session =
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
268 ngx_http_upstream_save_round_robin_peer_session;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
269 #endif
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
270
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
271 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
272 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
273
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
274
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
275 ngx_int_t
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
276 ngx_http_upstream_create_round_robin_peer(ngx_http_request_t *r,
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
277 ngx_http_upstream_resolved_t *ur)
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
278 {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
279 u_char *p;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
280 size_t len;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
281 ngx_uint_t i, n;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
282 struct sockaddr_in *sin;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
283 ngx_http_upstream_rr_peers_t *peers;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
284 ngx_http_upstream_rr_peer_data_t *rrp;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
285
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
286 rrp = r->upstream->peer.data;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
287
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
288 if (rrp == NULL) {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
289 rrp = ngx_palloc(r->pool, sizeof(ngx_http_upstream_rr_peer_data_t));
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
290 if (rrp == NULL) {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
291 return NGX_ERROR;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
292 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
293
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
294 r->upstream->peer.data = rrp;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
295 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
296
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
297 peers = ngx_pcalloc(r->pool, sizeof(ngx_http_upstream_rr_peers_t)
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
298 + sizeof(ngx_http_upstream_rr_peer_t) * (ur->naddrs - 1));
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
299 if (peers == NULL) {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
300 return NGX_ERROR;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
301 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
302
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
303 peers->single = (ur->naddrs == 1);
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
304 peers->number = ur->naddrs;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
305 peers->name = &ur->host;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
306
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
307 if (ur->sockaddr) {
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
308 peers->peer[0].sockaddr = ur->sockaddr;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
309 peers->peer[0].socklen = ur->socklen;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
310 peers->peer[0].name = ur->host;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
311 peers->peer[0].weight = 1;
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
312 peers->peer[0].effective_weight = 1;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
313 peers->peer[0].current_weight = 0;
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
314 peers->peer[0].max_fails = 1;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
315 peers->peer[0].fail_timeout = 10;
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
316
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
317 } else {
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
318
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
319 for (i = 0; i < ur->naddrs; i++) {
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
320
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
321 len = NGX_INET_ADDRSTRLEN + sizeof(":65536") - 1;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
322
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
323 p = ngx_pnalloc(r->pool, len);
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
324 if (p == NULL) {
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
325 return NGX_ERROR;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
326 }
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
327
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
328 len = ngx_inet_ntop(AF_INET, &ur->addrs[i], p, NGX_INET_ADDRSTRLEN);
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
329 len = ngx_sprintf(&p[len], ":%d", ur->port) - p;
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
330
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
331 sin = ngx_pcalloc(r->pool, sizeof(struct sockaddr_in));
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
332 if (sin == NULL) {
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
333 return NGX_ERROR;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
334 }
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
335
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
336 sin->sin_family = AF_INET;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
337 sin->sin_port = htons(ur->port);
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
338 sin->sin_addr.s_addr = ur->addrs[i];
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
339
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
340 peers->peer[i].sockaddr = (struct sockaddr *) sin;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
341 peers->peer[i].socklen = sizeof(struct sockaddr_in);
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
342 peers->peer[i].name.len = len;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
343 peers->peer[i].name.data = p;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
344 peers->peer[i].weight = 1;
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
345 peers->peer[i].effective_weight = 1;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
346 peers->peer[i].current_weight = 0;
434
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
347 peers->peer[i].max_fails = 1;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
348 peers->peer[i].fail_timeout = 10;
49a0eb7ce20c nginx 0.7.29
Igor Sysoev <http://sysoev.ru>
parents: 400
diff changeset
349 }
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
350 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
351
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
352 rrp->peers = peers;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
353 rrp->current = 0;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
354
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
355 if (rrp->peers->number <= 8 * sizeof(uintptr_t)) {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
356 rrp->tried = &rrp->data;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
357 rrp->data = 0;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
358
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
359 } else {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
360 n = (rrp->peers->number + (8 * sizeof(uintptr_t) - 1))
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
361 / (8 * sizeof(uintptr_t));
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
362
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
363 rrp->tried = ngx_pcalloc(r->pool, n * sizeof(uintptr_t));
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
364 if (rrp->tried == NULL) {
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
365 return NGX_ERROR;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
366 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
367 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
368
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
369 r->upstream->peer.get = ngx_http_upstream_get_round_robin_peer;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
370 r->upstream->peer.free = ngx_http_upstream_free_round_robin_peer;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
371 r->upstream->peer.tries = rrp->peers->number;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
372 #if (NGX_HTTP_SSL)
632
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
373 r->upstream->peer.set_session = ngx_http_upstream_empty_set_session;
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
374 r->upstream->peer.save_session = ngx_http_upstream_empty_save_session;
348
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
375 #endif
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
376
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
377 return NGX_OK;
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
378 }
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
379
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
380
e10168d6e371 nginx 0.6.18
Igor Sysoev <http://sysoev.ru>
parents: 340
diff changeset
381 ngx_int_t
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
382 ngx_http_upstream_get_round_robin_peer(ngx_peer_connection_t *pc, void *data)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
383 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
384 ngx_http_upstream_rr_peer_data_t *rrp = data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
385
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
386 ngx_int_t rc;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
387 ngx_uint_t i, n;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
388 ngx_connection_t *c;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
389 ngx_http_upstream_rr_peer_t *peer;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
390 ngx_http_upstream_rr_peers_t *peers;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
391
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
392 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, pc->log, 0,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
393 "get rr peer, try: %ui", pc->tries);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
394
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
395 /* ngx_lock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
396
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
397 if (rrp->peers->last_cached) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
398
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
399 /* cached connection */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
400
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
401 c = rrp->peers->cached[rrp->peers->last_cached];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
402 rrp->peers->last_cached--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
403
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
404 /* ngx_unlock_mutex(ppr->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
405
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
406 #if (NGX_THREADS)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
407 c->read->lock = c->read->own_lock;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
408 c->write->lock = c->write->own_lock;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
409 #endif
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
410
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
411 pc->connection = c;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
412 pc->cached = 1;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
413
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
414 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
415 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
416
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
417 pc->cached = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
418 pc->connection = NULL;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
419
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
420 if (rrp->peers->single) {
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
421 peer = &rrp->peers->peer[0];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
422
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
423 } else {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
424
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
425 /* there are several peers */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
426
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
427 peer = ngx_http_upstream_get_peer(rrp);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
428
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
429 if (peer == NULL) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
430 goto failed;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
431 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
432
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
433 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
434 "get rr peer, current: %ui %i",
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
435 rrp->current, peer->current_weight);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
436 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
437
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
438 pc->sockaddr = peer->sockaddr;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
439 pc->socklen = peer->socklen;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
440 pc->name = &peer->name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
441
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
442 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
443
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
444 if (pc->tries == 1 && rrp->peers->next) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
445 pc->tries += rrp->peers->next->number;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
446 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
447
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
448 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
449
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
450 failed:
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
451
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
452 peers = rrp->peers;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
453
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
454 if (peers->next) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
455
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
456 /* ngx_unlock_mutex(peers->mutex); */
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
457
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
458 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, pc->log, 0, "backup servers");
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
459
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
460 rrp->peers = peers->next;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
461 pc->tries = rrp->peers->number;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
462
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
463 n = rrp->peers->number / (8 * sizeof(uintptr_t)) + 1;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
464 for (i = 0; i < n; i++) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
465 rrp->tried[i] = 0;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
466 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
467
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
468 rc = ngx_http_upstream_get_round_robin_peer(pc, rrp);
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
469
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
470 if (rc != NGX_BUSY) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
471 return rc;
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
472 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
473
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
474 /* ngx_lock_mutex(peers->mutex); */
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
475 }
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
476
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
477 /* all peers failed, mark them as live for quick recovery */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
478
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
479 for (i = 0; i < peers->number; i++) {
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
480 peers->peer[i].fails = 0;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
481 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
482
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
483 /* ngx_unlock_mutex(peers->mutex); */
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
484
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
485 pc->name = peers->name;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
486
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
487 return NGX_BUSY;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
488 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
489
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
490
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
491 static ngx_http_upstream_rr_peer_t *
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
492 ngx_http_upstream_get_peer(ngx_http_upstream_rr_peer_data_t *rrp)
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
493 {
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
494 time_t now;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
495 uintptr_t m;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
496 ngx_int_t total;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
497 ngx_uint_t i, n;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
498 ngx_http_upstream_rr_peer_t *peer, *best;
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
499
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
500 now = ngx_time();
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
501
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
502 best = NULL;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
503 total = 0;
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
504
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
505 for (i = 0; i < rrp->peers->number; i++) {
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
506
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
507 n = i / (8 * sizeof(uintptr_t));
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
508 m = (uintptr_t) 1 << i % (8 * sizeof(uintptr_t));
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
509
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
510 if (rrp->tried[n] & m) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
511 continue;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
512 }
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
513
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
514 peer = &rrp->peers->peer[i];
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
515
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
516 if (peer->down) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
517 continue;
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
518 }
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
519
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
520 if (peer->max_fails
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
521 && peer->fails >= peer->max_fails
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
522 && now - peer->checked <= peer->fail_timeout)
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
523 {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
524 continue;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
525 }
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
526
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
527 peer->current_weight += peer->effective_weight;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
528 total += peer->effective_weight;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
529
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
530 if (peer->effective_weight < peer->weight) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
531 peer->effective_weight++;
634
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
532 }
23ef0645ea57 nginx 1.1.1
Igor Sysoev <http://sysoev.ru>
parents: 632
diff changeset
533
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
534 if (best == NULL || peer->current_weight > best->current_weight) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
535 best = peer;
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
536 }
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
537 }
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
538
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
539 if (best == NULL) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
540 return NULL;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
541 }
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
542
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
543 i = best - &rrp->peers->peer[0];
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
544
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
545 rrp->current = i;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
546
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
547 n = i / (8 * sizeof(uintptr_t));
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
548 m = (uintptr_t) 1 << i % (8 * sizeof(uintptr_t));
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
549
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
550 rrp->tried[n] |= m;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
551
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
552 best->current_weight -= total;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
553 best->checked = now;
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
554
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
555 return best;
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
556 }
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
557
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
558
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
559 void
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
560 ngx_http_upstream_free_round_robin_peer(ngx_peer_connection_t *pc, void *data,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
561 ngx_uint_t state)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
562 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
563 ngx_http_upstream_rr_peer_data_t *rrp = data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
564
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
565 time_t now;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
566 ngx_http_upstream_rr_peer_t *peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
567
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
568 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
569 "free rr peer %ui %ui", pc->tries, state);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
570
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
571 if (state == 0 && pc->tries == 0) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
572 return;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
573 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
574
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
575 /* TODO: NGX_PEER_KEEPALIVE */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
576
326
9fc4ab6673f9 nginx 0.6.7
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
577 if (rrp->peers->single) {
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
578 pc->tries = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
579 return;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
580 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
581
644
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
582 peer = &rrp->peers->peer[rrp->current];
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
583
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
584 if (state & NGX_PEER_FAILED) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
585 now = ngx_time();
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
586
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
587 /* ngx_lock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
588
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
589 peer->fails++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
590 peer->accessed = now;
644
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
591 peer->checked = now;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
592
400
6ebbca3d5ed7 nginx 0.7.12
Igor Sysoev <http://sysoev.ru>
parents: 382
diff changeset
593 if (peer->max_fails) {
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
594 peer->effective_weight -= peer->weight / peer->max_fails;
400
6ebbca3d5ed7 nginx 0.7.12
Igor Sysoev <http://sysoev.ru>
parents: 382
diff changeset
595 }
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
596
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
597 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
598 "free rr peer failed: %ui %i",
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
599 rrp->current, peer->effective_weight);
324
f7cd062ee035 nginx 0.6.6
Igor Sysoev <http://sysoev.ru>
parents: 318
diff changeset
600
674
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
601 if (peer->effective_weight < 0) {
4dcaf40cc702 nginx 1.3.0
Igor Sysoev <http://sysoev.ru>
parents: 670
diff changeset
602 peer->effective_weight = 0;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
603 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
604
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
605 /* ngx_unlock_mutex(rrp->peers->mutex); */
644
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
606
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
607 } else {
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
608
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
609 /* mark peer live if check passed */
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
610
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
611 if (peer->accessed < peer->checked) {
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
612 peer->fails = 0;
6f21ae02fb01 nginx 1.1.6
Igor Sysoev <http://sysoev.ru>
parents: 634
diff changeset
613 }
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
614 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
615
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
616 if (pc->tries) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
617 pc->tries--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
618 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
619
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
620 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
621 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
622
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
623
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
624 #if (NGX_HTTP_SSL)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
625
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
626 ngx_int_t
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
627 ngx_http_upstream_set_round_robin_peer_session(ngx_peer_connection_t *pc,
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
628 void *data)
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
629 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
630 ngx_http_upstream_rr_peer_data_t *rrp = data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
631
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
632 ngx_int_t rc;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
633 ngx_ssl_session_t *ssl_session;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
634 ngx_http_upstream_rr_peer_t *peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
635
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
636 peer = &rrp->peers->peer[rrp->current];
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
637
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
638 /* TODO: threads only mutex */
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
639 /* ngx_lock_mutex(rrp->peers->mutex); */
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
640
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
641 ssl_session = peer->ssl_session;
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
642
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
643 rc = ngx_ssl_set_session(pc->connection, ssl_session);
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
644
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
645 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
332
3a91bfeffaba nginx 0.6.10
Igor Sysoev <http://sysoev.ru>
parents: 330
diff changeset
646 "set session: %p:%d",
3a91bfeffaba nginx 0.6.10
Igor Sysoev <http://sysoev.ru>
parents: 330
diff changeset
647 ssl_session, ssl_session ? ssl_session->references : 0);
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
648
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
649 /* ngx_unlock_mutex(rrp->peers->mutex); */
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
650
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
651 return rc;
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
652 }
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
653
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
654
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
655 void
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
656 ngx_http_upstream_save_round_robin_peer_session(ngx_peer_connection_t *pc,
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
657 void *data)
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
658 {
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
659 ngx_http_upstream_rr_peer_data_t *rrp = data;
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
660
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
661 ngx_ssl_session_t *old_ssl_session, *ssl_session;
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
662 ngx_http_upstream_rr_peer_t *peer;
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
663
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
664 ssl_session = ngx_ssl_get_session(pc->connection);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
665
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
666 if (ssl_session == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
667 return;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
668 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
669
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
670 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
332
3a91bfeffaba nginx 0.6.10
Igor Sysoev <http://sysoev.ru>
parents: 330
diff changeset
671 "save session: %p:%d", ssl_session, ssl_session->references);
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
672
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
673 peer = &rrp->peers->peer[rrp->current];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
674
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
675 /* TODO: threads only mutex */
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
676 /* ngx_lock_mutex(rrp->peers->mutex); */
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
677
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
678 old_ssl_session = peer->ssl_session;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
679 peer->ssl_session = ssl_session;
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
680
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
681 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
682
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
683 if (old_ssl_session) {
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
684
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
685 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
332
3a91bfeffaba nginx 0.6.10
Igor Sysoev <http://sysoev.ru>
parents: 330
diff changeset
686 "old session: %p:%d",
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
687 old_ssl_session, old_ssl_session->references);
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
688
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
689 /* TODO: may block */
318
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
690
fc223117327f nginx 0.6.3
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
691 ngx_ssl_free_session(old_ssl_session);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
692 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
693 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
694
632
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
695
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
696 static ngx_int_t
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
697 ngx_http_upstream_empty_set_session(ngx_peer_connection_t *pc, void *data)
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
698 {
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
699 return NGX_OK;
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
700 }
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
701
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
702
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
703 static void
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
704 ngx_http_upstream_empty_save_session(ngx_peer_connection_t *pc, void *data)
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
705 {
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
706 return;
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
707 }
5b73504dd4ba nginx 1.1.0
Igor Sysoev <http://sysoev.ru>
parents: 434
diff changeset
708
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
709 #endif