Mercurial > hg > nginx
annotate src/http/ngx_http_request_body.c @ 1072:f303d33f3927
delete temporary file for incomplete small request body
| author | Igor Sysoev <igor@sysoev.ru> |
|---|---|
| date | Tue, 23 Jan 2007 12:55:23 +0000 |
| parents | 9039e845e532 |
| children | 4d203f76b757 |
| rev | line source |
|---|---|
|
441
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
1 |
|
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
2 /* |
|
444
42d11f017717
nginx-0.1.0-2004-09-29-20:00:49 import; remove years from copyright
Igor Sysoev <igor@sysoev.ru>
parents:
441
diff
changeset
|
3 * Copyright (C) Igor Sysoev |
|
441
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
4 */ |
|
da8c5707af39
nginx-0.1.0-2004-09-28-12:34:51 import; set copyright and remove unused files
Igor Sysoev <igor@sysoev.ru>
parents:
396
diff
changeset
|
5 |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
6 |
|
83
a7e45c45a95c
nginx-0.0.1-2003-04-28-19:06:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
82
diff
changeset
|
7 #include <ngx_config.h> |
|
a7e45c45a95c
nginx-0.0.1-2003-04-28-19:06:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
82
diff
changeset
|
8 #include <ngx_core.h> |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
9 #include <ngx_event.h> |
|
83
a7e45c45a95c
nginx-0.0.1-2003-04-28-19:06:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
82
diff
changeset
|
10 #include <ngx_http.h> |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
11 |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
12 |
| 509 | 13 static void ngx_http_read_client_request_body_handler(ngx_http_request_t *r); |
| 14 static ngx_int_t ngx_http_do_read_client_request_body(ngx_http_request_t *r); | |
| 633 | 15 static ngx_int_t ngx_http_write_request_body(ngx_http_request_t *r, |
| 16 ngx_chain_t *body); | |
| 17 static void ngx_http_finalize_request_body(ngx_http_request_t *r, ngx_int_t rc); | |
| 18 static void ngx_http_read_discarded_body_handler(ngx_http_request_t *r); | |
| 19 static ngx_int_t ngx_http_read_discarded_body(ngx_http_request_t *r); | |
| 20 | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
21 |
| 479 | 22 /* |
| 23 * on completion ngx_http_read_client_request_body() adds to | |
| 24 * r->request_body->bufs one or two bufs: | |
| 25 * *) one memory buf that was preread in r->header_in; | |
| 26 * *) one memory or file buf that contains the rest of the body | |
| 27 */ | |
|
83
a7e45c45a95c
nginx-0.0.1-2003-04-28-19:06:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
82
diff
changeset
|
28 |
| 501 | 29 ngx_int_t |
| 30 ngx_http_read_client_request_body(ngx_http_request_t *r, | |
| 31 ngx_http_client_body_handler_pt post_handler) | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
32 { |
| 663 | 33 size_t preread; |
| 34 ssize_t size; | |
|
1072
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
35 ngx_int_t rc; |
|
343
6bdf858bff8c
nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
36 ngx_buf_t *b; |
| 633 | 37 ngx_chain_t *cl, **next; |
|
725
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
38 ngx_temp_file_t *tf; |
| 479 | 39 ngx_http_request_body_t *rb; |
|
303
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
299
diff
changeset
|
40 ngx_http_core_loc_conf_t *clcf; |
|
297
ee394e997c77
nginx-0.0.3-2004-03-29-21:43:58 import
Igor Sysoev <igor@sysoev.ru>
parents:
296
diff
changeset
|
41 |
| 537 | 42 if (r->request_body || r->discard_body) { |
| 509 | 43 post_handler(r); |
| 44 return NGX_OK; | |
| 45 } | |
| 46 | |
| 501 | 47 rb = ngx_pcalloc(r->pool, sizeof(ngx_http_request_body_t)); |
| 48 if (rb == NULL) { | |
| 479 | 49 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 50 } | |
| 51 | |
| 52 r->request_body = rb; | |
| 53 | |
|
725
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
54 if (r->headers_in.content_length_n < 0) { |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
55 post_handler(r); |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
56 return NGX_OK; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
57 } |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
58 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
59 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
60 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
61 if (r->headers_in.content_length_n == 0) { |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
62 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
63 if (r->request_body_in_file_only) { |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
64 tf = ngx_pcalloc(r->pool, sizeof(ngx_temp_file_t)); |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
65 if (tf == NULL) { |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
66 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
67 } |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
68 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
69 tf->file.fd = NGX_INVALID_FILE; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
70 tf->file.log = r->connection->log; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
71 tf->path = clcf->client_body_temp_path; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
72 tf->pool = r->pool; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
73 tf->warn = "a client request body is buffered to a temporary file"; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
74 tf->log_level = r->request_body_file_log_level; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
75 tf->persistent = r->request_body_in_persistent_file; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
76 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
77 if (r->request_body_file_group_access) { |
| 1046 | 78 tf->access = 0660; |
|
725
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
79 } |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
80 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
81 rb->temp_file = tf; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
82 |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
83 if (ngx_create_temp_file(&tf->file, tf->path, tf->pool, |
| 1046 | 84 tf->persistent, tf->access) |
|
725
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
85 != NGX_OK) |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
86 { |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
87 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
88 } |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
89 } |
|
86862ad988da
fix segfault when zero length file is PUT
Igor Sysoev <igor@sysoev.ru>
parents:
681
diff
changeset
|
90 |
| 479 | 91 post_handler(r); |
| 92 return NGX_OK; | |
| 93 } | |
| 94 | |
| 95 rb->post_handler = post_handler; | |
| 96 | |
| 97 /* | |
| 98 * set by ngx_pcalloc(): | |
| 99 * | |
| 100 * rb->bufs = NULL; | |
| 101 * rb->buf = NULL; | |
| 102 * rb->rest = 0; | |
| 103 */ | |
| 104 | |
| 633 | 105 preread = r->header_in->last - r->header_in->pos; |
|
83
a7e45c45a95c
nginx-0.0.1-2003-04-28-19:06:39 import
Igor Sysoev <igor@sysoev.ru>
parents:
82
diff
changeset
|
106 |
| 633 | 107 if (preread) { |
|
296
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
108 |
|
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
109 /* there is the pre-read part of the request body */ |
|
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
110 |
| 633 | 111 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, |
| 112 "http client request body preread %uz", preread); | |
| 113 | |
| 501 | 114 b = ngx_calloc_buf(r->pool); |
| 115 if (b == NULL) { | |
| 479 | 116 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 117 } | |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
118 |
|
343
6bdf858bff8c
nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
119 b->temporary = 1; |
| 633 | 120 b->start = r->header_in->pos; |
| 121 b->pos = r->header_in->pos; | |
| 122 b->last = r->header_in->last; | |
| 123 b->end = r->header_in->end; | |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
124 |
| 501 | 125 rb->bufs = ngx_alloc_chain_link(r->pool); |
| 126 if (rb->bufs == NULL) { | |
| 479 | 127 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 128 } | |
| 129 | |
| 130 rb->bufs->buf = b; | |
| 131 rb->bufs->next = NULL; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
132 |
| 667 | 133 rb->buf = b; |
| 134 | |
| 665 | 135 if ((off_t) preread >= r->headers_in.content_length_n) { |
|
296
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
136 |
|
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
137 /* the whole request body was pre-read */ |
|
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
138 |
| 663 | 139 r->header_in->pos += (size_t) r->headers_in.content_length_n; |
| 475 | 140 r->request_length += r->headers_in.content_length_n; |
|
299
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
141 |
| 633 | 142 if (r->request_body_in_file_only) { |
| 143 if (ngx_http_write_request_body(r, rb->bufs) != NGX_OK) { | |
| 144 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 145 } | |
| 146 } | |
| 147 | |
| 479 | 148 post_handler(r); |
|
299
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
149 |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
150 return NGX_OK; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
151 } |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
152 |
| 633 | 153 /* |
| 154 * to not consider the body as pipelined request in | |
| 155 * ngx_http_set_keepalive() | |
| 156 */ | |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
157 r->header_in->pos = r->header_in->last; |
| 633 | 158 |
| 159 r->request_length += preread; | |
| 160 | |
| 161 rb->rest = r->headers_in.content_length_n - preread; | |
| 162 | |
| 665 | 163 if (rb->rest <= (off_t) (b->end - b->last)) { |
| 633 | 164 |
| 165 /* the whole request body may be placed in r->header_in */ | |
| 166 | |
|
1065
9039e845e532
fix segfault when a request body fits in r->header_in and
Igor Sysoev <igor@sysoev.ru>
parents:
1046
diff
changeset
|
167 rb->to_write = rb->bufs; |
|
9039e845e532
fix segfault when a request body fits in r->header_in and
Igor Sysoev <igor@sysoev.ru>
parents:
1046
diff
changeset
|
168 |
| 633 | 169 r->read_event_handler = ngx_http_read_client_request_body_handler; |
| 170 | |
|
1072
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
171 rc = ngx_http_do_read_client_request_body(r); |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
172 |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
173 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
174 ngx_http_finalize_request_body(r, rc); |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
175 return NGX_DONE; |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
176 } |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
177 |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
178 return rc; |
| 633 | 179 } |
| 180 | |
| 181 next = &rb->bufs->next; | |
| 182 | |
| 183 } else { | |
| 184 b = NULL; | |
| 185 rb->rest = r->headers_in.content_length_n; | |
| 186 next = &rb->bufs; | |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
187 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
188 |
| 633 | 189 size = clcf->client_body_buffer_size; |
| 190 size += size >> 2; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
191 |
| 663 | 192 if (rb->rest < size) { |
| 193 size = (ssize_t) rb->rest; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
194 |
| 633 | 195 if (r->request_body_in_single_buf) { |
| 196 size += preread; | |
| 197 } | |
| 198 | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
199 } else { |
|
303
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
299
diff
changeset
|
200 size = clcf->client_body_buffer_size; |
| 633 | 201 |
| 202 /* disable copying buffer for r->request_body_in_single_buf */ | |
| 203 b = NULL; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
204 } |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
205 |
| 501 | 206 rb->buf = ngx_create_temp_buf(r->pool, size); |
| 207 if (rb->buf == NULL) { | |
| 479 | 208 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 209 } | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
210 |
| 501 | 211 cl = ngx_alloc_chain_link(r->pool); |
| 212 if (cl == NULL) { | |
| 479 | 213 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 214 } | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
215 |
| 479 | 216 cl->buf = rb->buf; |
| 217 cl->next = NULL; | |
| 218 | |
| 633 | 219 if (b && r->request_body_in_single_buf) { |
| 220 size = b->last - b->pos; | |
| 221 ngx_memcpy(rb->buf->pos, b->pos, size); | |
| 222 rb->buf->last += size; | |
| 223 | |
| 224 next = &rb->bufs; | |
| 225 } | |
| 226 | |
| 227 *next = cl; | |
| 228 | |
| 229 if (r->request_body_in_file_only || r->request_body_in_single_buf) { | |
| 230 rb->to_write = rb->bufs; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
231 |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
232 } else { |
| 633 | 233 rb->to_write = rb->bufs->next ? rb->bufs->next : rb->bufs; |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
234 } |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
235 |
| 509 | 236 r->read_event_handler = ngx_http_read_client_request_body_handler; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
237 |
|
1072
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
238 rc = ngx_http_do_read_client_request_body(r); |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
239 |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
240 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
241 ngx_http_finalize_request_body(r, rc); |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
242 return NGX_DONE; |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
243 } |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
244 |
|
f303d33f3927
delete temporary file for incomplete small request body
Igor Sysoev <igor@sysoev.ru>
parents:
1065
diff
changeset
|
245 return rc; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
246 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
247 |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
248 |
| 501 | 249 static void |
| 509 | 250 ngx_http_read_client_request_body_handler(ngx_http_request_t *r) |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
251 { |
| 509 | 252 ngx_int_t rc; |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
253 |
| 509 | 254 if (r->connection->read->timedout) { |
| 577 | 255 r->connection->timedout = 1; |
| 633 | 256 ngx_http_finalize_request_body(r, NGX_HTTP_REQUEST_TIME_OUT); |
|
299
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
257 return; |
|
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
258 } |
|
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
259 |
| 509 | 260 rc = ngx_http_do_read_client_request_body(r); |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
261 |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
262 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { |
| 633 | 263 ngx_http_finalize_request_body(r, rc); |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
264 } |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
265 } |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
266 |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
267 |
| 501 | 268 static ngx_int_t |
| 509 | 269 ngx_http_do_read_client_request_body(ngx_http_request_t *r) |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
270 { |
|
290
87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
171
diff
changeset
|
271 size_t size; |
|
87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
171
diff
changeset
|
272 ssize_t n; |
|
343
6bdf858bff8c
nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
273 ngx_buf_t *b; |
| 509 | 274 ngx_connection_t *c; |
| 479 | 275 ngx_http_request_body_t *rb; |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
276 ngx_http_core_loc_conf_t *clcf; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
277 |
| 509 | 278 c = r->connection; |
| 479 | 279 rb = r->request_body; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
280 |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
281 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
282 "http read client request body"); |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
283 |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
284 for ( ;; ) { |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
285 for ( ;; ) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
286 if (rb->buf->last == rb->buf->end) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
287 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
288 if (ngx_http_write_request_body(r, rb->to_write) != NGX_OK) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
289 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
290 } |
| 479 | 291 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
292 rb->to_write = rb->bufs->next ? rb->bufs->next : rb->bufs; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
293 rb->buf->last = rb->buf->start; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
294 } |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
295 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
296 size = rb->buf->end - rb->buf->last; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
297 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
298 if ((off_t) size > rb->rest) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
299 size = (size_t) rb->rest; |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
300 } |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
301 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
302 n = c->recv(c, rb->buf->last, size); |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
303 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
304 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
305 "http client request body recv %z", n); |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
306 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
307 if (n == NGX_AGAIN) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
308 break; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
309 } |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
310 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
311 if (n == 0) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
312 ngx_log_error(NGX_LOG_INFO, c->log, 0, |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
313 "client closed prematurely connection"); |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
314 } |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
315 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
316 if (n == 0 || n == NGX_ERROR) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
317 c->error = 1; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
318 return NGX_HTTP_BAD_REQUEST; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
319 } |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
320 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
321 rb->buf->last += n; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
322 rb->rest -= n; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
323 r->request_length += n; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
324 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
325 if (rb->rest == 0) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
326 break; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
327 } |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
328 |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
329 if (rb->buf->last < rb->buf->end) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
330 break; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
331 } |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
332 } |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
333 |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
334 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
335 "http client request body rest %uz", rb->rest); |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
336 |
| 479 | 337 if (rb->rest == 0) { |
|
294
5cfd65b8b0a7
nginx-0.0.3-2004-03-23-09:01:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
293
diff
changeset
|
338 break; |
|
5cfd65b8b0a7
nginx-0.0.3-2004-03-23-09:01:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
293
diff
changeset
|
339 } |
|
5cfd65b8b0a7
nginx-0.0.3-2004-03-23-09:01:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
293
diff
changeset
|
340 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
341 if (!c->read->ready) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
342 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
343 ngx_add_timer(c->read, clcf->client_body_timeout); |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
344 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
345 if (ngx_handle_read_event(c->read, 0) == NGX_ERROR) { |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
346 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
347 } |
| 573 | 348 |
|
841
790ed4eb762e
fix big client body receiving with deferred accept()
Igor Sysoev <igor@sysoev.ru>
parents:
725
diff
changeset
|
349 return NGX_AGAIN; |
| 573 | 350 } |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
351 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
352 |
| 573 | 353 if (c->read->timer_set) { |
| 354 ngx_del_timer(c->read); | |
| 355 } | |
| 356 | |
| 633 | 357 if (rb->temp_file || r->request_body_in_file_only) { |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
358 |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
359 /* save the last part */ |
| 479 | 360 |
| 633 | 361 if (ngx_http_write_request_body(r, rb->to_write) != NGX_OK) { |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
362 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
363 } |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
364 |
| 501 | 365 b = ngx_calloc_buf(r->pool); |
| 366 if (b == NULL) { | |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
367 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
368 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
369 |
|
343
6bdf858bff8c
nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
370 b->in_file = 1; |
|
6bdf858bff8c
nginx-0.0.3-2004-05-28-19:49:23 import; rename ngx_hunk_t to ngx_buf_t
Igor Sysoev <igor@sysoev.ru>
parents:
303
diff
changeset
|
371 b->file_pos = 0; |
| 479 | 372 b->file_last = rb->temp_file->file.offset; |
| 373 b->file = &rb->temp_file->file; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
374 |
| 479 | 375 if (rb->bufs->next) { |
| 376 rb->bufs->next->buf = b; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
377 |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
378 } else { |
| 479 | 379 rb->bufs->buf = b; |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
380 } |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
381 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
382 |
| 633 | 383 if (r->request_body_in_file_only && rb->bufs->next) { |
| 384 rb->bufs = rb->bufs->next; | |
| 385 } | |
| 386 | |
| 479 | 387 rb->post_handler(r); |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
388 |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
389 return NGX_OK; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
390 } |
| 633 | 391 |
| 392 | |
| 393 static ngx_int_t | |
| 394 ngx_http_write_request_body(ngx_http_request_t *r, ngx_chain_t *body) | |
| 395 { | |
| 396 ssize_t n; | |
| 397 ngx_temp_file_t *tf; | |
| 398 ngx_http_request_body_t *rb; | |
| 399 ngx_http_core_loc_conf_t *clcf; | |
| 400 | |
| 401 rb = r->request_body; | |
| 402 | |
| 403 if (rb->temp_file == NULL) { | |
| 404 tf = ngx_pcalloc(r->pool, sizeof(ngx_temp_file_t)); | |
| 405 if (tf == NULL) { | |
| 406 return NGX_ERROR; | |
| 407 } | |
| 408 | |
| 409 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); | |
| 410 | |
| 411 tf->file.fd = NGX_INVALID_FILE; | |
| 412 tf->file.log = r->connection->log; | |
| 413 tf->path = clcf->client_body_temp_path; | |
| 414 tf->pool = r->pool; | |
| 415 tf->warn = "a client request body is buffered to a temporary file"; | |
| 637 | 416 tf->log_level = r->request_body_file_log_level; |
| 633 | 417 tf->persistent = r->request_body_in_persistent_file; |
| 418 | |
| 419 if (r->request_body_file_group_access) { | |
| 1046 | 420 tf->access = 0660; |
| 633 | 421 } |
| 422 | |
| 423 rb->temp_file = tf; | |
| 424 } | |
| 425 | |
| 426 n = ngx_write_chain_to_temp_file(rb->temp_file, body); | |
| 427 | |
| 428 /* TODO: n == 0 or not complete and level event */ | |
| 429 | |
| 430 if (n == NGX_ERROR) { | |
| 431 return NGX_ERROR; | |
| 432 } | |
| 433 | |
| 434 rb->temp_file->offset += n; | |
| 435 | |
| 436 return NGX_OK; | |
| 437 } | |
| 438 | |
| 439 | |
| 440 static void | |
| 441 ngx_http_finalize_request_body(ngx_http_request_t *r, ngx_int_t rc) | |
| 442 { | |
| 443 if (r->request_body->temp_file | |
| 444 && r->request_body_in_persistent_file | |
| 445 && r->request_body_delete_incomplete_file) | |
| 446 { | |
| 447 if (ngx_delete_file(r->request_body->temp_file->file.name.data) | |
| 448 == NGX_FILE_ERROR) | |
| 449 { | |
| 450 ngx_log_error(NGX_LOG_CRIT, r->connection->log, ngx_errno, | |
| 451 ngx_delete_file_n " \"%s\" failed", | |
| 452 r->request_body->temp_file->file.name.data); | |
| 453 } | |
| 454 } | |
| 455 | |
| 456 ngx_http_finalize_request(r, rc); | |
| 457 } | |
| 458 | |
| 459 | |
| 460 ngx_int_t | |
| 461 ngx_http_discard_body(ngx_http_request_t *r) | |
| 462 { | |
| 463 ssize_t size; | |
| 464 ngx_event_t *rev; | |
| 465 | |
| 673 | 466 if (r != r->main || r->discard_body) { |
| 633 | 467 return NGX_OK; |
| 468 } | |
| 469 | |
| 470 rev = r->connection->read; | |
| 471 | |
| 472 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "http set discard body"); | |
| 473 | |
| 474 if (rev->timer_set) { | |
| 475 ngx_del_timer(rev); | |
| 476 } | |
| 477 | |
| 681 | 478 r->discard_body = 1; |
| 479 | |
| 633 | 480 if (r->headers_in.content_length_n <= 0) { |
| 481 return NGX_OK; | |
| 482 } | |
| 483 | |
| 484 size = r->header_in->last - r->header_in->pos; | |
| 485 | |
| 486 if (size) { | |
| 487 if (r->headers_in.content_length_n > size) { | |
| 488 r->headers_in.content_length_n -= size; | |
| 489 | |
| 490 } else { | |
| 663 | 491 r->header_in->pos += (size_t) r->headers_in.content_length_n; |
| 633 | 492 r->headers_in.content_length_n = 0; |
| 493 return NGX_OK; | |
| 494 } | |
| 495 } | |
| 496 | |
| 497 r->read_event_handler = ngx_http_read_discarded_body_handler; | |
| 498 | |
| 499 if (ngx_handle_read_event(rev, 0) == NGX_ERROR) { | |
| 500 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 501 } | |
| 502 | |
| 503 return ngx_http_read_discarded_body(r); | |
| 504 } | |
| 505 | |
| 506 | |
| 507 static void | |
| 508 ngx_http_read_discarded_body_handler(ngx_http_request_t *r) | |
| 509 { | |
| 510 ngx_int_t rc; | |
| 511 | |
| 512 rc = ngx_http_read_discarded_body(r); | |
| 513 | |
| 514 if (rc == NGX_AGAIN) { | |
| 515 if (ngx_handle_read_event(r->connection->read, 0) == NGX_ERROR) { | |
| 516 ngx_http_finalize_request(r, rc); | |
| 517 return; | |
| 518 } | |
| 519 } | |
| 520 | |
| 521 if (rc != NGX_OK) { | |
| 522 ngx_http_finalize_request(r, rc); | |
| 523 } | |
| 524 } | |
| 525 | |
| 526 | |
| 527 static ngx_int_t | |
| 528 ngx_http_read_discarded_body(ngx_http_request_t *r) | |
| 529 { | |
| 663 | 530 size_t size; |
| 531 ssize_t n; | |
| 633 | 532 u_char buffer[NGX_HTTP_DISCARD_BUFFER_SIZE]; |
| 533 | |
| 534 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 535 "http read discarded body"); | |
| 536 | |
| 537 if (r->headers_in.content_length_n == 0) { | |
| 538 return NGX_OK; | |
| 539 } | |
| 540 | |
| 663 | 541 size = (r->headers_in.content_length_n > NGX_HTTP_DISCARD_BUFFER_SIZE) ? |
| 542 NGX_HTTP_DISCARD_BUFFER_SIZE: | |
| 543 (size_t) r->headers_in.content_length_n; | |
| 633 | 544 |
| 545 n = r->connection->recv(r->connection, buffer, size); | |
| 546 | |
| 547 if (n == NGX_ERROR) { | |
| 548 | |
| 549 r->connection->error = 1; | |
| 550 | |
| 551 /* | |
| 552 * if a client request body is discarded then we already set | |
| 553 * some HTTP response code for client and we can ignore the error | |
| 554 */ | |
| 555 | |
| 556 return NGX_OK; | |
| 557 } | |
| 558 | |
| 559 if (n == NGX_AGAIN) { | |
| 560 return NGX_AGAIN; | |
| 561 } | |
| 562 | |
| 563 r->headers_in.content_length_n -= n; | |
| 564 | |
| 565 return NGX_OK; | |
| 566 } |