mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2024-12-05 06:19:01 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

move ranges array to ngx_http_range_filter_ctx_t

Browse Source
This commit is contained in:
Igor Sysoev 2006-12-29 08:02:31 +00:00
parent 6fd25e105c
commit e974a72404
2 changed files with 32 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
src/http/modules/ngx_http_range_filter_module.c
View File

@ -45,8 +45,16 @@
typedef struct { typedef struct {
off_t offset; off_t start;
ngx_str_t boundary_header; off_t end;
ngx_str_t content_range;
} ngx_http_range_t;
typedef struct {
off_t offset;
ngx_str_t boundary_header;
ngx_array_t ranges;
} ngx_http_range_filter_ctx_t; } ngx_http_range_filter_ctx_t;
@ -160,8 +168,12 @@ ngx_http_range_header_filter(ngx_http_request_t *r)
return ngx_http_next_header_filter(r); return ngx_http_next_header_filter(r);
} }
if (ngx_array_init(&r->headers_out.ranges, r->pool, 2, ctx = ngx_pcalloc(r->pool, sizeof(ngx_http_range_filter_ctx_t));
sizeof(ngx_http_range_t)) if (ctx == NULL) {
return NGX_ERROR;
}
if (ngx_array_init(&ctx->ranges, r->pool, 1, sizeof(ngx_http_range_t))
== NGX_ERROR) == NGX_ERROR)
{ {
return NGX_ERROR; return NGX_ERROR;
@ -203,7 +215,7 @@ ngx_http_range_header_filter(ngx_http_request_t *r)
while (*p == ' ') { p++; } while (*p == ' ') { p++; }
if (*p == ',' || *p == '\0') { if (*p == ',' || *p == '\0') {
range = ngx_array_push(&r->headers_out.ranges); range = ngx_array_push(&ctx->ranges);
if (range == NULL) { if (range == NULL) {
return NGX_ERROR; return NGX_ERROR;
} }
@ -249,7 +261,7 @@ ngx_http_range_header_filter(ngx_http_request_t *r)
break; break;
} }
range = ngx_array_push(&r->headers_out.ranges); range = ngx_array_push(&ctx->ranges);
if (range == NULL) { if (range == NULL) {
return NGX_ERROR; return NGX_ERROR;
} }
@ -277,7 +289,6 @@ ngx_http_range_header_filter(ngx_http_request_t *r)
/* rc == NGX_HTTP_RANGE_NOT_SATISFIABLE */ /* rc == NGX_HTTP_RANGE_NOT_SATISFIABLE */
r->headers_out.status = rc; r->headers_out.status = rc;
r->headers_out.ranges.nelts = 0;
content_range = ngx_list_push(&r->headers_out.headers); content_range = ngx_list_push(&r->headers_out.headers);
if (content_range == NULL) { if (content_range == NULL) {
@ -306,18 +317,11 @@ ngx_http_range_header_filter(ngx_http_request_t *r)
return rc; return rc;
} }
ctx = ngx_pcalloc(r->pool, sizeof(ngx_http_range_filter_ctx_t));
if (ctx == NULL) {
return NGX_ERROR;
}
ngx_http_set_ctx(r, ctx, ngx_http_range_body_filter_module); ngx_http_set_ctx(r, ctx, ngx_http_range_body_filter_module);
r->headers_out.status = NGX_HTTP_PARTIAL_CONTENT; r->headers_out.status = NGX_HTTP_PARTIAL_CONTENT;
if (r->headers_out.ranges.nelts == 1) { if (ctx->ranges.nelts == 1) {
content_range = ngx_list_push(&r->headers_out.headers); content_range = ngx_list_push(&r->headers_out.headers);
if (content_range == NULL) { if (content_range == NULL) {
@ -425,8 +429,8 @@ ngx_http_range_header_filter(ngx_http_request_t *r)
len = sizeof(CRLF "--") - 1 + NGX_ATOMIC_T_LEN + sizeof("--" CRLF) - 1; len = sizeof(CRLF "--") - 1 + NGX_ATOMIC_T_LEN + sizeof("--" CRLF) - 1;
range = r->headers_out.ranges.elts; range = ctx->ranges.elts;
for (i = 0; i < r->headers_out.ranges.nelts; i++) { for (i = 0; i < ctx->ranges.nelts; i++) {
/* the size of the range: "SSSS-EEEE/TTTT" CRLF CRLF */ /* the size of the range: "SSSS-EEEE/TTTT" CRLF CRLF */
@ -468,7 +472,13 @@ ngx_http_range_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
ngx_http_range_t *range; ngx_http_range_t *range;
ngx_http_range_filter_ctx_t *ctx; ngx_http_range_filter_ctx_t *ctx;
if (in == NULL || r->headers_out.ranges.nelts == 0) { if (in == NULL) {
return ngx_http_next_body_filter(r, in);
}
ctx = ngx_http_get_module_ctx(r, ngx_http_range_body_filter_module);
if (ctx == NULL) {
return ngx_http_next_body_filter(r, in); return ngx_http_next_body_filter(r, in);
} }
@ -478,12 +488,11 @@ ngx_http_range_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
return ngx_http_next_body_filter(r, in); return ngx_http_next_body_filter(r, in);
} }
ctx = ngx_http_get_module_ctx(r, ngx_http_range_body_filter_module);
if (ctx->offset) { if (ctx->offset) {
goto overlapped; goto overlapped;
} }
range = r->headers_out.ranges.elts; range = ctx->ranges.elts;
if (!buf->last_buf) { if (!buf->last_buf) {
@ -496,7 +505,7 @@ ngx_http_range_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
last = buf->last - buf->start + ctx->offset; last = buf->last - buf->start + ctx->offset;
} }
for (i = 0; i < r->headers_out.ranges.nelts; i++) { for (i = 0; i < ctx->ranges.nelts; i++) {
if (start > range[i].start || last < range[i].end) { if (start > range[i].start || last < range[i].end) {
goto overlapped; goto overlapped;
} }
@ -510,7 +519,7 @@ ngx_http_range_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
ctx->offset = ngx_buf_size(buf); ctx->offset = ngx_buf_size(buf);
if (r->headers_out.ranges.nelts == 1) { if (ctx->ranges.nelts == 1) {
if (buf->in_file) { if (buf->in_file) {
buf->file_pos = range->start; buf->file_pos = range->start;
@ -527,7 +536,7 @@ ngx_http_range_body_filter(ngx_http_request_t *r, ngx_chain_t *in)
ll = &out; ll = &out;
for (i = 0; i < r->headers_out.ranges.nelts; i++) { for (i = 0; i < ctx->ranges.nelts; i++) {
/* /*
* The boundary header of the range: * The boundary header of the range:

8
src/http/ngx_http_request.h
View File

@ -214,13 +214,6 @@ typedef struct {
} ngx_http_headers_in_t; } ngx_http_headers_in_t;
typedef struct {
off_t start;
off_t end;
ngx_str_t content_range;
} ngx_http_range_t;
typedef struct { typedef struct {
ngx_list_t headers; ngx_list_t headers;
@ -245,7 +238,6 @@ typedef struct {
ngx_str_t content_type; ngx_str_t content_type;
ngx_str_t charset; ngx_str_t charset;
ngx_array_t ranges;
ngx_array_t cache_control; ngx_array_t cache_control;
off_t content_length_n; off_t content_length_n;