Fijxu/nginx-quic
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Fixed fastcgi/scgi/uwsgi_param inheritance.

Browse source 
The following problems were fixed:

1. Directive fastcgi_cache affected headers sent to backends in unrelated
   servers / locations (see ticket #45).

2. If-Unmodified-Since, If-Match and If-Range headers were sent to backends
   if fastcgi_cache was used.

3. Cache-related headers were sent to backends if there were no fastcgi_param
   directives and fastcgi_cache was used at server level.
This commit is contained in:
Maxim Dounin 2011-11-14 13:26:18 +00:00
parent f5cb08dc33
commit a60f482c6b
3 changed files with 174 additions and 90 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

88
src/http/modules/ngx_http_fastcgi_module.c
View file

@ -2365,8 +2365,11 @@ ngx_http_fastcgi_merge_params(ngx_conf_t *cf,
u_char *p; u_char *p;
size_t size; size_t size;
uintptr_t *code; uintptr_t *code;
ngx_uint_t i; ngx_uint_t i, nsrc;
ngx_array_t headers_names; ngx_array_t headers_names;
#if (NGX_HTTP_CACHE)
ngx_array_t params_merged;
#endif
ngx_keyval_t *src; ngx_keyval_t *src;
ngx_hash_key_t *hk; ngx_hash_key_t *hk;
ngx_hash_init_t hash; ngx_hash_init_t hash;
@ -2374,36 +2377,32 @@ ngx_http_fastcgi_merge_params(ngx_conf_t *cf,
ngx_http_script_copy_code_t *copy; ngx_http_script_copy_code_t *copy;
if (conf->params_source == NULL) { if (conf->params_source == NULL) {
conf->params_source = prev->params_source;
if (prev->headers_hash.buckets
#if (NGX_HTTP_CACHE)
&& ((conf->upstream.cache == NULL) == (prev->upstream.cache == NULL))
#endif
)
{
conf->flushes = prev->flushes; conf->flushes = prev->flushes;
conf->params_len = prev->params_len; conf->params_len = prev->params_len;
conf->params = prev->params; conf->params = prev->params;
conf->params_source = prev->params_source;
conf->headers_hash = prev->headers_hash; conf->headers_hash = prev->headers_hash;
conf->header_params = prev->header_params;
return NGX_OK;
}
}
if (conf->params_source == NULL
#if (NGX_HTTP_CACHE) #if (NGX_HTTP_CACHE)
&& (conf->upstream.cache == NULL)
if (conf->params_source == NULL) {
if ((conf->upstream.cache == NULL)
== (prev->upstream.cache == NULL))
{
return NGX_OK;
}
/* 6 is a number of ngx_http_fastcgi_cache_headers entries */
conf->params_source = ngx_array_create(cf->pool, 6,
sizeof(ngx_keyval_t));
if (conf->params_source == NULL) {
return NGX_ERROR;
}
}
#else
if (conf->params_source == NULL) {
return NGX_OK;
}
#endif #endif
)
{
conf->headers_hash.buckets = (void *) 1;
return NGX_OK;
} }
conf->params_len = ngx_array_create(cf->pool, 64, 1); conf->params_len = ngx_array_create(cf->pool, 64, 1);
@ -2422,39 +2421,68 @@ ngx_http_fastcgi_merge_params(ngx_conf_t *cf,
return NGX_ERROR; return NGX_ERROR;
} }
if (conf->params_source) {
src = conf->params_source->elts; src = conf->params_source->elts;
nsrc = conf->params_source->nelts;
} else {
src = NULL;
nsrc = 0;
}
#if (NGX_HTTP_CACHE) #if (NGX_HTTP_CACHE)
if (conf->upstream.cache) { if (conf->upstream.cache) {
ngx_keyval_t *h, *s; ngx_keyval_t *h, *s;
for (h = ngx_http_fastcgi_cache_headers; h->key.len; h++) { if (ngx_array_init(&params_merged, cf->temp_pool, 4, sizeof(ngx_keyval_t))
!= NGX_OK)
{
return NGX_ERROR;
}
for (i = 0; i < conf->params_source->nelts; i++) { for (i = 0; i < nsrc; i++) {
s = ngx_array_push(&params_merged);
if (s == NULL) {
return NGX_ERROR;
}
*s = src[i];
}
h = ngx_http_fastcgi_cache_headers;
while (h->key.len) {
src = params_merged.elts;
nsrc = params_merged.nelts;
for (i = 0; i < nsrc; i++) {
if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) { if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) {
goto next; goto next;
} }
} }
s = ngx_array_push(conf->params_source); s = ngx_array_push(&params_merged);
if (s == NULL) { if (s == NULL) {
return NGX_ERROR; return NGX_ERROR;
} }
*s = *h; *s = *h;
src = conf->params_source->elts;
next: next:
h++; h++;
} }
src = params_merged.elts;
nsrc = params_merged.nelts;
} }
#endif #endif
for (i = 0; i < conf->params_source->nelts; i++) { for (i = 0; i < nsrc; i++) {
if (src[i].key.len > sizeof("HTTP_") - 1 if (src[i].key.len > sizeof("HTTP_") - 1
&& ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0) && ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0)

88
src/http/modules/ngx_http_scgi_module.c
View file

@ -1316,8 +1316,11 @@ ngx_http_scgi_merge_params(ngx_conf_t *cf, ngx_http_scgi_loc_conf_t *conf,
u_char *p; u_char *p;
size_t size; size_t size;
uintptr_t *code; uintptr_t *code;
ngx_uint_t i; ngx_uint_t i, nsrc;
ngx_array_t headers_names; ngx_array_t headers_names;
#if (NGX_HTTP_CACHE)
ngx_array_t params_merged;
#endif
ngx_keyval_t *src; ngx_keyval_t *src;
ngx_hash_key_t *hk; ngx_hash_key_t *hk;
ngx_hash_init_t hash; ngx_hash_init_t hash;
@ -1325,36 +1328,32 @@ ngx_http_scgi_merge_params(ngx_conf_t *cf, ngx_http_scgi_loc_conf_t *conf,
ngx_http_script_copy_code_t *copy; ngx_http_script_copy_code_t *copy;
if (conf->params_source == NULL) { if (conf->params_source == NULL) {
conf->params_source = prev->params_source;
if (prev->headers_hash.buckets
#if (NGX_HTTP_CACHE)
&& ((conf->upstream.cache == NULL) == (prev->upstream.cache == NULL))
#endif
)
{
conf->flushes = prev->flushes; conf->flushes = prev->flushes;
conf->params_len = prev->params_len; conf->params_len = prev->params_len;
conf->params = prev->params; conf->params = prev->params;
conf->params_source = prev->params_source;
conf->headers_hash = prev->headers_hash; conf->headers_hash = prev->headers_hash;
conf->header_params = prev->header_params;
return NGX_OK;
}
}
if (conf->params_source == NULL
#if (NGX_HTTP_CACHE) #if (NGX_HTTP_CACHE)
&& (conf->upstream.cache == NULL)
if (conf->params_source == NULL) {
if ((conf->upstream.cache == NULL)
== (prev->upstream.cache == NULL))
{
return NGX_OK;
}
/* 6 is a number of ngx_http_scgi_cache_headers entries */
conf->params_source = ngx_array_create(cf->pool, 6,
sizeof(ngx_keyval_t));
if (conf->params_source == NULL) {
return NGX_ERROR;
}
}
#else
if (conf->params_source == NULL) {
return NGX_OK;
}
#endif #endif
)
{
conf->headers_hash.buckets = (void *) 1;
return NGX_OK;
} }
conf->params_len = ngx_array_create(cf->pool, 64, 1); conf->params_len = ngx_array_create(cf->pool, 64, 1);
@ -1373,39 +1372,68 @@ ngx_http_scgi_merge_params(ngx_conf_t *cf, ngx_http_scgi_loc_conf_t *conf,
return NGX_ERROR; return NGX_ERROR;
} }
if (conf->params_source) {
src = conf->params_source->elts; src = conf->params_source->elts;
nsrc = conf->params_source->nelts;
} else {
src = NULL;
nsrc = 0;
}
#if (NGX_HTTP_CACHE) #if (NGX_HTTP_CACHE)
if (conf->upstream.cache) { if (conf->upstream.cache) {
ngx_keyval_t *h, *s; ngx_keyval_t *h, *s;
for (h = ngx_http_scgi_cache_headers; h->key.len; h++) { if (ngx_array_init(&params_merged, cf->temp_pool, 4, sizeof(ngx_keyval_t))
!= NGX_OK)
{
return NGX_ERROR;
}
for (i = 0; i < conf->params_source->nelts; i++) { for (i = 0; i < nsrc; i++) {
s = ngx_array_push(&params_merged);
if (s == NULL) {
return NGX_ERROR;
}
*s = src[i];
}
h = ngx_http_scgi_cache_headers;
while (h->key.len) {
src = params_merged.elts;
nsrc = params_merged.nelts;
for (i = 0; i < nsrc; i++) {
if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) { if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) {
goto next; goto next;
} }
} }
s = ngx_array_push(conf->params_source); s = ngx_array_push(&params_merged);
if (s == NULL) { if (s == NULL) {
return NGX_ERROR; return NGX_ERROR;
} }
*s = *h; *s = *h;
src = conf->params_source->elts;
next: next:
h++; h++;
} }
src = params_merged.elts;
nsrc = params_merged.nelts;
} }
#endif #endif
for (i = 0; i < conf->params_source->nelts; i++) { for (i = 0; i < nsrc; i++) {
if (src[i].key.len > sizeof("HTTP_") - 1 if (src[i].key.len > sizeof("HTTP_") - 1
&& ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0) && ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0)

88
src/http/modules/ngx_http_uwsgi_module.c
View file

@ -1374,8 +1374,11 @@ ngx_http_uwsgi_merge_params(ngx_conf_t *cf, ngx_http_uwsgi_loc_conf_t *conf,
u_char *p; u_char *p;
size_t size; size_t size;
uintptr_t *code; uintptr_t *code;
ngx_uint_t i; ngx_uint_t i, nsrc;
ngx_array_t headers_names; ngx_array_t headers_names;
#if (NGX_HTTP_CACHE)
ngx_array_t params_merged;
#endif
ngx_keyval_t *src; ngx_keyval_t *src;
ngx_hash_key_t *hk; ngx_hash_key_t *hk;
ngx_hash_init_t hash; ngx_hash_init_t hash;
@ -1383,36 +1386,32 @@ ngx_http_uwsgi_merge_params(ngx_conf_t *cf, ngx_http_uwsgi_loc_conf_t *conf,
ngx_http_script_copy_code_t *copy; ngx_http_script_copy_code_t *copy;
if (conf->params_source == NULL) { if (conf->params_source == NULL) {
conf->params_source = prev->params_source;
if (prev->headers_hash.buckets
#if (NGX_HTTP_CACHE)
&& ((conf->upstream.cache == NULL) == (prev->upstream.cache == NULL))
#endif
)
{
conf->flushes = prev->flushes; conf->flushes = prev->flushes;
conf->params_len = prev->params_len; conf->params_len = prev->params_len;
conf->params = prev->params; conf->params = prev->params;
conf->params_source = prev->params_source;
conf->headers_hash = prev->headers_hash; conf->headers_hash = prev->headers_hash;
conf->header_params = prev->header_params;
return NGX_OK;
}
}
if (conf->params_source == NULL
#if (NGX_HTTP_CACHE) #if (NGX_HTTP_CACHE)
&& (conf->upstream.cache == NULL)
if (conf->params_source == NULL) {
if ((conf->upstream.cache == NULL)
== (prev->upstream.cache == NULL))
{
return NGX_OK;
}
/* 6 is a number of ngx_http_uwsgi_cache_headers entries */
conf->params_source = ngx_array_create(cf->pool, 6,
sizeof(ngx_keyval_t));
if (conf->params_source == NULL) {
return NGX_ERROR;
}
}
#else
if (conf->params_source == NULL) {
return NGX_OK;
}
#endif #endif
)
{
conf->headers_hash.buckets = (void *) 1;
return NGX_OK;
} }
conf->params_len = ngx_array_create(cf->pool, 64, 1); conf->params_len = ngx_array_create(cf->pool, 64, 1);
@ -1431,39 +1430,68 @@ ngx_http_uwsgi_merge_params(ngx_conf_t *cf, ngx_http_uwsgi_loc_conf_t *conf,
return NGX_ERROR; return NGX_ERROR;
} }
if (conf->params_source) {
src = conf->params_source->elts; src = conf->params_source->elts;
nsrc = conf->params_source->nelts;
} else {
src = NULL;
nsrc = 0;
}
#if (NGX_HTTP_CACHE) #if (NGX_HTTP_CACHE)
if (conf->upstream.cache) { if (conf->upstream.cache) {
ngx_keyval_t *h, *s; ngx_keyval_t *h, *s;
for (h = ngx_http_uwsgi_cache_headers; h->key.len; h++) { if (ngx_array_init(&params_merged, cf->temp_pool, 4, sizeof(ngx_keyval_t))
!= NGX_OK)
{
return NGX_ERROR;
}
for (i = 0; i < conf->params_source->nelts; i++) { for (i = 0; i < nsrc; i++) {
s = ngx_array_push(&params_merged);
if (s == NULL) {
return NGX_ERROR;
}
*s = src[i];
}
h = ngx_http_uwsgi_cache_headers;
while (h->key.len) {
src = params_merged.elts;
nsrc = params_merged.nelts;
for (i = 0; i < nsrc; i++) {
if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) { if (ngx_strcasecmp(h->key.data, src[i].key.data) == 0) {
goto next; goto next;
} }
} }
s = ngx_array_push(conf->params_source); s = ngx_array_push(&params_merged);
if (s == NULL) { if (s == NULL) {
return NGX_ERROR; return NGX_ERROR;
} }
*s = *h; *s = *h;
src = conf->params_source->elts;
next: next:
h++; h++;
} }
src = params_merged.elts;
nsrc = params_merged.nelts;
} }
#endif #endif
for (i = 0; i < conf->params_source->nelts; i++) { for (i = 0; i < nsrc; i++) {
if (src[i].key.len > sizeof("HTTP_") - 1 if (src[i].key.len > sizeof("HTTP_") - 1
&& ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0) && ngx_strncmp(src[i].key.data, "HTTP_", sizeof("HTTP_") - 1) == 0)