Mercurial > hg > nginx
annotate src/http/modules/ngx_http_scgi_module.c @ 5204:a64c8a5da336
PCRE: retain input pattern for all regular expressions.
Previously, input pattern was kept only for regular expressions
with named captures, which resulted in error log entries without
input pattern for PCRE errors that occured while processing
regular expressions without them.
Signed-off-by: Piotr Sikora <piotr@cloudflare.com>
| author | Piotr Sikora <piotr@cloudflare.com> |
|---|---|
| date | Thu, 02 May 2013 03:26:36 -0700 |
| parents | 8da37c1b22a4 |
| children | 05c53652e7b4 |
| rev | line source |
|---|---|
| 3637 | 1 |
| 2 /* | |
| 3 * Copyright (C) Igor Sysoev | |
| 4412 | 4 * Copyright (C) Nginx, Inc. |
| 3637 | 5 * Copyright (C) Manlio Perillo (manlio.perillo@gmail.com) |
| 6 */ | |
| 7 | |
| 8 | |
| 9 #include <ngx_config.h> | |
| 10 #include <ngx_core.h> | |
| 11 #include <ngx_http.h> | |
| 12 | |
| 13 | |
| 14 typedef struct { | |
| 15 ngx_http_upstream_conf_t upstream; | |
| 16 | |
| 17 ngx_array_t *flushes; | |
| 18 ngx_array_t *params_len; | |
| 19 ngx_array_t *params; | |
| 20 ngx_array_t *params_source; | |
| 21 | |
| 22 ngx_hash_t headers_hash; | |
| 23 ngx_uint_t header_params; | |
| 24 | |
| 25 ngx_array_t *scgi_lengths; | |
| 26 ngx_array_t *scgi_values; | |
| 27 | |
| 28 #if (NGX_HTTP_CACHE) | |
| 29 ngx_http_complex_value_t cache_key; | |
| 30 #endif | |
| 31 } ngx_http_scgi_loc_conf_t; | |
| 32 | |
| 33 | |
| 34 static ngx_int_t ngx_http_scgi_eval(ngx_http_request_t *r, | |
| 35 ngx_http_scgi_loc_conf_t *scf); | |
| 36 static ngx_int_t ngx_http_scgi_create_request(ngx_http_request_t *r); | |
| 37 static ngx_int_t ngx_http_scgi_reinit_request(ngx_http_request_t *r); | |
| 38 static ngx_int_t ngx_http_scgi_process_status_line(ngx_http_request_t *r); | |
| 39 static ngx_int_t ngx_http_scgi_process_header(ngx_http_request_t *r); | |
| 40 static void ngx_http_scgi_abort_request(ngx_http_request_t *r); | |
| 41 static void ngx_http_scgi_finalize_request(ngx_http_request_t *r, ngx_int_t rc); | |
| 42 | |
| 43 static void *ngx_http_scgi_create_loc_conf(ngx_conf_t *cf); | |
| 44 static char *ngx_http_scgi_merge_loc_conf(ngx_conf_t *cf, void *parent, | |
| 45 void *child); | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
46 static ngx_int_t ngx_http_scgi_merge_params(ngx_conf_t *cf, |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
47 ngx_http_scgi_loc_conf_t *conf, ngx_http_scgi_loc_conf_t *prev); |
| 3637 | 48 |
| 49 static char *ngx_http_scgi_pass(ngx_conf_t *cf, ngx_command_t *cmd, void *conf); | |
| 50 static char *ngx_http_scgi_store(ngx_conf_t *cf, ngx_command_t *cmd, | |
| 51 void *conf); | |
| 52 | |
| 53 #if (NGX_HTTP_CACHE) | |
| 54 static ngx_int_t ngx_http_scgi_create_key(ngx_http_request_t *r); | |
| 55 static char *ngx_http_scgi_cache(ngx_conf_t *cf, ngx_command_t *cmd, | |
| 56 void *conf); | |
| 57 static char *ngx_http_scgi_cache_key(ngx_conf_t *cf, ngx_command_t *cmd, | |
| 58 void *conf); | |
| 59 #endif | |
| 60 | |
| 61 | |
| 62 static ngx_conf_bitmask_t ngx_http_scgi_next_upstream_masks[] = { | |
| 63 { ngx_string("error"), NGX_HTTP_UPSTREAM_FT_ERROR }, | |
| 64 { ngx_string("timeout"), NGX_HTTP_UPSTREAM_FT_TIMEOUT }, | |
| 65 { ngx_string("invalid_header"), NGX_HTTP_UPSTREAM_FT_INVALID_HEADER }, | |
| 66 { ngx_string("http_500"), NGX_HTTP_UPSTREAM_FT_HTTP_500 }, | |
| 67 { ngx_string("http_503"), NGX_HTTP_UPSTREAM_FT_HTTP_503 }, | |
| 68 { ngx_string("http_404"), NGX_HTTP_UPSTREAM_FT_HTTP_404 }, | |
| 69 { ngx_string("updating"), NGX_HTTP_UPSTREAM_FT_UPDATING }, | |
| 70 { ngx_string("off"), NGX_HTTP_UPSTREAM_FT_OFF }, | |
| 71 { ngx_null_string, 0 } | |
| 72 }; | |
| 73 | |
| 74 | |
| 75 ngx_module_t ngx_http_scgi_module; | |
| 76 | |
| 77 | |
| 78 static ngx_command_t ngx_http_scgi_commands[] = { | |
| 79 | |
| 80 { ngx_string("scgi_pass"), | |
| 81 NGX_HTTP_LOC_CONF|NGX_HTTP_LIF_CONF|NGX_CONF_TAKE1, | |
| 82 ngx_http_scgi_pass, | |
| 83 NGX_HTTP_LOC_CONF_OFFSET, | |
| 84 0, | |
| 85 NULL }, | |
| 86 | |
| 87 { ngx_string("scgi_store"), | |
| 88 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 89 ngx_http_scgi_store, | |
| 90 NGX_HTTP_LOC_CONF_OFFSET, | |
| 91 0, | |
| 92 NULL }, | |
| 93 | |
| 94 { ngx_string("scgi_store_access"), | |
| 95 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE123, | |
| 96 ngx_conf_set_access_slot, | |
| 97 NGX_HTTP_LOC_CONF_OFFSET, | |
| 98 offsetof(ngx_http_scgi_loc_conf_t, upstream.store_access), | |
| 99 NULL }, | |
| 100 | |
|
4157
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
101 { ngx_string("scgi_buffering"), |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
102 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
103 ngx_conf_set_flag_slot, |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
104 NGX_HTTP_LOC_CONF_OFFSET, |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
105 offsetof(ngx_http_scgi_loc_conf_t, upstream.buffering), |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
106 NULL }, |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
107 |
| 3637 | 108 { ngx_string("scgi_ignore_client_abort"), |
| 109 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, | |
| 110 ngx_conf_set_flag_slot, | |
| 111 NGX_HTTP_LOC_CONF_OFFSET, | |
| 112 offsetof(ngx_http_scgi_loc_conf_t, upstream.ignore_client_abort), | |
| 113 NULL }, | |
| 114 | |
| 115 { ngx_string("scgi_bind"), | |
| 116 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 117 ngx_http_upstream_bind_set_slot, | |
| 118 NGX_HTTP_LOC_CONF_OFFSET, | |
| 119 offsetof(ngx_http_scgi_loc_conf_t, upstream.local), | |
| 120 NULL }, | |
| 121 | |
| 122 { ngx_string("scgi_connect_timeout"), | |
| 123 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 124 ngx_conf_set_msec_slot, | |
| 125 NGX_HTTP_LOC_CONF_OFFSET, | |
| 126 offsetof(ngx_http_scgi_loc_conf_t, upstream.connect_timeout), | |
| 127 NULL }, | |
| 128 | |
| 129 { ngx_string("scgi_send_timeout"), | |
| 130 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 131 ngx_conf_set_msec_slot, | |
| 132 NGX_HTTP_LOC_CONF_OFFSET, | |
| 133 offsetof(ngx_http_scgi_loc_conf_t, upstream.send_timeout), | |
| 134 NULL }, | |
| 135 | |
| 136 { ngx_string("scgi_buffer_size"), | |
| 137 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 138 ngx_conf_set_size_slot, | |
| 139 NGX_HTTP_LOC_CONF_OFFSET, | |
| 140 offsetof(ngx_http_scgi_loc_conf_t, upstream.buffer_size), | |
| 141 NULL }, | |
| 142 | |
| 143 { ngx_string("scgi_pass_request_headers"), | |
| 144 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, | |
| 145 ngx_conf_set_flag_slot, | |
| 146 NGX_HTTP_LOC_CONF_OFFSET, | |
| 147 offsetof(ngx_http_scgi_loc_conf_t, upstream.pass_request_headers), | |
| 148 NULL }, | |
| 149 | |
| 150 { ngx_string("scgi_pass_request_body"), | |
| 151 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, | |
| 152 ngx_conf_set_flag_slot, | |
| 153 NGX_HTTP_LOC_CONF_OFFSET, | |
| 154 offsetof(ngx_http_scgi_loc_conf_t, upstream.pass_request_body), | |
| 155 NULL }, | |
| 156 | |
| 157 { ngx_string("scgi_intercept_errors"), | |
| 158 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, | |
| 159 ngx_conf_set_flag_slot, | |
| 160 NGX_HTTP_LOC_CONF_OFFSET, | |
| 161 offsetof(ngx_http_scgi_loc_conf_t, upstream.intercept_errors), | |
| 162 NULL }, | |
| 163 | |
| 164 { ngx_string("scgi_read_timeout"), | |
| 165 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 166 ngx_conf_set_msec_slot, | |
| 167 NGX_HTTP_LOC_CONF_OFFSET, | |
| 168 offsetof(ngx_http_scgi_loc_conf_t, upstream.read_timeout), | |
| 169 NULL }, | |
| 170 | |
| 171 { ngx_string("scgi_buffers"), | |
| 172 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE2, | |
| 173 ngx_conf_set_bufs_slot, | |
| 174 NGX_HTTP_LOC_CONF_OFFSET, | |
| 175 offsetof(ngx_http_scgi_loc_conf_t, upstream.bufs), | |
| 176 NULL }, | |
| 177 | |
| 178 { ngx_string("scgi_busy_buffers_size"), | |
| 179 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 180 ngx_conf_set_size_slot, | |
| 181 NGX_HTTP_LOC_CONF_OFFSET, | |
| 182 offsetof(ngx_http_scgi_loc_conf_t, upstream.busy_buffers_size_conf), | |
| 183 NULL }, | |
| 184 | |
| 185 #if (NGX_HTTP_CACHE) | |
| 186 | |
| 187 { ngx_string("scgi_cache"), | |
| 3729 | 188 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, |
| 3637 | 189 ngx_http_scgi_cache, |
| 190 NGX_HTTP_LOC_CONF_OFFSET, | |
| 191 0, | |
| 192 NULL }, | |
| 193 | |
| 194 { ngx_string("scgi_cache_key"), | |
| 3729 | 195 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, |
| 3637 | 196 ngx_http_scgi_cache_key, |
| 197 NGX_HTTP_LOC_CONF_OFFSET, | |
| 198 0, | |
| 199 NULL }, | |
| 200 | |
| 201 { ngx_string("scgi_cache_path"), | |
| 202 NGX_HTTP_MAIN_CONF|NGX_CONF_2MORE, | |
| 203 ngx_http_file_cache_set_slot, | |
| 204 0, | |
| 205 0, | |
| 206 &ngx_http_scgi_module }, | |
| 207 | |
|
3699
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
208 { ngx_string("scgi_cache_bypass"), |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
209 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
210 ngx_http_set_predicate_slot, |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
211 NGX_HTTP_LOC_CONF_OFFSET, |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
212 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_bypass), |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
213 NULL }, |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
214 |
| 3637 | 215 { ngx_string("scgi_no_cache"), |
| 216 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, | |
|
3692
045ea40cbfe8
use ngx_http_test_predicates(), ngx_http_set_predicate_slot()
Igor Sysoev <igor@sysoev.ru>
parents:
3670
diff
changeset
|
217 ngx_http_set_predicate_slot, |
| 3637 | 218 NGX_HTTP_LOC_CONF_OFFSET, |
| 219 offsetof(ngx_http_scgi_loc_conf_t, upstream.no_cache), | |
| 220 NULL }, | |
| 221 | |
| 222 { ngx_string("scgi_cache_valid"), | |
| 223 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, | |
| 224 ngx_http_file_cache_valid_set_slot, | |
| 225 NGX_HTTP_LOC_CONF_OFFSET, | |
| 226 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_valid), | |
| 227 NULL }, | |
| 228 | |
| 229 { ngx_string("scgi_cache_min_uses"), | |
| 230 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 231 ngx_conf_set_num_slot, | |
| 232 NGX_HTTP_LOC_CONF_OFFSET, | |
| 233 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_min_uses), | |
| 234 NULL }, | |
| 235 | |
| 236 { ngx_string("scgi_cache_use_stale"), | |
| 237 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, | |
| 238 ngx_conf_set_bitmask_slot, | |
| 239 NGX_HTTP_LOC_CONF_OFFSET, | |
| 240 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_use_stale), | |
| 241 &ngx_http_scgi_next_upstream_masks }, | |
| 242 | |
| 243 { ngx_string("scgi_cache_methods"), | |
| 244 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, | |
| 245 ngx_conf_set_bitmask_slot, | |
| 246 NGX_HTTP_LOC_CONF_OFFSET, | |
| 247 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_methods), | |
| 248 &ngx_http_upstream_cache_method_mask }, | |
| 249 | |
|
4386
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
250 { ngx_string("scgi_cache_lock"), |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
251 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_FLAG, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
252 ngx_conf_set_flag_slot, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
253 NGX_HTTP_LOC_CONF_OFFSET, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
254 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_lock), |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
255 NULL }, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
256 |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
257 { ngx_string("scgi_cache_lock_timeout"), |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
258 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
259 ngx_conf_set_msec_slot, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
260 NGX_HTTP_LOC_CONF_OFFSET, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
261 offsetof(ngx_http_scgi_loc_conf_t, upstream.cache_lock_timeout), |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
262 NULL }, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
263 |
| 3637 | 264 #endif |
| 265 | |
| 266 { ngx_string("scgi_temp_path"), | |
| 267 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1234, | |
| 268 ngx_conf_set_path_slot, | |
| 269 NGX_HTTP_LOC_CONF_OFFSET, | |
| 270 offsetof(ngx_http_scgi_loc_conf_t, upstream.temp_path), | |
| 271 NULL }, | |
| 272 | |
| 273 { ngx_string("scgi_max_temp_file_size"), | |
| 274 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 275 ngx_conf_set_size_slot, | |
| 276 NGX_HTTP_LOC_CONF_OFFSET, | |
| 277 offsetof(ngx_http_scgi_loc_conf_t, upstream.max_temp_file_size_conf), | |
| 278 NULL }, | |
| 279 | |
| 280 { ngx_string("scgi_temp_file_write_size"), | |
| 281 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, | |
| 282 ngx_conf_set_size_slot, | |
| 283 NGX_HTTP_LOC_CONF_OFFSET, | |
| 284 offsetof(ngx_http_scgi_loc_conf_t, upstream.temp_file_write_size_conf), | |
| 285 NULL }, | |
| 286 | |
| 287 { ngx_string("scgi_next_upstream"), | |
| 288 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, | |
| 289 ngx_conf_set_bitmask_slot, | |
| 290 NGX_HTTP_LOC_CONF_OFFSET, | |
| 291 offsetof(ngx_http_scgi_loc_conf_t, upstream.next_upstream), | |
| 292 &ngx_http_scgi_next_upstream_masks }, | |
| 293 | |
| 294 { ngx_string("scgi_param"), | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
295 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE23, |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
296 ngx_http_upstream_param_set_slot, |
| 3637 | 297 NGX_HTTP_LOC_CONF_OFFSET, |
| 298 offsetof(ngx_http_scgi_loc_conf_t, params_source), | |
| 299 NULL }, | |
| 300 | |
| 301 { ngx_string("scgi_pass_header"), | |
| 3729 | 302 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, |
| 3637 | 303 ngx_conf_set_str_array_slot, |
| 304 NGX_HTTP_LOC_CONF_OFFSET, | |
| 305 offsetof(ngx_http_scgi_loc_conf_t, upstream.pass_headers), | |
| 306 NULL }, | |
| 307 | |
| 308 { ngx_string("scgi_hide_header"), | |
| 3729 | 309 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1, |
| 3637 | 310 ngx_conf_set_str_array_slot, |
| 311 NGX_HTTP_LOC_CONF_OFFSET, | |
| 312 offsetof(ngx_http_scgi_loc_conf_t, upstream.hide_headers), | |
| 313 NULL }, | |
| 314 | |
| 315 { ngx_string("scgi_ignore_headers"), | |
| 316 NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE, | |
| 317 ngx_conf_set_bitmask_slot, | |
| 318 NGX_HTTP_LOC_CONF_OFFSET, | |
| 319 offsetof(ngx_http_scgi_loc_conf_t, upstream.ignore_headers), | |
|
3667
12bd9e26fadb
use shared ngx_http_upstream_ignore_headers_masks[]
Igor Sysoev <igor@sysoev.ru>
parents:
3637
diff
changeset
|
320 &ngx_http_upstream_ignore_headers_masks }, |
| 3637 | 321 |
| 322 ngx_null_command | |
| 323 }; | |
| 324 | |
| 325 | |
| 326 static ngx_http_module_t ngx_http_scgi_module_ctx = { | |
| 327 NULL, /* preconfiguration */ | |
| 328 NULL, /* postconfiguration */ | |
| 329 | |
| 330 NULL, /* create main configuration */ | |
| 331 NULL, /* init main configuration */ | |
| 332 | |
| 333 NULL, /* create server configuration */ | |
| 334 NULL, /* merge server configuration */ | |
| 335 | |
| 336 ngx_http_scgi_create_loc_conf, /* create location configuration */ | |
| 337 ngx_http_scgi_merge_loc_conf /* merge location configuration */ | |
| 338 }; | |
| 339 | |
| 340 | |
| 341 ngx_module_t ngx_http_scgi_module = { | |
| 342 NGX_MODULE_V1, | |
| 343 &ngx_http_scgi_module_ctx, /* module context */ | |
| 344 ngx_http_scgi_commands, /* module directives */ | |
| 345 NGX_HTTP_MODULE, /* module type */ | |
| 346 NULL, /* init master */ | |
| 347 NULL, /* init module */ | |
| 348 NULL, /* init process */ | |
| 349 NULL, /* init thread */ | |
| 350 NULL, /* exit thread */ | |
| 351 NULL, /* exit process */ | |
| 352 NULL, /* exit master */ | |
| 353 NGX_MODULE_V1_PADDING | |
| 354 }; | |
| 355 | |
| 356 | |
| 357 static ngx_str_t ngx_http_scgi_hide_headers[] = { | |
| 358 ngx_string("Status"), | |
| 359 ngx_string("X-Accel-Expires"), | |
| 360 ngx_string("X-Accel-Redirect"), | |
| 361 ngx_string("X-Accel-Limit-Rate"), | |
| 362 ngx_string("X-Accel-Buffering"), | |
| 363 ngx_string("X-Accel-Charset"), | |
| 364 ngx_null_string | |
| 365 }; | |
| 366 | |
| 367 | |
| 368 #if (NGX_HTTP_CACHE) | |
| 369 | |
| 370 static ngx_keyval_t ngx_http_scgi_cache_headers[] = { | |
| 371 { ngx_string("HTTP_IF_MODIFIED_SINCE"), ngx_string("") }, | |
| 372 { ngx_string("HTTP_IF_UNMODIFIED_SINCE"), ngx_string("") }, | |
| 373 { ngx_string("HTTP_IF_NONE_MATCH"), ngx_string("") }, | |
| 374 { ngx_string("HTTP_IF_MATCH"), ngx_string("") }, | |
| 375 { ngx_string("HTTP_RANGE"), ngx_string("") }, | |
| 376 { ngx_string("HTTP_IF_RANGE"), ngx_string("") }, | |
| 377 { ngx_null_string, ngx_null_string } | |
| 378 }; | |
| 379 | |
| 380 #endif | |
| 381 | |
| 382 | |
| 383 static ngx_path_init_t ngx_http_scgi_temp_path = { | |
| 384 ngx_string(NGX_HTTP_SCGI_TEMP_PATH), { 1, 2, 0 } | |
| 385 }; | |
| 386 | |
| 387 | |
| 388 static ngx_int_t | |
| 389 ngx_http_scgi_handler(ngx_http_request_t *r) | |
| 390 { | |
| 391 ngx_int_t rc; | |
| 392 ngx_http_status_t *status; | |
| 393 ngx_http_upstream_t *u; | |
| 394 ngx_http_scgi_loc_conf_t *scf; | |
| 395 | |
| 396 if (r->subrequest_in_memory) { | |
| 397 ngx_log_error(NGX_LOG_ALERT, r->connection->log, 0, | |
| 398 "ngx_http_scgi_module does not support " | |
| 399 "subrequests in memory"); | |
| 400 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 401 } | |
| 402 | |
| 403 if (ngx_http_upstream_create(r) != NGX_OK) { | |
| 404 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 405 } | |
| 406 | |
| 407 status = ngx_pcalloc(r->pool, sizeof(ngx_http_status_t)); | |
| 408 if (status == NULL) { | |
| 409 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 410 } | |
| 411 | |
| 412 ngx_http_set_ctx(r, status, ngx_http_scgi_module); | |
| 413 | |
| 414 scf = ngx_http_get_module_loc_conf(r, ngx_http_scgi_module); | |
| 415 | |
| 416 if (scf->scgi_lengths) { | |
| 417 if (ngx_http_scgi_eval(r, scf) != NGX_OK) { | |
| 418 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 419 } | |
| 420 } | |
| 421 | |
| 422 u = r->upstream; | |
| 423 | |
| 424 ngx_str_set(&u->schema, "scgi://"); | |
| 425 u->output.tag = (ngx_buf_tag_t) &ngx_http_scgi_module; | |
| 426 | |
| 427 u->conf = &scf->upstream; | |
| 428 | |
| 429 #if (NGX_HTTP_CACHE) | |
| 430 u->create_key = ngx_http_scgi_create_key; | |
| 431 #endif | |
| 432 u->create_request = ngx_http_scgi_create_request; | |
| 433 u->reinit_request = ngx_http_scgi_reinit_request; | |
| 434 u->process_header = ngx_http_scgi_process_status_line; | |
| 435 u->abort_request = ngx_http_scgi_abort_request; | |
| 436 u->finalize_request = ngx_http_scgi_finalize_request; | |
|
4615
adcd60233817
Added r->state reset on fastcgi/scgi/uwsgi request start.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4593
diff
changeset
|
437 r->state = 0; |
| 3637 | 438 |
|
4157
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
439 u->buffering = scf->upstream.buffering; |
| 3637 | 440 |
| 441 u->pipe = ngx_pcalloc(r->pool, sizeof(ngx_event_pipe_t)); | |
| 442 if (u->pipe == NULL) { | |
| 443 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 444 } | |
| 445 | |
| 446 u->pipe->input_filter = ngx_event_pipe_copy_input_filter; | |
| 447 u->pipe->input_ctx = r; | |
| 448 | |
| 449 rc = ngx_http_read_client_request_body(r, ngx_http_upstream_init); | |
| 450 | |
| 451 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { | |
| 452 return rc; | |
| 453 } | |
| 454 | |
| 455 return NGX_DONE; | |
| 456 } | |
| 457 | |
| 458 | |
| 459 static ngx_int_t | |
| 460 ngx_http_scgi_eval(ngx_http_request_t *r, ngx_http_scgi_loc_conf_t * scf) | |
| 461 { | |
| 462 ngx_url_t url; | |
| 463 ngx_http_upstream_t *u; | |
| 464 | |
| 465 ngx_memzero(&url, sizeof(ngx_url_t)); | |
| 466 | |
| 467 if (ngx_http_script_run(r, &url.url, scf->scgi_lengths->elts, 0, | |
| 468 scf->scgi_values->elts) | |
| 469 == NULL) | |
| 470 { | |
| 471 return NGX_ERROR; | |
| 472 } | |
| 473 | |
| 474 url.no_resolve = 1; | |
| 475 | |
| 476 if (ngx_parse_url(r->pool, &url) != NGX_OK) { | |
| 477 if (url.err) { | |
| 478 ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, | |
| 479 "%s in upstream \"%V\"", url.err, &url.url); | |
| 480 } | |
| 481 | |
| 482 return NGX_ERROR; | |
| 483 } | |
| 484 | |
| 485 u = r->upstream; | |
| 486 | |
| 487 u->resolved = ngx_pcalloc(r->pool, sizeof(ngx_http_upstream_resolved_t)); | |
| 488 if (u->resolved == NULL) { | |
| 489 return NGX_ERROR; | |
| 490 } | |
| 491 | |
| 492 if (url.addrs && url.addrs[0].sockaddr) { | |
| 493 u->resolved->sockaddr = url.addrs[0].sockaddr; | |
| 494 u->resolved->socklen = url.addrs[0].socklen; | |
| 495 u->resolved->naddrs = 1; | |
| 496 u->resolved->host = url.addrs[0].name; | |
| 497 | |
| 498 } else { | |
| 499 u->resolved->host = url.host; | |
| 500 u->resolved->port = url.port; | |
|
3879
502a6b0acf3f
fix case when a host in fastcgi_pass, scgi_pass, and uwsgi_pass
Igor Sysoev <igor@sysoev.ru>
parents:
3731
diff
changeset
|
501 u->resolved->no_port = url.no_port; |
| 3637 | 502 } |
| 503 | |
| 504 return NGX_OK; | |
| 505 } | |
| 506 | |
| 507 | |
| 508 #if (NGX_HTTP_CACHE) | |
| 509 | |
| 510 static ngx_int_t | |
| 511 ngx_http_scgi_create_key(ngx_http_request_t *r) | |
| 512 { | |
| 513 ngx_str_t *key; | |
| 514 ngx_http_scgi_loc_conf_t *scf; | |
| 515 | |
| 516 key = ngx_array_push(&r->cache->keys); | |
| 517 if (key == NULL) { | |
| 518 return NGX_ERROR; | |
| 519 } | |
| 520 | |
| 521 scf = ngx_http_get_module_loc_conf(r, ngx_http_scgi_module); | |
| 522 | |
| 523 if (ngx_http_complex_value(r, &scf->cache_key, key) != NGX_OK) { | |
| 524 return NGX_ERROR; | |
| 525 } | |
| 526 | |
| 527 return NGX_OK; | |
| 528 } | |
| 529 | |
| 530 #endif | |
| 531 | |
| 532 | |
| 533 static ngx_int_t | |
| 534 ngx_http_scgi_create_request(ngx_http_request_t *r) | |
| 535 { | |
|
4929
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
536 off_t content_length_n; |
| 3637 | 537 u_char ch, *key, *val, *lowcase_key; |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
538 size_t len, key_len, val_len, allocated; |
| 3637 | 539 ngx_buf_t *b; |
|
4929
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
540 ngx_str_t content_length; |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
541 ngx_uint_t i, n, hash, skip_empty, header_params; |
| 3637 | 542 ngx_chain_t *cl, *body; |
| 543 ngx_list_part_t *part; | |
| 544 ngx_table_elt_t *header, **ignored; | |
| 545 ngx_http_script_code_pt code; | |
| 546 ngx_http_script_engine_t e, le; | |
| 547 ngx_http_scgi_loc_conf_t *scf; | |
| 548 ngx_http_script_len_code_pt lcode; | |
|
4929
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
549 u_char buffer[NGX_OFF_T_LEN]; |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
550 |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
551 content_length_n = 0; |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
552 body = r->upstream->request_bufs; |
| 3637 | 553 |
|
4929
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
554 while (body) { |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
555 content_length_n += ngx_buf_size(body->buf); |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
556 body = body->next; |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
557 } |
| 3637 | 558 |
|
4929
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
559 content_length.data = buffer; |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
560 content_length.len = ngx_sprintf(buffer, "%O", content_length_n) - buffer; |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
561 |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
562 len = sizeof("CONTENT_LENGTH") + content_length.len + 1; |
| 3637 | 563 |
| 564 header_params = 0; | |
| 565 ignored = NULL; | |
| 566 | |
| 567 scf = ngx_http_get_module_loc_conf(r, ngx_http_scgi_module); | |
| 568 | |
| 569 if (scf->params_len) { | |
| 570 ngx_memzero(&le, sizeof(ngx_http_script_engine_t)); | |
| 571 | |
| 572 ngx_http_script_flush_no_cacheable_variables(r, scf->flushes); | |
| 573 le.flushed = 1; | |
| 574 | |
| 575 le.ip = scf->params_len->elts; | |
| 576 le.request = r; | |
| 577 | |
| 578 while (*(uintptr_t *) le.ip) { | |
| 579 | |
| 580 lcode = *(ngx_http_script_len_code_pt *) le.ip; | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
581 key_len = lcode(&le); |
| 3637 | 582 |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
583 lcode = *(ngx_http_script_len_code_pt *) le.ip; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
584 skip_empty = lcode(&le); |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
585 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
586 for (val_len = 0; *(uintptr_t *) le.ip; val_len += lcode(&le)) { |
| 3637 | 587 lcode = *(ngx_http_script_len_code_pt *) le.ip; |
| 588 } | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
589 le.ip += sizeof(uintptr_t); |
|
4294
56cb2255735a
Fixed incorrect counting the length of headers in a SCGI request.
Valentin Bartenev <vbart@nginx.com>
parents:
4278
diff
changeset
|
590 |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
591 if (skip_empty && val_len == 0) { |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
592 continue; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
593 } |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
594 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
595 len += key_len + val_len + 1; |
| 3637 | 596 } |
| 597 } | |
| 598 | |
| 599 if (scf->upstream.pass_request_headers) { | |
| 600 | |
| 601 allocated = 0; | |
| 602 lowcase_key = NULL; | |
| 603 | |
| 604 if (scf->header_params) { | |
|
4015
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
605 n = 0; |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
606 part = &r->headers_in.headers.part; |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
607 |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
608 while (part) { |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
609 n += part->nelts; |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
610 part = part->next; |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
611 } |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
612 |
|
e0a435f5f504
Fix ignored headers handling in fastcgi/scgi/uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
3976
diff
changeset
|
613 ignored = ngx_palloc(r->pool, n * sizeof(void *)); |
| 3637 | 614 if (ignored == NULL) { |
| 615 return NGX_ERROR; | |
| 616 } | |
| 617 } | |
| 618 | |
| 619 part = &r->headers_in.headers.part; | |
| 620 header = part->elts; | |
| 621 | |
| 622 for (i = 0; /* void */; i++) { | |
| 623 | |
| 624 if (i >= part->nelts) { | |
| 625 if (part->next == NULL) { | |
| 626 break; | |
| 627 } | |
| 628 | |
| 629 part = part->next; | |
| 630 header = part->elts; | |
| 631 i = 0; | |
| 632 } | |
| 633 | |
| 634 if (scf->header_params) { | |
| 635 if (allocated < header[i].key.len) { | |
| 636 allocated = header[i].key.len + 16; | |
| 637 lowcase_key = ngx_pnalloc(r->pool, allocated); | |
| 638 if (lowcase_key == NULL) { | |
| 639 return NGX_ERROR; | |
| 640 } | |
| 641 } | |
| 642 | |
| 643 hash = 0; | |
| 644 | |
| 645 for (n = 0; n < header[i].key.len; n++) { | |
| 646 ch = header[i].key.data[n]; | |
| 647 | |
| 648 if (ch >= 'A' && ch <= 'Z') { | |
| 649 ch |= 0x20; | |
| 650 | |
| 651 } else if (ch == '-') { | |
| 652 ch = '_'; | |
| 653 } | |
| 654 | |
| 655 hash = ngx_hash(hash, ch); | |
| 656 lowcase_key[n] = ch; | |
| 657 } | |
| 658 | |
| 659 if (ngx_hash_find(&scf->headers_hash, hash, lowcase_key, n)) { | |
| 660 ignored[header_params++] = &header[i]; | |
| 661 continue; | |
| 662 } | |
| 663 } | |
| 664 | |
| 665 len += sizeof("HTTP_") - 1 + header[i].key.len + 1 | |
| 666 + header[i].value.len + 1; | |
| 667 } | |
| 668 } | |
| 669 | |
| 670 /* netstring: "length:" + packet + "," */ | |
| 671 | |
| 672 b = ngx_create_temp_buf(r->pool, NGX_SIZE_T_LEN + 1 + len + 1); | |
| 673 if (b == NULL) { | |
| 674 return NGX_ERROR; | |
| 675 } | |
| 676 | |
| 677 cl = ngx_alloc_chain_link(r->pool); | |
| 678 if (cl == NULL) { | |
| 679 return NGX_ERROR; | |
| 680 } | |
| 681 | |
| 682 cl->buf = b; | |
| 683 | |
|
4929
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
684 b->last = ngx_sprintf(b->last, "%ui:CONTENT_LENGTH%Z%V%Z", |
|
5a44d638cd27
Request body: recalculate size of a request body in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4615
diff
changeset
|
685 len, &content_length); |
| 3637 | 686 |
| 687 if (scf->params_len) { | |
| 688 ngx_memzero(&e, sizeof(ngx_http_script_engine_t)); | |
| 689 | |
| 690 e.ip = scf->params->elts; | |
| 691 e.pos = b->last; | |
| 692 e.request = r; | |
| 693 e.flushed = 1; | |
| 694 | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
695 le.ip = scf->params_len->elts; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
696 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
697 while (*(uintptr_t *) le.ip) { |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
698 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
699 lcode = *(ngx_http_script_len_code_pt *) le.ip; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
700 lcode(&le); /* key length */ |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
701 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
702 lcode = *(ngx_http_script_len_code_pt *) le.ip; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
703 skip_empty = lcode(&le); |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
704 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
705 for (val_len = 0; *(uintptr_t *) le.ip; val_len += lcode(&le)) { |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
706 lcode = *(ngx_http_script_len_code_pt *) le.ip; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
707 } |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
708 le.ip += sizeof(uintptr_t); |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
709 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
710 if (skip_empty && val_len == 0) { |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
711 e.skip = 1; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
712 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
713 while (*(uintptr_t *) e.ip) { |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
714 code = *(ngx_http_script_code_pt *) e.ip; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
715 code((ngx_http_script_engine_t *) &e); |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
716 } |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
717 e.ip += sizeof(uintptr_t); |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
718 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
719 e.skip = 0; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
720 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
721 continue; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
722 } |
| 3637 | 723 |
| 724 #if (NGX_DEBUG) | |
| 725 key = e.pos; | |
| 726 #endif | |
| 727 code = *(ngx_http_script_code_pt *) e.ip; | |
| 728 code((ngx_http_script_engine_t *) & e); | |
| 729 | |
| 730 #if (NGX_DEBUG) | |
| 731 val = e.pos; | |
| 732 #endif | |
| 733 while (*(uintptr_t *) e.ip) { | |
| 734 code = *(ngx_http_script_code_pt *) e.ip; | |
| 735 code((ngx_http_script_engine_t *) &e); | |
| 736 } | |
| 737 *e.pos++ = '\0'; | |
| 738 e.ip += sizeof(uintptr_t); | |
| 739 | |
| 740 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 741 "scgi param: \"%s: %s\"", key, val); | |
| 742 } | |
| 743 | |
| 744 b->last = e.pos; | |
| 745 } | |
| 746 | |
| 747 if (scf->upstream.pass_request_headers) { | |
| 748 | |
| 749 part = &r->headers_in.headers.part; | |
| 750 header = part->elts; | |
| 751 | |
| 752 for (i = 0; /* void */; i++) { | |
| 753 | |
| 754 if (i >= part->nelts) { | |
| 755 if (part->next == NULL) { | |
| 756 break; | |
| 757 } | |
| 758 | |
| 759 part = part->next; | |
| 760 header = part->elts; | |
| 761 i = 0; | |
| 762 } | |
| 763 | |
| 764 for (n = 0; n < header_params; n++) { | |
| 765 if (&header[i] == ignored[n]) { | |
| 766 goto next; | |
| 767 } | |
| 768 } | |
| 769 | |
| 770 key = b->last; | |
| 771 b->last = ngx_cpymem(key, "HTTP_", sizeof("HTTP_") - 1); | |
| 772 | |
| 773 for (n = 0; n < header[i].key.len; n++) { | |
| 774 ch = header[i].key.data[n]; | |
| 775 | |
| 776 if (ch >= 'a' && ch <= 'z') { | |
| 777 ch &= ~0x20; | |
| 778 | |
| 779 } else if (ch == '-') { | |
| 780 ch = '_'; | |
| 781 } | |
| 782 | |
| 783 *b->last++ = ch; | |
| 784 } | |
| 785 | |
| 786 *b->last++ = (u_char) 0; | |
| 787 | |
| 788 val = b->last; | |
| 789 b->last = ngx_copy(val, header[i].value.data, header[i].value.len); | |
| 790 *b->last++ = (u_char) 0; | |
| 791 | |
| 792 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 793 "scgi param: \"%s: %s\"", key, val); | |
| 794 | |
| 795 next: | |
| 796 | |
| 797 continue; | |
| 798 } | |
| 799 } | |
| 800 | |
| 801 *b->last++ = (u_char) ','; | |
| 802 | |
| 803 if (scf->upstream.pass_request_body) { | |
| 804 body = r->upstream->request_bufs; | |
| 805 r->upstream->request_bufs = cl; | |
| 806 | |
| 807 while (body) { | |
| 808 b = ngx_alloc_buf(r->pool); | |
| 809 if (b == NULL) { | |
| 810 return NGX_ERROR; | |
| 811 } | |
| 812 | |
| 813 ngx_memcpy(b, body->buf, sizeof(ngx_buf_t)); | |
| 814 | |
| 815 cl->next = ngx_alloc_chain_link(r->pool); | |
| 816 if (cl->next == NULL) { | |
| 817 return NGX_ERROR; | |
| 818 } | |
| 819 | |
| 820 cl = cl->next; | |
| 821 cl->buf = b; | |
| 822 | |
| 823 body = body->next; | |
| 824 } | |
| 825 | |
| 826 } else { | |
| 827 r->upstream->request_bufs = cl; | |
| 828 } | |
| 829 | |
| 830 cl->next = NULL; | |
| 831 | |
| 832 return NGX_OK; | |
| 833 } | |
| 834 | |
| 835 | |
| 836 static ngx_int_t | |
| 837 ngx_http_scgi_reinit_request(ngx_http_request_t *r) | |
| 838 { | |
| 839 ngx_http_status_t *status; | |
| 840 | |
| 841 status = ngx_http_get_module_ctx(r, ngx_http_scgi_module); | |
| 842 | |
| 843 if (status == NULL) { | |
| 844 return NGX_OK; | |
| 845 } | |
| 846 | |
| 847 status->code = 0; | |
| 848 status->count = 0; | |
| 849 status->start = NULL; | |
| 850 status->end = NULL; | |
| 851 | |
| 852 r->upstream->process_header = ngx_http_scgi_process_status_line; | |
|
4615
adcd60233817
Added r->state reset on fastcgi/scgi/uwsgi request start.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4593
diff
changeset
|
853 r->state = 0; |
| 3637 | 854 |
| 855 return NGX_OK; | |
| 856 } | |
| 857 | |
| 858 | |
| 859 static ngx_int_t | |
| 860 ngx_http_scgi_process_status_line(ngx_http_request_t *r) | |
| 861 { | |
| 862 size_t len; | |
| 863 ngx_int_t rc; | |
| 864 ngx_http_status_t *status; | |
| 865 ngx_http_upstream_t *u; | |
| 866 | |
| 867 status = ngx_http_get_module_ctx(r, ngx_http_scgi_module); | |
| 868 | |
| 869 if (status == NULL) { | |
| 870 return NGX_ERROR; | |
| 871 } | |
| 872 | |
| 873 u = r->upstream; | |
| 874 | |
| 875 rc = ngx_http_parse_status_line(r, &u->buffer, status); | |
| 876 | |
| 877 if (rc == NGX_AGAIN) { | |
| 878 return rc; | |
| 879 } | |
| 880 | |
| 881 if (rc == NGX_ERROR) { | |
| 882 u->process_header = ngx_http_scgi_process_header; | |
| 883 return ngx_http_scgi_process_header(r); | |
| 884 } | |
| 885 | |
| 886 if (u->state) { | |
| 887 u->state->status = status->code; | |
| 888 } | |
| 889 | |
| 890 u->headers_in.status_n = status->code; | |
| 891 | |
| 892 len = status->end - status->start; | |
| 893 u->headers_in.status_line.len = len; | |
| 894 | |
| 895 u->headers_in.status_line.data = ngx_pnalloc(r->pool, len); | |
| 896 if (u->headers_in.status_line.data == NULL) { | |
| 897 return NGX_ERROR; | |
| 898 } | |
| 899 | |
| 900 ngx_memcpy(u->headers_in.status_line.data, status->start, len); | |
| 901 | |
| 902 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 903 "http scgi status %ui \"%V\"", | |
| 904 u->headers_in.status_n, &u->headers_in.status_line); | |
| 905 | |
| 906 u->process_header = ngx_http_scgi_process_header; | |
| 907 | |
| 908 return ngx_http_scgi_process_header(r); | |
| 909 } | |
| 910 | |
| 911 | |
| 912 static ngx_int_t | |
| 913 ngx_http_scgi_process_header(ngx_http_request_t *r) | |
| 914 { | |
| 915 ngx_str_t *status_line; | |
| 916 ngx_int_t rc, status; | |
| 917 ngx_table_elt_t *h; | |
| 918 ngx_http_upstream_t *u; | |
| 919 ngx_http_upstream_header_t *hh; | |
| 920 ngx_http_upstream_main_conf_t *umcf; | |
| 921 | |
| 922 umcf = ngx_http_get_module_main_conf(r, ngx_http_upstream_module); | |
| 923 | |
| 924 for ( ;; ) { | |
| 925 | |
| 926 rc = ngx_http_parse_header_line(r, &r->upstream->buffer, 1); | |
| 927 | |
| 928 if (rc == NGX_OK) { | |
| 929 | |
| 930 /* a header line has been parsed successfully */ | |
| 931 | |
| 932 h = ngx_list_push(&r->upstream->headers_in.headers); | |
| 933 if (h == NULL) { | |
| 934 return NGX_ERROR; | |
| 935 } | |
| 936 | |
| 937 h->hash = r->header_hash; | |
| 938 | |
| 939 h->key.len = r->header_name_end - r->header_name_start; | |
| 940 h->value.len = r->header_end - r->header_start; | |
| 941 | |
| 942 h->key.data = ngx_pnalloc(r->pool, | |
| 943 h->key.len + 1 + h->value.len + 1 | |
| 944 + h->key.len); | |
| 945 if (h->key.data == NULL) { | |
| 946 return NGX_ERROR; | |
| 947 } | |
| 948 | |
| 949 h->value.data = h->key.data + h->key.len + 1; | |
| 950 h->lowcase_key = h->key.data + h->key.len + 1 + h->value.len + 1; | |
| 951 | |
|
4529
1ebec1d15a25
Fixed incorrect ngx_cpystrn() usage in ngx_http_*_process_header().
Maxim Dounin <mdounin@mdounin.ru>
parents:
4522
diff
changeset
|
952 ngx_memcpy(h->key.data, r->header_name_start, h->key.len); |
|
1ebec1d15a25
Fixed incorrect ngx_cpystrn() usage in ngx_http_*_process_header().
Maxim Dounin <mdounin@mdounin.ru>
parents:
4522
diff
changeset
|
953 h->key.data[h->key.len] = '\0'; |
|
1ebec1d15a25
Fixed incorrect ngx_cpystrn() usage in ngx_http_*_process_header().
Maxim Dounin <mdounin@mdounin.ru>
parents:
4522
diff
changeset
|
954 ngx_memcpy(h->value.data, r->header_start, h->value.len); |
|
1ebec1d15a25
Fixed incorrect ngx_cpystrn() usage in ngx_http_*_process_header().
Maxim Dounin <mdounin@mdounin.ru>
parents:
4522
diff
changeset
|
955 h->value.data[h->value.len] = '\0'; |
| 3637 | 956 |
| 957 if (h->key.len == r->lowcase_index) { | |
| 958 ngx_memcpy(h->lowcase_key, r->lowcase_header, h->key.len); | |
| 959 | |
| 960 } else { | |
| 961 ngx_strlow(h->lowcase_key, h->key.data, h->key.len); | |
| 962 } | |
| 963 | |
| 964 hh = ngx_hash_find(&umcf->headers_in_hash, h->hash, | |
| 965 h->lowcase_key, h->key.len); | |
| 966 | |
| 967 if (hh && hh->handler(r, h, hh->offset) != NGX_OK) { | |
| 968 return NGX_ERROR; | |
| 969 } | |
| 970 | |
| 971 ngx_log_debug2(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 972 "http scgi header: \"%V: %V\"", &h->key, &h->value); | |
| 973 | |
| 974 continue; | |
| 975 } | |
| 976 | |
| 977 if (rc == NGX_HTTP_PARSE_HEADER_DONE) { | |
| 978 | |
| 979 /* a whole header has been parsed successfully */ | |
| 980 | |
| 981 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 982 "http scgi header done"); | |
| 983 | |
|
4371
16ebad9447ee
Fixed incorrect use of r->http_version in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4331
diff
changeset
|
984 u = r->upstream; |
|
16ebad9447ee
Fixed incorrect use of r->http_version in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4331
diff
changeset
|
985 |
|
16ebad9447ee
Fixed incorrect use of r->http_version in scgi module.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4331
diff
changeset
|
986 if (u->headers_in.status_n) { |
|
5078
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
987 goto done; |
| 3637 | 988 } |
| 989 | |
| 990 if (u->headers_in.status) { | |
| 991 status_line = &u->headers_in.status->value; | |
| 992 | |
| 993 status = ngx_atoi(status_line->data, 3); | |
| 994 if (status == NGX_ERROR) { | |
| 995 ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, | |
| 996 "upstream sent invalid status \"%V\"", | |
| 997 status_line); | |
| 998 return NGX_HTTP_UPSTREAM_INVALID_HEADER; | |
| 999 } | |
| 1000 | |
| 1001 u->headers_in.status_n = status; | |
| 1002 u->headers_in.status_line = *status_line; | |
| 1003 | |
| 1004 } else if (u->headers_in.location) { | |
| 1005 u->headers_in.status_n = 302; | |
| 1006 ngx_str_set(&u->headers_in.status_line, | |
| 1007 "302 Moved Temporarily"); | |
| 1008 | |
| 1009 } else { | |
| 1010 u->headers_in.status_n = 200; | |
| 1011 ngx_str_set(&u->headers_in.status_line, "200 OK"); | |
| 1012 } | |
| 1013 | |
| 1014 if (u->state) { | |
| 1015 u->state->status = u->headers_in.status_n; | |
| 1016 } | |
| 1017 | |
|
5078
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1018 done: |
|
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1019 |
|
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1020 if (u->headers_in.status_n == NGX_HTTP_SWITCHING_PROTOCOLS |
|
5080
8da37c1b22a4
Trailing whitespace fix.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5078
diff
changeset
|
1021 && r->headers_in.upgrade) |
|
5078
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1022 { |
|
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1023 u->upgrade = 1; |
|
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1024 } |
|
10c74d3b15d1
Connection upgrade support in uwsgi and scgi modules.
Maxim Dounin <mdounin@mdounin.ru>
parents:
5008
diff
changeset
|
1025 |
| 3637 | 1026 return NGX_OK; |
| 1027 } | |
| 1028 | |
| 1029 if (rc == NGX_AGAIN) { | |
| 1030 return NGX_AGAIN; | |
| 1031 } | |
| 1032 | |
| 1033 /* there was error while a header line parsing */ | |
| 1034 | |
| 1035 ngx_log_error(NGX_LOG_ERR, r->connection->log, 0, | |
| 1036 "upstream sent invalid header"); | |
| 1037 | |
| 1038 return NGX_HTTP_UPSTREAM_INVALID_HEADER; | |
| 1039 } | |
| 1040 } | |
| 1041 | |
| 1042 | |
| 1043 static void | |
| 1044 ngx_http_scgi_abort_request(ngx_http_request_t *r) | |
| 1045 { | |
| 1046 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 1047 "abort http scgi request"); | |
| 1048 | |
| 1049 return; | |
| 1050 } | |
| 1051 | |
| 1052 | |
| 1053 static void | |
| 1054 ngx_http_scgi_finalize_request(ngx_http_request_t *r, ngx_int_t rc) | |
| 1055 { | |
| 1056 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 1057 "finalize http scgi request"); | |
| 1058 | |
| 1059 return; | |
| 1060 } | |
| 1061 | |
| 1062 | |
| 1063 static void * | |
| 1064 ngx_http_scgi_create_loc_conf(ngx_conf_t *cf) | |
| 1065 { | |
| 1066 ngx_http_scgi_loc_conf_t *conf; | |
| 1067 | |
| 1068 conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_scgi_loc_conf_t)); | |
| 1069 if (conf == NULL) { | |
| 1070 return NULL; | |
| 1071 } | |
| 1072 | |
| 1073 conf->upstream.store = NGX_CONF_UNSET; | |
| 1074 conf->upstream.store_access = NGX_CONF_UNSET_UINT; | |
| 1075 conf->upstream.buffering = NGX_CONF_UNSET; | |
| 1076 conf->upstream.ignore_client_abort = NGX_CONF_UNSET; | |
| 1077 | |
|
5008
fd84344f1df7
Fixed and improved the "*_bind" directives of proxying modules.
Ruslan Ermilov <ru@nginx.com>
parents:
4947
diff
changeset
|
1078 conf->upstream.local = NGX_CONF_UNSET_PTR; |
|
fd84344f1df7
Fixed and improved the "*_bind" directives of proxying modules.
Ruslan Ermilov <ru@nginx.com>
parents:
4947
diff
changeset
|
1079 |
| 3637 | 1080 conf->upstream.connect_timeout = NGX_CONF_UNSET_MSEC; |
| 1081 conf->upstream.send_timeout = NGX_CONF_UNSET_MSEC; | |
| 1082 conf->upstream.read_timeout = NGX_CONF_UNSET_MSEC; | |
| 1083 | |
| 1084 conf->upstream.send_lowat = NGX_CONF_UNSET_SIZE; | |
| 1085 conf->upstream.buffer_size = NGX_CONF_UNSET_SIZE; | |
| 1086 | |
| 1087 conf->upstream.busy_buffers_size_conf = NGX_CONF_UNSET_SIZE; | |
| 1088 conf->upstream.max_temp_file_size_conf = NGX_CONF_UNSET_SIZE; | |
| 1089 conf->upstream.temp_file_write_size_conf = NGX_CONF_UNSET_SIZE; | |
| 1090 | |
| 1091 conf->upstream.pass_request_headers = NGX_CONF_UNSET; | |
| 1092 conf->upstream.pass_request_body = NGX_CONF_UNSET; | |
| 1093 | |
| 1094 #if (NGX_HTTP_CACHE) | |
| 1095 conf->upstream.cache = NGX_CONF_UNSET_PTR; | |
| 1096 conf->upstream.cache_min_uses = NGX_CONF_UNSET_UINT; | |
|
3699
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
1097 conf->upstream.cache_bypass = NGX_CONF_UNSET_PTR; |
|
3693
e3bcc2f4c418
fix scgi_no_cache and uwsgi_no_cache initialization
Igor Sysoev <igor@sysoev.ru>
parents:
3692
diff
changeset
|
1098 conf->upstream.no_cache = NGX_CONF_UNSET_PTR; |
| 3637 | 1099 conf->upstream.cache_valid = NGX_CONF_UNSET_PTR; |
|
4386
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1100 conf->upstream.cache_lock = NGX_CONF_UNSET; |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1101 conf->upstream.cache_lock_timeout = NGX_CONF_UNSET_MSEC; |
| 3637 | 1102 #endif |
| 1103 | |
| 1104 conf->upstream.hide_headers = NGX_CONF_UNSET_PTR; | |
| 1105 conf->upstream.pass_headers = NGX_CONF_UNSET_PTR; | |
| 1106 | |
| 1107 conf->upstream.intercept_errors = NGX_CONF_UNSET; | |
| 1108 | |
| 1109 /* "scgi_cyclic_temp_file" is disabled */ | |
| 1110 conf->upstream.cyclic_temp_file = 0; | |
| 1111 | |
|
4157
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
1112 conf->upstream.change_buffering = 1; |
|
9d59a8eda373
Added uwsgi_buffering and scgi_buffering directives.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4015
diff
changeset
|
1113 |
|
3976
215fe9223419
update r3945 with more descriptive error message
Igor Sysoev <igor@sysoev.ru>
parents:
3879
diff
changeset
|
1114 ngx_str_set(&conf->upstream.module, "scgi"); |
|
215fe9223419
update r3945 with more descriptive error message
Igor Sysoev <igor@sysoev.ru>
parents:
3879
diff
changeset
|
1115 |
| 3637 | 1116 return conf; |
| 1117 } | |
| 1118 | |
| 1119 | |
| 1120 static char * | |
| 1121 ngx_http_scgi_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child) | |
| 1122 { | |
| 1123 ngx_http_scgi_loc_conf_t *prev = parent; | |
| 1124 ngx_http_scgi_loc_conf_t *conf = child; | |
| 1125 | |
| 1126 size_t size; | |
| 1127 ngx_hash_init_t hash; | |
|
3731
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1128 ngx_http_core_loc_conf_t *clcf; |
| 3637 | 1129 |
| 1130 if (conf->upstream.store != 0) { | |
| 1131 ngx_conf_merge_value(conf->upstream.store, prev->upstream.store, 0); | |
| 1132 | |
| 1133 if (conf->upstream.store_lengths == NULL) { | |
| 1134 conf->upstream.store_lengths = prev->upstream.store_lengths; | |
| 1135 conf->upstream.store_values = prev->upstream.store_values; | |
| 1136 } | |
| 1137 } | |
| 1138 | |
| 1139 ngx_conf_merge_uint_value(conf->upstream.store_access, | |
| 1140 prev->upstream.store_access, 0600); | |
| 1141 | |
| 1142 ngx_conf_merge_value(conf->upstream.buffering, | |
| 1143 prev->upstream.buffering, 1); | |
| 1144 | |
| 1145 ngx_conf_merge_value(conf->upstream.ignore_client_abort, | |
| 1146 prev->upstream.ignore_client_abort, 0); | |
| 1147 | |
|
5008
fd84344f1df7
Fixed and improved the "*_bind" directives of proxying modules.
Ruslan Ermilov <ru@nginx.com>
parents:
4947
diff
changeset
|
1148 ngx_conf_merge_ptr_value(conf->upstream.local, |
|
fd84344f1df7
Fixed and improved the "*_bind" directives of proxying modules.
Ruslan Ermilov <ru@nginx.com>
parents:
4947
diff
changeset
|
1149 prev->upstream.local, NULL); |
|
fd84344f1df7
Fixed and improved the "*_bind" directives of proxying modules.
Ruslan Ermilov <ru@nginx.com>
parents:
4947
diff
changeset
|
1150 |
| 3637 | 1151 ngx_conf_merge_msec_value(conf->upstream.connect_timeout, |
| 1152 prev->upstream.connect_timeout, 60000); | |
| 1153 | |
| 1154 ngx_conf_merge_msec_value(conf->upstream.send_timeout, | |
| 1155 prev->upstream.send_timeout, 60000); | |
| 1156 | |
| 1157 ngx_conf_merge_msec_value(conf->upstream.read_timeout, | |
| 1158 prev->upstream.read_timeout, 60000); | |
| 1159 | |
| 1160 ngx_conf_merge_size_value(conf->upstream.send_lowat, | |
| 1161 prev->upstream.send_lowat, 0); | |
| 1162 | |
| 1163 ngx_conf_merge_size_value(conf->upstream.buffer_size, | |
| 1164 prev->upstream.buffer_size, | |
| 1165 (size_t) ngx_pagesize); | |
| 1166 | |
| 1167 | |
| 1168 ngx_conf_merge_bufs_value(conf->upstream.bufs, prev->upstream.bufs, | |
| 1169 8, ngx_pagesize); | |
| 1170 | |
| 1171 if (conf->upstream.bufs.num < 2) { | |
| 1172 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | |
| 1173 "there must be at least 2 \"scgi_buffers\""); | |
| 1174 return NGX_CONF_ERROR; | |
| 1175 } | |
| 1176 | |
| 1177 | |
| 1178 size = conf->upstream.buffer_size; | |
| 1179 if (size < conf->upstream.bufs.size) { | |
| 1180 size = conf->upstream.bufs.size; | |
| 1181 } | |
| 1182 | |
| 1183 | |
| 1184 ngx_conf_merge_size_value(conf->upstream.busy_buffers_size_conf, | |
| 1185 prev->upstream.busy_buffers_size_conf, | |
| 1186 NGX_CONF_UNSET_SIZE); | |
| 1187 | |
| 1188 if (conf->upstream.busy_buffers_size_conf == NGX_CONF_UNSET_SIZE) { | |
| 1189 conf->upstream.busy_buffers_size = 2 * size; | |
| 1190 } else { | |
| 1191 conf->upstream.busy_buffers_size = | |
| 1192 conf->upstream.busy_buffers_size_conf; | |
| 1193 } | |
| 1194 | |
| 1195 if (conf->upstream.busy_buffers_size < size) { | |
| 1196 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | |
|
4593
834049edae24
Fixed grammar in error messages.
Ruslan Ermilov <ru@nginx.com>
parents:
4529
diff
changeset
|
1197 "\"scgi_busy_buffers_size\" must be equal to or greater " |
|
834049edae24
Fixed grammar in error messages.
Ruslan Ermilov <ru@nginx.com>
parents:
4529
diff
changeset
|
1198 "than the maximum of the value of \"scgi_buffer_size\" and " |
| 3637 | 1199 "one of the \"scgi_buffers\""); |
| 1200 | |
| 1201 return NGX_CONF_ERROR; | |
| 1202 } | |
| 1203 | |
| 1204 if (conf->upstream.busy_buffers_size | |
| 1205 > (conf->upstream.bufs.num - 1) * conf->upstream.bufs.size) | |
| 1206 { | |
| 1207 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | |
| 1208 "\"scgi_busy_buffers_size\" must be less than " | |
| 1209 "the size of all \"scgi_buffers\" minus one buffer"); | |
| 1210 | |
| 1211 return NGX_CONF_ERROR; | |
| 1212 } | |
| 1213 | |
| 1214 | |
| 1215 ngx_conf_merge_size_value(conf->upstream.temp_file_write_size_conf, | |
| 1216 prev->upstream.temp_file_write_size_conf, | |
| 1217 NGX_CONF_UNSET_SIZE); | |
| 1218 | |
| 1219 if (conf->upstream.temp_file_write_size_conf == NGX_CONF_UNSET_SIZE) { | |
| 1220 conf->upstream.temp_file_write_size = 2 * size; | |
| 1221 } else { | |
| 1222 conf->upstream.temp_file_write_size = | |
| 1223 conf->upstream.temp_file_write_size_conf; | |
| 1224 } | |
| 1225 | |
| 1226 if (conf->upstream.temp_file_write_size < size) { | |
| 1227 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | |
|
4593
834049edae24
Fixed grammar in error messages.
Ruslan Ermilov <ru@nginx.com>
parents:
4529
diff
changeset
|
1228 "\"scgi_temp_file_write_size\" must be equal to or greater than " |
|
834049edae24
Fixed grammar in error messages.
Ruslan Ermilov <ru@nginx.com>
parents:
4529
diff
changeset
|
1229 "the maximum of the value of \"scgi_buffer_size\" and " |
| 3637 | 1230 "one of the \"scgi_buffers\""); |
| 1231 | |
| 1232 return NGX_CONF_ERROR; | |
| 1233 } | |
| 1234 | |
| 1235 | |
| 1236 ngx_conf_merge_size_value(conf->upstream.max_temp_file_size_conf, | |
| 1237 prev->upstream.max_temp_file_size_conf, | |
| 1238 NGX_CONF_UNSET_SIZE); | |
| 1239 | |
| 1240 if (conf->upstream.max_temp_file_size_conf == NGX_CONF_UNSET_SIZE) { | |
| 1241 conf->upstream.max_temp_file_size = 1024 * 1024 * 1024; | |
| 1242 } else { | |
| 1243 conf->upstream.max_temp_file_size = | |
| 1244 conf->upstream.max_temp_file_size_conf; | |
| 1245 } | |
| 1246 | |
| 1247 if (conf->upstream.max_temp_file_size != 0 | |
| 1248 && conf->upstream.max_temp_file_size < size) { | |
| 1249 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | |
| 1250 "\"scgi_max_temp_file_size\" must be equal to zero to disable " | |
|
4593
834049edae24
Fixed grammar in error messages.
Ruslan Ermilov <ru@nginx.com>
parents:
4529
diff
changeset
|
1251 "temporary files usage or must be equal to or greater than " |
|
834049edae24
Fixed grammar in error messages.
Ruslan Ermilov <ru@nginx.com>
parents:
4529
diff
changeset
|
1252 "the maximum of the value of \"scgi_buffer_size\" and " |
| 3637 | 1253 "one of the \"scgi_buffers\""); |
| 1254 | |
| 1255 return NGX_CONF_ERROR; | |
| 1256 } | |
| 1257 | |
| 1258 | |
| 1259 ngx_conf_merge_bitmask_value(conf->upstream.ignore_headers, | |
| 1260 prev->upstream.ignore_headers, | |
| 1261 NGX_CONF_BITMASK_SET); | |
| 1262 | |
| 1263 | |
| 1264 ngx_conf_merge_bitmask_value(conf->upstream.next_upstream, | |
| 1265 prev->upstream.next_upstream, | |
| 1266 (NGX_CONF_BITMASK_SET | |
| 1267 |NGX_HTTP_UPSTREAM_FT_ERROR | |
| 1268 |NGX_HTTP_UPSTREAM_FT_TIMEOUT)); | |
| 1269 | |
| 1270 if (conf->upstream.next_upstream & NGX_HTTP_UPSTREAM_FT_OFF) { | |
| 1271 conf->upstream.next_upstream = NGX_CONF_BITMASK_SET | |
| 1272 |NGX_HTTP_UPSTREAM_FT_OFF; | |
| 1273 } | |
| 1274 | |
| 1275 if (ngx_conf_merge_path_value(cf, &conf->upstream.temp_path, | |
| 1276 prev->upstream.temp_path, | |
| 1277 &ngx_http_scgi_temp_path) | |
| 1278 != NGX_OK) | |
| 1279 { | |
| 1280 return NGX_CONF_ERROR; | |
| 1281 } | |
| 1282 | |
| 1283 #if (NGX_HTTP_CACHE) | |
| 1284 | |
| 1285 ngx_conf_merge_ptr_value(conf->upstream.cache, | |
| 1286 prev->upstream.cache, NULL); | |
| 1287 | |
| 1288 if (conf->upstream.cache && conf->upstream.cache->data == NULL) { | |
| 1289 ngx_shm_zone_t *shm_zone; | |
| 1290 | |
| 1291 shm_zone = conf->upstream.cache; | |
| 1292 | |
| 1293 ngx_conf_log_error(NGX_LOG_EMERG, cf, 0, | |
| 1294 "\"scgi_cache\" zone \"%V\" is unknown", | |
| 1295 &shm_zone->shm.name); | |
| 1296 | |
| 1297 return NGX_CONF_ERROR; | |
| 1298 } | |
| 1299 | |
| 1300 ngx_conf_merge_uint_value(conf->upstream.cache_min_uses, | |
| 1301 prev->upstream.cache_min_uses, 1); | |
| 1302 | |
| 1303 ngx_conf_merge_bitmask_value(conf->upstream.cache_use_stale, | |
| 1304 prev->upstream.cache_use_stale, | |
| 1305 (NGX_CONF_BITMASK_SET | |
| 1306 |NGX_HTTP_UPSTREAM_FT_OFF)); | |
| 1307 | |
| 1308 if (conf->upstream.cache_use_stale & NGX_HTTP_UPSTREAM_FT_OFF) { | |
| 1309 conf->upstream.cache_use_stale = NGX_CONF_BITMASK_SET | |
| 1310 |NGX_HTTP_UPSTREAM_FT_OFF; | |
| 1311 } | |
| 1312 | |
|
4401
d45742815c90
Fixed proxy_cache_use_stale in "no live upstreams" case.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4386
diff
changeset
|
1313 if (conf->upstream.cache_use_stale & NGX_HTTP_UPSTREAM_FT_ERROR) { |
|
d45742815c90
Fixed proxy_cache_use_stale in "no live upstreams" case.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4386
diff
changeset
|
1314 conf->upstream.cache_use_stale |= NGX_HTTP_UPSTREAM_FT_NOLIVE; |
|
d45742815c90
Fixed proxy_cache_use_stale in "no live upstreams" case.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4386
diff
changeset
|
1315 } |
|
d45742815c90
Fixed proxy_cache_use_stale in "no live upstreams" case.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4386
diff
changeset
|
1316 |
| 3637 | 1317 if (conf->upstream.cache_methods == 0) { |
| 1318 conf->upstream.cache_methods = prev->upstream.cache_methods; | |
| 1319 } | |
| 1320 | |
| 1321 conf->upstream.cache_methods |= NGX_HTTP_GET|NGX_HTTP_HEAD; | |
| 1322 | |
|
3699
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
1323 ngx_conf_merge_ptr_value(conf->upstream.cache_bypass, |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
1324 prev->upstream.cache_bypass, NULL); |
|
b0a0686a85bb
proxy_cache_pass, fastcgi_cache_bypass, uwsgi_cache_bypass, scgi_cache_bypass
Igor Sysoev <igor@sysoev.ru>
parents:
3693
diff
changeset
|
1325 |
| 3637 | 1326 ngx_conf_merge_ptr_value(conf->upstream.no_cache, |
| 1327 prev->upstream.no_cache, NULL); | |
| 1328 | |
| 1329 ngx_conf_merge_ptr_value(conf->upstream.cache_valid, | |
| 1330 prev->upstream.cache_valid, NULL); | |
| 1331 | |
| 1332 if (conf->cache_key.value.data == NULL) { | |
| 1333 conf->cache_key = prev->cache_key; | |
| 1334 } | |
| 1335 | |
|
4386
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1336 ngx_conf_merge_value(conf->upstream.cache_lock, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1337 prev->upstream.cache_lock, 0); |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1338 |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1339 ngx_conf_merge_msec_value(conf->upstream.cache_lock_timeout, |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1340 prev->upstream.cache_lock_timeout, 5000); |
|
92deb73393f7
Cache lock support for fastcgi, scgi, uwsgi.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4373
diff
changeset
|
1341 |
| 3637 | 1342 #endif |
| 1343 | |
| 1344 ngx_conf_merge_value(conf->upstream.pass_request_headers, | |
| 1345 prev->upstream.pass_request_headers, 1); | |
| 1346 ngx_conf_merge_value(conf->upstream.pass_request_body, | |
| 1347 prev->upstream.pass_request_body, 1); | |
| 1348 | |
| 1349 ngx_conf_merge_value(conf->upstream.intercept_errors, | |
| 1350 prev->upstream.intercept_errors, 0); | |
| 1351 | |
| 1352 hash.max_size = 512; | |
| 1353 hash.bucket_size = ngx_align(64, ngx_cacheline_size); | |
| 1354 hash.name = "scgi_hide_headers_hash"; | |
| 1355 | |
| 1356 if (ngx_http_upstream_hide_headers_hash(cf, &conf->upstream, | |
|
3670
2728c4e4a9ae
do not use a cache headers set to hide
Igor Sysoev <igor@sysoev.ru>
parents:
3668
diff
changeset
|
1357 &prev->upstream, ngx_http_scgi_hide_headers, &hash) |
| 3637 | 1358 != NGX_OK) |
| 1359 { | |
| 1360 return NGX_CONF_ERROR; | |
| 1361 } | |
| 1362 | |
| 1363 if (conf->upstream.upstream == NULL) { | |
| 1364 conf->upstream.upstream = prev->upstream.upstream; | |
| 1365 } | |
| 1366 | |
| 1367 if (conf->scgi_lengths == NULL) { | |
| 1368 conf->scgi_lengths = prev->scgi_lengths; | |
| 1369 conf->scgi_values = prev->scgi_values; | |
| 1370 } | |
| 1371 | |
|
3731
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1372 if (conf->upstream.upstream || conf->scgi_lengths) { |
|
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1373 clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module); |
|
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1374 if (clcf->handler == NULL && clcf->lmt_excpt) { |
|
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1375 clcf->handler = ngx_http_scgi_handler; |
|
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1376 } |
|
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1377 } |
|
72cc5b789021
inherit proxy_pass, fastcgi_pass, uwsgi_pass, scgi_pass inside
Igor Sysoev <igor@sysoev.ru>
parents:
3729
diff
changeset
|
1378 |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1379 if (ngx_http_scgi_merge_params(cf, conf, prev) != NGX_OK) { |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1380 return NGX_CONF_ERROR; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1381 } |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1382 |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1383 return NGX_CONF_OK; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1384 } |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1385 |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1386 |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1387 static ngx_int_t |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1388 ngx_http_scgi_merge_params(ngx_conf_t *cf, ngx_http_scgi_loc_conf_t *conf, |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1389 ngx_http_scgi_loc_conf_t *prev) |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1390 { |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1391 u_char *p; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1392 size_t size; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1393 uintptr_t *code; |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1394 ngx_uint_t i, nsrc; |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1395 ngx_array_t headers_names; |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1396 #if (NGX_HTTP_CACHE) |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1397 ngx_array_t params_merged; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1398 #endif |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1399 ngx_hash_key_t *hk; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1400 ngx_hash_init_t hash; |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1401 ngx_http_upstream_param_t *src; |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1402 ngx_http_script_compile_t sc; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1403 ngx_http_script_copy_code_t *copy; |
|
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1404 |
| 3637 | 1405 if (conf->params_source == NULL) { |
| 1406 conf->params_source = prev->params_source; | |
| 1407 | |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1408 if (prev->headers_hash.buckets |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1409 #if (NGX_HTTP_CACHE) |
| 4522 | 1410 && ((conf->upstream.cache == NULL) |
| 1411 == (prev->upstream.cache == NULL)) | |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1412 #endif |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1413 ) |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1414 { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1415 conf->flushes = prev->flushes; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1416 conf->params_len = prev->params_len; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1417 conf->params = prev->params; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1418 conf->headers_hash = prev->headers_hash; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1419 conf->header_params = prev->header_params; |
| 3637 | 1420 |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1421 return NGX_OK; |
| 3637 | 1422 } |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1423 } |
| 3637 | 1424 |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1425 if (conf->params_source == NULL |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1426 #if (NGX_HTTP_CACHE) |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1427 && (conf->upstream.cache == NULL) |
| 3637 | 1428 #endif |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1429 ) |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1430 { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1431 conf->headers_hash.buckets = (void *) 1; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1432 return NGX_OK; |
| 3637 | 1433 } |
| 1434 | |
| 1435 conf->params_len = ngx_array_create(cf->pool, 64, 1); | |
| 1436 if (conf->params_len == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1437 return NGX_ERROR; |
| 3637 | 1438 } |
| 1439 | |
| 1440 conf->params = ngx_array_create(cf->pool, 512, 1); | |
| 1441 if (conf->params == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1442 return NGX_ERROR; |
| 3637 | 1443 } |
| 1444 | |
| 1445 if (ngx_array_init(&headers_names, cf->temp_pool, 4, sizeof(ngx_hash_key_t)) | |
| 1446 != NGX_OK) | |
| 1447 { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1448 return NGX_ERROR; |
| 3637 | 1449 } |
| 1450 | |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1451 if (conf->params_source) { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1452 src = conf->params_source->elts; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1453 nsrc = conf->params_source->nelts; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1454 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1455 } else { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1456 src = NULL; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1457 nsrc = 0; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1458 } |
| 3637 | 1459 |
| 1460 #if (NGX_HTTP_CACHE) | |
| 1461 | |
| 1462 if (conf->upstream.cache) { | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1463 ngx_keyval_t *h; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1464 ngx_http_upstream_param_t *s; |
| 3637 | 1465 |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1466 if (ngx_array_init(¶ms_merged, cf->temp_pool, 4, |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1467 sizeof(ngx_http_upstream_param_t)) |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1468 != NGX_OK) |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1469 { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1470 return NGX_ERROR; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1471 } |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1472 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1473 for (i = 0; i < nsrc; i++) { |
| 3637 | 1474 |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1475 s = ngx_array_push(¶ms_merged); |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1476 if (s == NULL) { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1477 return NGX_ERROR; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1478 } |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1479 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1480 *s = src[i]; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1481 } |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1482 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1483 h = ngx_http_scgi_cache_headers; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1484 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1485 while (h->key.len) { |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1486 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1487 src = params_merged.elts; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1488 nsrc = params_merged.nelts; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1489 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1490 for (i = 0; i < nsrc; i++) { |
| 3637 | 1491 if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) { |
| 1492 goto next; | |
| 1493 } | |
| 1494 } | |
| 1495 | |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1496 s = ngx_array_push(¶ms_merged); |
| 3637 | 1497 if (s == NULL) { |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1498 return NGX_ERROR; |
| 3637 | 1499 } |
| 1500 | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1501 s->key = h->key; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1502 s->value = h->value; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1503 s->skip_empty = 0; |
| 3637 | 1504 |
| 1505 next: | |
| 1506 | |
| 1507 h++; | |
| 1508 } | |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1509 |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1510 src = params_merged.elts; |
|
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1511 nsrc = params_merged.nelts; |
| 3637 | 1512 } |
| 1513 | |
| 1514 #endif | |
| 1515 | |
|
4278
f57229cba7ad
Fixed fastcgi/scgi/uwsgi_param inheritance.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4277
diff
changeset
|
1516 for (i = 0; i < nsrc; i++) { |
| 3637 | 1517 |
| 1518 if (src[i].key.len > sizeof("HTTP_") - 1 | |
| 1519 && ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0) | |
| 1520 { | |
| 1521 hk = ngx_array_push(&headers_names); | |
| 1522 if (hk == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1523 return NGX_ERROR; |
| 3637 | 1524 } |
| 1525 | |
| 1526 hk->key.len = src[i].key.len - 5; | |
| 1527 hk->key.data = src[i].key.data + 5; | |
| 1528 hk->key_hash = ngx_hash_key_lc(hk->key.data, hk->key.len); | |
| 1529 hk->value = (void *) 1; | |
| 1530 | |
| 1531 if (src[i].value.len == 0) { | |
| 1532 continue; | |
| 1533 } | |
| 1534 } | |
| 1535 | |
| 1536 copy = ngx_array_push_n(conf->params_len, | |
| 1537 sizeof(ngx_http_script_copy_code_t)); | |
| 1538 if (copy == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1539 return NGX_ERROR; |
| 3637 | 1540 } |
| 1541 | |
| 1542 copy->code = (ngx_http_script_code_pt) ngx_http_script_copy_len_code; | |
| 1543 copy->len = src[i].key.len + 1; | |
| 1544 | |
|
4331
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1545 copy = ngx_array_push_n(conf->params_len, |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1546 sizeof(ngx_http_script_copy_code_t)); |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1547 if (copy == NULL) { |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1548 return NGX_ERROR; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1549 } |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1550 |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1551 copy->code = (ngx_http_script_code_pt) ngx_http_script_copy_len_code; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1552 copy->len = src[i].skip_empty; |
|
059260de158d
SCGI: added "if_not_empty" flag support to the "scgi_param" directive.
Valentin Bartenev <vbart@nginx.com>
parents:
4294
diff
changeset
|
1553 |
| 3637 | 1554 |
| 1555 size = (sizeof(ngx_http_script_copy_code_t) | |
| 1556 + src[i].key.len + 1 + sizeof(uintptr_t) - 1) | |
| 1557 & ~(sizeof(uintptr_t) - 1); | |
| 1558 | |
| 1559 copy = ngx_array_push_n(conf->params, size); | |
| 1560 if (copy == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1561 return NGX_ERROR; |
| 3637 | 1562 } |
| 1563 | |
| 1564 copy->code = ngx_http_script_copy_code; | |
| 1565 copy->len = src[i].key.len + 1; | |
| 1566 | |
| 1567 p = (u_char *) copy + sizeof(ngx_http_script_copy_code_t); | |
| 1568 (void) ngx_cpystrn(p, src[i].key.data, src[i].key.len + 1); | |
| 1569 | |
| 1570 | |
| 1571 ngx_memzero(&sc, sizeof(ngx_http_script_compile_t)); | |
| 1572 | |
| 1573 sc.cf = cf; | |
| 1574 sc.source = &src[i].value; | |
| 1575 sc.flushes = &conf->flushes; | |
| 1576 sc.lengths = &conf->params_len; | |
| 1577 sc.values = &conf->params; | |
| 1578 | |
| 1579 if (ngx_http_script_compile(&sc) != NGX_OK) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1580 return NGX_ERROR; |
| 3637 | 1581 } |
| 1582 | |
| 1583 code = ngx_array_push_n(conf->params_len, sizeof(uintptr_t)); | |
| 1584 if (code == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1585 return NGX_ERROR; |
| 3637 | 1586 } |
| 1587 | |
| 1588 *code = (uintptr_t) NULL; | |
| 1589 | |
| 1590 | |
| 1591 code = ngx_array_push_n(conf->params, sizeof(uintptr_t)); | |
| 1592 if (code == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1593 return NGX_ERROR; |
| 3637 | 1594 } |
| 1595 | |
| 1596 *code = (uintptr_t) NULL; | |
| 1597 } | |
| 1598 | |
| 1599 code = ngx_array_push_n(conf->params_len, sizeof(uintptr_t)); | |
| 1600 if (code == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1601 return NGX_ERROR; |
| 3637 | 1602 } |
| 1603 | |
| 1604 *code = (uintptr_t) NULL; | |
| 1605 | |
| 1606 code = ngx_array_push_n(conf->params, sizeof(uintptr_t)); | |
| 1607 if (code == NULL) { | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1608 return NGX_ERROR; |
| 3637 | 1609 } |
| 1610 | |
| 1611 *code = (uintptr_t) NULL; | |
| 1612 | |
| 1613 conf->header_params = headers_names.nelts; | |
| 1614 | |
| 1615 hash.hash = &conf->headers_hash; | |
| 1616 hash.key = ngx_hash_key_lc; | |
| 1617 hash.max_size = 512; | |
| 1618 hash.bucket_size = 64; | |
| 1619 hash.name = "scgi_params_hash"; | |
| 1620 hash.pool = cf->pool; | |
| 1621 hash.temp_pool = NULL; | |
| 1622 | |
|
4277
e4b8255e44c3
Separate functions to merge fastcgi/scgi/uwsgi params.
Maxim Dounin <mdounin@mdounin.ru>
parents:
4157
diff
changeset
|
1623 return ngx_hash_init(&hash, headers_names.elts, headers_names.nelts); |
| 3637 | 1624 } |
| 1625 | |
| 1626 | |
| 1627 static char * | |
| 1628 ngx_http_scgi_pass(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) | |
| 1629 { | |
| 1630 ngx_http_scgi_loc_conf_t *scf = conf; | |
| 1631 | |
| 1632 ngx_url_t u; | |
| 1633 ngx_str_t *value, *url; | |
| 1634 ngx_uint_t n; | |
| 1635 ngx_http_core_loc_conf_t *clcf; | |
| 1636 ngx_http_script_compile_t sc; | |
| 1637 | |
| 1638 if (scf->upstream.upstream || scf->scgi_lengths) { | |
| 1639 return "is duplicate"; | |
| 1640 } | |
| 1641 | |
| 1642 clcf = ngx_http_conf_get_module_loc_conf (cf, ngx_http_core_module); | |
| 1643 clcf->handler = ngx_http_scgi_handler; | |
| 1644 | |
| 1645 value = cf->args->elts; | |
| 1646 | |
| 1647 url = &value[1]; | |
| 1648 | |
| 1649 n = ngx_http_script_variables_count(url); | |
| 1650 | |
| 1651 if (n) { | |
| 1652 | |
| 1653 ngx_memzero(&sc, sizeof(ngx_http_script_compile_t)); | |
| 1654 | |
| 1655 sc.cf = cf; | |
| 1656 sc.source = url; | |
| 1657 sc.lengths = &scf->scgi_lengths; | |
| 1658 sc.values = &scf->scgi_values; | |
| 1659 sc.variables = n; | |
| 1660 sc.complete_lengths = 1; | |
| 1661 sc.complete_values = 1; | |
| 1662 | |
| 1663 if (ngx_http_script_compile(&sc) != NGX_OK) { | |
| 1664 return NGX_CONF_ERROR; | |
| 1665 } | |
| 1666 | |
| 1667 return NGX_CONF_OK; | |
| 1668 } | |
| 1669 | |
| 1670 ngx_memzero(&u, sizeof(ngx_url_t)); | |
| 1671 | |
| 1672 u.url = value[1]; | |
| 1673 u.no_resolve = 1; | |
| 1674 | |
| 1675 scf->upstream.upstream = ngx_http_upstream_add(cf, &u, 0); | |
| 1676 if (scf->upstream.upstream == NULL) { | |
| 1677 return NGX_CONF_ERROR; | |
| 1678 } | |
| 1679 | |
| 1680 if (clcf->name.data[clcf->name.len - 1] == '/') { | |
| 1681 clcf->auto_redirect = 1; | |
| 1682 } | |
| 1683 | |
| 1684 return NGX_CONF_OK; | |
| 1685 } | |
| 1686 | |
| 1687 | |
| 1688 static char * | |
| 1689 ngx_http_scgi_store(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) | |
| 1690 { | |
| 1691 ngx_http_scgi_loc_conf_t *scf = conf; | |
| 1692 | |
| 1693 ngx_str_t *value; | |
| 1694 ngx_http_script_compile_t sc; | |
| 1695 | |
| 1696 if (scf->upstream.store != NGX_CONF_UNSET || scf->upstream.store_lengths) { | |
| 1697 return "is duplicate"; | |
| 1698 } | |
| 1699 | |
| 1700 value = cf->args->elts; | |
| 1701 | |
| 1702 if (ngx_strcmp(value[1].data, "off") == 0) { | |
| 1703 scf->upstream.store = 0; | |
| 1704 return NGX_CONF_OK; | |
| 1705 } | |
| 1706 | |
| 1707 #if (NGX_HTTP_CACHE) | |
| 1708 | |
| 1709 if (scf->upstream.cache != NGX_CONF_UNSET_PTR | |
| 1710 && scf->upstream.cache != NULL) | |
| 1711 { | |
| 1712 return "is incompatible with \"scgi_cache\""; | |
| 1713 } | |
| 1714 | |
| 1715 #endif | |
| 1716 | |
| 1717 if (ngx_strcmp(value[1].data, "on") == 0) { | |
| 1718 scf->upstream.store = 1; | |
| 1719 return NGX_CONF_OK; | |
| 1720 } | |
| 1721 | |
| 1722 /* include the terminating '\0' into script */ | |
| 1723 value[1].len++; | |
| 1724 | |
| 1725 ngx_memzero(&sc, sizeof(ngx_http_script_compile_t)); | |
| 1726 | |
| 1727 sc.cf = cf; | |
| 1728 sc.source = &value[1]; | |
| 1729 sc.lengths = &scf->upstream.store_lengths; | |
| 1730 sc.values = &scf->upstream.store_values; | |
| 1731 sc.variables = ngx_http_script_variables_count(&value[1]);; | |
| 1732 sc.complete_lengths = 1; | |
| 1733 sc.complete_values = 1; | |
| 1734 | |
| 1735 if (ngx_http_script_compile(&sc) != NGX_OK) { | |
| 1736 return NGX_CONF_ERROR; | |
| 1737 } | |
| 1738 | |
| 1739 return NGX_CONF_OK; | |
| 1740 } | |
| 1741 | |
| 1742 | |
| 1743 #if (NGX_HTTP_CACHE) | |
| 1744 | |
| 1745 static char * | |
| 1746 ngx_http_scgi_cache(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) | |
| 1747 { | |
| 1748 ngx_http_scgi_loc_conf_t *scf = conf; | |
| 1749 | |
| 1750 ngx_str_t *value; | |
| 1751 | |
| 1752 value = cf->args->elts; | |
| 1753 | |
| 1754 if (scf->upstream.cache != NGX_CONF_UNSET_PTR) { | |
| 1755 return "is duplicate"; | |
| 1756 } | |
| 1757 | |
| 1758 if (ngx_strcmp(value[1].data, "off") == 0) { | |
| 1759 scf->upstream.cache = NULL; | |
| 1760 return NGX_CONF_OK; | |
| 1761 } | |
| 1762 | |
| 1763 if (scf->upstream.store > 0 || scf->upstream.store_lengths) { | |
| 1764 return "is incompatible with \"scgi_store\""; | |
| 1765 } | |
| 1766 | |
| 1767 scf->upstream.cache = ngx_shared_memory_add(cf, &value[1], 0, | |
| 1768 &ngx_http_scgi_module); | |
| 1769 if (scf->upstream.cache == NULL) { | |
| 1770 return NGX_CONF_ERROR; | |
| 1771 } | |
| 1772 | |
| 1773 return NGX_CONF_OK; | |
| 1774 } | |
| 1775 | |
| 1776 | |
| 1777 static char * | |
| 1778 ngx_http_scgi_cache_key(ngx_conf_t *cf, ngx_command_t *cmd, void *conf) | |
| 1779 { | |
| 1780 ngx_http_scgi_loc_conf_t *scf = conf; | |
| 1781 | |
| 1782 ngx_str_t *value; | |
| 1783 ngx_http_compile_complex_value_t ccv; | |
| 1784 | |
| 1785 value = cf->args->elts; | |
| 1786 | |
|
4947
4251e72b8bb4
Allow the complex value to be defined as an empty string.
Ruslan Ermilov <ru@nginx.com>
parents:
4929
diff
changeset
|
1787 if (scf->cache_key.value.data) { |
| 3637 | 1788 return "is duplicate"; |
| 1789 } | |
| 1790 | |
| 1791 ngx_memzero(&ccv, sizeof(ngx_http_compile_complex_value_t)); | |
| 1792 | |
| 1793 ccv.cf = cf; | |
| 1794 ccv.value = &value[1]; | |
| 1795 ccv.complex_value = &scf->cache_key; | |
| 1796 | |
| 1797 if (ngx_http_compile_complex_value(&ccv) != NGX_OK) { | |
| 1798 return NGX_CONF_ERROR; | |
| 1799 } | |
| 1800 | |
| 1801 return NGX_CONF_OK; | |
| 1802 } | |
| 1803 | |
| 1804 #endif |