annotate src/http/ngx_http_upstream_round_robin.c @ 328:26ff8d6b618d NGINX_0_5_34

nginx 0.5.34 *) Change: now the full request line instead of URI only is written to error_log. *) Feature: Cygwin compatibility. Thanks to Vladimir Kutakov. *) Feature: the "merge_slashes" directive. *) Feature: the "gzip_vary" directive. *) Feature: the "server_tokens" directive. *) Feature: the "access_log" directive may be used inside the "limit_except" block. *) Bugfix: if the $server_protocol was used in FastCGI parameters and a request line length was near to the "client_header_buffer_size" directive value, then nginx issued an alert "fastcgi: the request record is too big". *) Bugfix: if a plain text HTTP/0.9 version request was made to HTTPS server, then nginx returned usual response. *) Bugfix: URL double escaping in a redirect of the "msie_refresh" directive; bug appeared in 0.5.28. *) Bugfix: a segmentation fault might occur in worker process if subrequests were used. *) Bugfix: the big responses may be transferred truncated if SSL and gzip were used. *) Bugfix: compatibility with mget. *) Bugfix: nginx did not unescape URI in the "include" SSI command. *) Bugfix: the segmentation fault was occurred on start or while reconfiguration if variable was used in the "charset" or "source_charset" directives. *) Bugfix: nginx returned the 400 response on requests like "GET http://www.domain.com HTTP/1.0". Thanks to James Oakley. *) Bugfix: a segmentation fault occurred in worker process if $date_local and $date_gmt were used outside the ngx_http_ssi_filter_module. *) Bugfix: a segmentation fault might occur in worker process if debug log was enabled. Thanks to Andrei Nigmatulin. *) Bugfix: ngx_http_memcached_module did not set $upstream_response_time. Thanks to Maxim Dounin. *) Bugfix: a worker process may got caught in an endless loop, if the memcached was used.
author Igor Sysoev <http://sysoev.ru>
date Thu, 13 Dec 2007 00:00:00 +0300
parents 7cf404023f50
children
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
4 */
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 #include <ngx_config.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
8 #include <ngx_core.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
9 #include <ngx_http.h>
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
10
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 ngx_int_t
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
13 ngx_http_upstream_init_round_robin(ngx_conf_t *cf,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
14 ngx_http_upstream_srv_conf_t *us)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
15 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
16 ngx_url_t u;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
17 ngx_uint_t i, j, n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
18 ngx_http_upstream_server_t *server;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
19 ngx_http_upstream_rr_peers_t *peers;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
20
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
21 us->peer.init = ngx_http_upstream_init_round_robin_peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
22
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
23 if (us->servers) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
24 n = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
25 server = us->servers->elts;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
26
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
27 for (i = 0; i < us->servers->nelts; i++) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
28 n += server[i].naddrs;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
29 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
30
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
31 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
32 + sizeof(ngx_http_upstream_rr_peer_t) * (n - 1));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
33 if (peers == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
34 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
35 }
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 peers->number = n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
38 peers->name = &us->host;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
39
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
40 n = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
41
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
42 for (i = 0; i < us->servers->nelts; i++) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
43 for (j = 0; j < server[i].naddrs; j++) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
44 peers->peer[n].sockaddr = server[i].addrs[j].sockaddr;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
45 peers->peer[n].socklen = server[i].addrs[j].socklen;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
46 peers->peer[n].name = server[i].addrs[j].name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
47 peers->peer[n].weight = server[i].weight;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
48 peers->peer[n].current_weight = server[i].weight;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
49 peers->peer[n].max_fails = server[i].max_fails;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
50 peers->peer[n].fail_timeout = server[i].fail_timeout;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
51 peers->peer[n].down = server[i].down;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
52 n++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
53 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
54 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
55
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
56 us->peer.data = peers;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
57
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
58 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
59 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
60
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
61
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
62 /* an upstream implicitly defined by proxy_pass, etc. */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
63
266
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
64 if (us->port == 0 && us->default_port == 0) {
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
65 ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
66 "no port in upstream \"%V\" in %s:%ui",
324
7cf404023f50 nginx 0.5.32
Igor Sysoev <http://sysoev.ru>
parents: 320
diff changeset
67 &us->host, us->file_name, us->line);
266
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
68 return NGX_ERROR;
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
69 }
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
70
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
71 ngx_memzero(&u, sizeof(ngx_url_t));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
72
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
73 u.host = us->host;
266
251bcd11a5b8 nginx 0.5.3
Igor Sysoev <http://sysoev.ru>
parents: 262
diff changeset
74 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
75
328
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
76 if (ngx_inet_resolve_host(cf->pool, &u) != NGX_OK) {
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
77 if (u.err) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
78 ngx_log_error(NGX_LOG_EMERG, cf->log, 0,
262
e0b1d0a6c629 nginx 0.5.1
Igor Sysoev <http://sysoev.ru>
parents: 260
diff changeset
79 "%s in upstream \"%V\" in %s:%ui",
324
7cf404023f50 nginx 0.5.32
Igor Sysoev <http://sysoev.ru>
parents: 320
diff changeset
80 u.err, &us->host, us->file_name, us->line);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
81 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
82
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
83 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
84 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
85
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
86 n = u.naddrs;
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 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
89 + sizeof(ngx_http_upstream_rr_peer_t) * (n - 1));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
90 if (peers == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
91 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
92 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
93
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
94 peers->number = n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
95 peers->name = &us->host;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
96
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
97 for (i = 0; i < u.naddrs; i++) {
328
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
98 peers->peer[i].sockaddr = u.addrs[i].sockaddr;
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
99 peers->peer[i].socklen = u.addrs[i].socklen;
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
100 peers->peer[i].name = u.addrs[i].name;
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
101 peers->peer[i].weight = 1;
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
102 peers->peer[i].current_weight = 1;
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
103 peers->peer[i].max_fails = 1;
26ff8d6b618d nginx 0.5.34
Igor Sysoev <http://sysoev.ru>
parents: 324
diff changeset
104 peers->peer[i].fail_timeout = 10;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
105 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
106
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
107 us->peer.data = peers;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
108
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
109 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
110 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
111
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
112
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
113 ngx_int_t
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
114 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
115 ngx_http_upstream_srv_conf_t *us)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
116 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
117 ngx_uint_t n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
118 ngx_http_upstream_rr_peer_data_t *rrp;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
119
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
120 rrp = r->upstream->peer.data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
121
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
122 if (rrp == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
123 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
124 if (rrp == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
125 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
126 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
127
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
128 r->upstream->peer.data = rrp;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
129 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
130
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
131 rrp->peers = us->peer.data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
132 rrp->current = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
133
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
134 if (rrp->peers->number <= 8 * sizeof(uintptr_t)) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
135 rrp->tried = &rrp->data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
136 rrp->data = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
137
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
138 } else {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
139 n = (rrp->peers->number + (8 * sizeof(uintptr_t) - 1))
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
140 / (8 * sizeof(uintptr_t));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
141
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
142 rrp->tried = ngx_pcalloc(r->pool, n * sizeof(uintptr_t));
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
143 if (rrp->tried == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
144 return NGX_ERROR;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
145 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
146 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
147
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
148 r->upstream->peer.get = ngx_http_upstream_get_round_robin_peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
149 r->upstream->peer.free = ngx_http_upstream_free_round_robin_peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
150 r->upstream->peer.tries = rrp->peers->number;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
151 #if (NGX_HTTP_SSL)
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
152 r->upstream->peer.set_session =
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
153 ngx_http_upstream_set_round_robin_peer_session;
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
154 r->upstream->peer.save_session =
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
155 ngx_http_upstream_save_round_robin_peer_session;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
156 #endif
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
157
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
158 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
159 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
160
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
161
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
162 ngx_int_t
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
163 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
164 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
165 ngx_http_upstream_rr_peer_data_t *rrp = data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
166
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
167 time_t now;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
168 uintptr_t m;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
169 ngx_uint_t i, n;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
170 ngx_connection_t *c;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
171 ngx_http_upstream_rr_peer_t *peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
172
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
173 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, pc->log, 0,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
174 "get rr peer, try: %ui", pc->tries);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
175
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
176 now = ngx_time();
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 /* ngx_lock_mutex(rrp->peers->mutex); */
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 if (rrp->peers->last_cached) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
181
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
182 /* cached connection */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
183
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
184 c = rrp->peers->cached[rrp->peers->last_cached];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
185 rrp->peers->last_cached--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
186
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
187 /* ngx_unlock_mutex(ppr->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
188
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
189 #if (NGX_THREADS)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
190 c->read->lock = c->read->own_lock;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
191 c->write->lock = c->write->own_lock;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
192 #endif
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
193
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
194 pc->connection = c;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
195 pc->cached = 1;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
196
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
197 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
198 }
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 pc->cached = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
201 pc->connection = NULL;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
202
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
203 if (rrp->peers->number == 1) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
204 peer = &rrp->peers->peer[0];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
205
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
206 } else {
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 /* there are several peers */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
209
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
210 if (pc->tries == rrp->peers->number) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
211
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
212 /* it's a first try - get a current peer */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
213
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
214 for ( ;; ) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
215 rrp->current = rrp->peers->current;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
216
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
217 n = rrp->current / (8 * sizeof(uintptr_t));
302
9b7db0df50f0 nginx 0.5.21
Igor Sysoev <http://sysoev.ru>
parents: 266
diff changeset
218 m = (uintptr_t) 1 << rrp->current % (8 * sizeof(uintptr_t));
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
219
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
220 if (!(rrp->tried[n] & m)) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
221 peer = &rrp->peers->peer[rrp->current];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
222
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
223 if (!peer->down) {
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 if (peer->max_fails == 0
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
226 || peer->fails < peer->max_fails)
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 break;
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
231 if (now - peer->accessed > peer->fail_timeout) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
232 peer->fails = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
233 break;
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 } else {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
237 rrp->tried[n] |= m;
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
240 pc->tries--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
241 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
242
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
243 rrp->peers->current++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
244
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
245 if (rrp->peers->current >= rrp->peers->number) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
246 rrp->peers->current = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
247 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
248
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
249 if (pc->tries) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
250 continue;
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
253 goto failed;
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
256 peer->current_weight--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
257
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
258 if (peer->current_weight == 0) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
259 peer->current_weight = peer->weight;
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 rrp->peers->current++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
262
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
263 if (rrp->peers->current >= rrp->peers->number) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
264 rrp->peers->current = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
265 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
266 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
267
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
268 } else {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
269 for ( ;; ) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
270 n = rrp->current / (8 * sizeof(uintptr_t));
302
9b7db0df50f0 nginx 0.5.21
Igor Sysoev <http://sysoev.ru>
parents: 266
diff changeset
271 m = (uintptr_t) 1 << rrp->current % (8 * sizeof(uintptr_t));
260
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 if (!(rrp->tried[n] & m)) {
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 peer = &rrp->peers->peer[rrp->current];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
276
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
277 if (!peer->down) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
278
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
279 if (peer->max_fails == 0
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
280 || peer->fails < peer->max_fails)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
281 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
282 break;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
283 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
284
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
285 if (now - peer->accessed > peer->fail_timeout) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
286 peer->fails = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
287 break;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
288 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
289
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
290 } else {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
291 rrp->tried[n] |= m;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
292 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
293
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
294 pc->tries--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
295 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
296
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
297 rrp->current++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
298
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
299 if (rrp->current >= rrp->peers->number) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
300 rrp->current = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
301 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
302
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
303 if (pc->tries) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
304 continue;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
305 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
306
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
307 goto failed;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
308 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
309
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
310 peer->current_weight--;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
311
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
312 if (peer->current_weight == 0) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
313 peer->current_weight = peer->weight;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
314
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
315 if (rrp->current == rrp->peers->current) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
316 rrp->peers->current++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
317
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
318 if (rrp->peers->current >= rrp->peers->number) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
319 rrp->peers->current = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
320 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
321 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
322 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
323 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
324
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
325 rrp->tried[n] |= m;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
326 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
327
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
328 pc->sockaddr = peer->sockaddr;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
329 pc->socklen = peer->socklen;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
330 pc->name = &peer->name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
331
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
332 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
333
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
334 return NGX_OK;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
335
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
336 failed:
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
337
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
338 /* all peers failed, mark them as live for quick recovery */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
339
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
340 for (i = 0; i < rrp->peers->number; i++) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
341 rrp->peers->peer[i].fails = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
342 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
343
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
344 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
345
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
346 pc->name = rrp->peers->name;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
347
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
348 return NGX_BUSY;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
349 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
350
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
351
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
352 void
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
353 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
354 ngx_uint_t state)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
355 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
356 ngx_http_upstream_rr_peer_data_t *rrp = data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
357
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
358 time_t now;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
359 ngx_http_upstream_rr_peer_t *peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
360
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
361 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
362 "free rr peer %ui %ui", pc->tries, state);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
363
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
364 if (state == 0 && pc->tries == 0) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
365 return;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
366 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
367
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
368 /* TODO: NGX_PEER_KEEPALIVE */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
369
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
370 if (rrp->peers->number == 1) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
371 pc->tries = 0;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
372 return;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
373 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
374
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
375 if (state & NGX_PEER_FAILED) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
376 now = ngx_time();
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
377
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
378 peer = &rrp->peers->peer[rrp->current];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
379
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
380 /* ngx_lock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
381
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
382 peer->fails++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
383 peer->accessed = now;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
384
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
385 if (peer->current_weight > 1) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
386 peer->current_weight /= 2;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
387 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
388
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
389 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
390 }
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 rrp->current++;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
393
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
394 if (rrp->current >= rrp->peers->number) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
395 rrp->current = 0;
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
398 if (pc->tries) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
399 pc->tries--;
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
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
402 /* ngx_unlock_mutex(rrp->peers->mutex); */
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
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_HTTP_SSL)
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
407
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
408 ngx_int_t
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
409 ngx_http_upstream_set_round_robin_peer_session(ngx_peer_connection_t *pc,
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
410 void *data)
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
411 {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
412 ngx_http_upstream_rr_peer_data_t *rrp = data;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
413
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
414 ngx_int_t rc;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
415 ngx_ssl_session_t *ssl_session;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
416 ngx_http_upstream_rr_peer_t *peer;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
417
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
418 peer = &rrp->peers->peer[rrp->current];
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
419
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
420 /* TODO: threads only mutex */
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
421 /* ngx_lock_mutex(rrp->peers->mutex); */
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
422
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
423 ssl_session = peer->ssl_session;
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
424
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
425 rc = ngx_ssl_set_session(pc->connection, ssl_session);
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
426
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
427 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
324
7cf404023f50 nginx 0.5.32
Igor Sysoev <http://sysoev.ru>
parents: 320
diff changeset
428 "set session: %p:%d",
7cf404023f50 nginx 0.5.32
Igor Sysoev <http://sysoev.ru>
parents: 320
diff changeset
429 ssl_session, ssl_session ? ssl_session->references : 0);
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
430
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
431 /* ngx_unlock_mutex(rrp->peers->mutex); */
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
432
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
433 return rc;
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
434 }
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
435
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
436
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
437 void
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
438 ngx_http_upstream_save_round_robin_peer_session(ngx_peer_connection_t *pc,
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
439 void *data)
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
440 {
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
441 ngx_http_upstream_rr_peer_data_t *rrp = data;
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
442
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
443 ngx_ssl_session_t *old_ssl_session, *ssl_session;
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
444 ngx_http_upstream_rr_peer_t *peer;
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
445
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
446 ssl_session = ngx_ssl_get_session(pc->connection);
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
447
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
448 if (ssl_session == NULL) {
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
449 return;
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
450 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
451
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
452 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
324
7cf404023f50 nginx 0.5.32
Igor Sysoev <http://sysoev.ru>
parents: 320
diff changeset
453 "save session: %p:%d", ssl_session, ssl_session->references);
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
454
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
455 peer = &rrp->peers->peer[rrp->current];
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
456
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
457 /* TODO: threads only mutex */
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
458 /* ngx_lock_mutex(rrp->peers->mutex); */
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
459
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
460 old_ssl_session = peer->ssl_session;
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
461 peer->ssl_session = ssl_session;
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
462
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
463 /* ngx_unlock_mutex(rrp->peers->mutex); */
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
464
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
465 if (old_ssl_session) {
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
466
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
467 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, pc->log, 0,
324
7cf404023f50 nginx 0.5.32
Igor Sysoev <http://sysoev.ru>
parents: 320
diff changeset
468 "old session: %p:%d",
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
469 old_ssl_session, old_ssl_session->references);
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
470
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
471 /* TODO: may block */
320
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
472
1e9e2c5e7c14 nginx 0.5.30
Igor Sysoev <http://sysoev.ru>
parents: 302
diff changeset
473 ngx_ssl_free_session(old_ssl_session);
260
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
474 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
475 }
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
476
0effe91f6083 nginx 0.5.0
Igor Sysoev <http://sysoev.ru>
parents:
diff changeset
477 #endif