Mercurial > hg > nginx
annotate src/http/ngx_http_request_body.c @ 633:f971949ffb58 release-0.3.38
nginx-0.3.38-RELEASE import
*) Feature: the ngx_http_dav_module.
*) Change: the ngx_http_perl_module optimizations.
Thanks to Sergey Skvortsov.
*) Feature: the ngx_http_perl_module supports the $r->request_body_file
method.
*) Feature: the "client_body_in_file_only" directive.
*) Workaround: now on disk overflow nginx tries to write access logs
once a second only.
Thanks to Anton Yuzhaninov and Maxim Dounin.
*) Bugfix: now the "limit_rate" directive more precisely limits rate if
rate is more than 100 Kbyte/s.
Thanks to ForJest.
*) Bugfix: now the IMAP/POP3 proxy escapes the "\r" and "\n" symbols in
login and password to pass authorization server.
Thanks to Maxim Dounin.
| author | Igor Sysoev <igor@sysoev.ru> |
|---|---|
| date | Fri, 14 Apr 2006 09:53:38 +0000 |
| parents | 4e296b7d25bf |
| children | e60fe4cf1d4e |
| 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 { |
| 633 | 33 ssize_t size, preread; |
|
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
|
34 ngx_buf_t *b; |
| 633 | 35 ngx_chain_t *cl, **next; |
| 479 | 36 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
|
37 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
|
38 |
| 537 | 39 if (r->request_body || r->discard_body) { |
| 509 | 40 post_handler(r); |
| 41 return NGX_OK; | |
| 42 } | |
| 43 | |
| 501 | 44 rb = ngx_pcalloc(r->pool, sizeof(ngx_http_request_body_t)); |
| 45 if (rb == NULL) { | |
| 479 | 46 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 47 } | |
| 48 | |
| 49 r->request_body = rb; | |
| 50 | |
| 51 if (r->headers_in.content_length_n <= 0) { | |
| 52 post_handler(r); | |
| 53 return NGX_OK; | |
| 54 } | |
| 55 | |
| 56 rb->post_handler = post_handler; | |
| 57 | |
| 58 /* | |
| 59 * set by ngx_pcalloc(): | |
| 60 * | |
| 61 * rb->bufs = NULL; | |
| 62 * rb->buf = NULL; | |
| 63 * rb->rest = 0; | |
| 64 */ | |
| 65 | |
| 633 | 66 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
|
67 |
| 633 | 68 if (preread) { |
|
296
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
69 |
|
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
70 /* 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
|
71 |
| 633 | 72 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, |
| 73 "http client request body preread %uz", preread); | |
| 74 | |
| 501 | 75 b = ngx_calloc_buf(r->pool); |
| 76 if (b == NULL) { | |
| 479 | 77 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 78 } | |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
79 |
|
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
|
80 b->temporary = 1; |
| 633 | 81 b->start = r->header_in->pos; |
| 82 b->pos = r->header_in->pos; | |
| 83 b->last = r->header_in->last; | |
| 84 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
|
85 |
| 501 | 86 rb->bufs = ngx_alloc_chain_link(r->pool); |
| 87 if (rb->bufs == NULL) { | |
| 479 | 88 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 89 } | |
| 90 | |
| 91 rb->bufs->buf = b; | |
| 92 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
|
93 |
| 633 | 94 if (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
|
95 |
|
bfe099e3f5b4
nginx-0.0.3-2004-03-26-19:13:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
294
diff
changeset
|
96 /* 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
|
97 |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
98 r->header_in->pos += r->headers_in.content_length_n; |
| 475 | 99 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
|
100 |
| 633 | 101 if (r->request_body_in_file_only) { |
| 102 if (ngx_http_write_request_body(r, rb->bufs) != NGX_OK) { | |
| 103 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 104 } | |
| 105 } | |
| 106 | |
| 479 | 107 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
|
108 |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
109 return NGX_OK; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
110 } |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
111 |
| 633 | 112 /* |
| 113 * to not consider the body as pipelined request in | |
| 114 * ngx_http_set_keepalive() | |
| 115 */ | |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
116 r->header_in->pos = r->header_in->last; |
| 633 | 117 |
| 118 r->request_length += preread; | |
| 119 | |
| 120 rb->rest = r->headers_in.content_length_n - preread; | |
| 121 | |
| 122 if (rb->rest <= (size_t) (b->end - b->last)) { | |
| 123 | |
| 124 /* the whole request body may be placed in r->header_in */ | |
| 125 | |
| 126 rb->buf = b; | |
| 127 | |
| 128 r->read_event_handler = ngx_http_read_client_request_body_handler; | |
| 129 | |
| 130 return ngx_http_do_read_client_request_body(r); | |
| 131 } | |
| 132 | |
| 133 next = &rb->bufs->next; | |
| 134 | |
| 135 } else { | |
| 136 b = NULL; | |
| 137 rb->rest = r->headers_in.content_length_n; | |
| 138 next = &rb->bufs; | |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
139 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
140 |
|
303
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
299
diff
changeset
|
141 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); |
|
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
299
diff
changeset
|
142 |
| 633 | 143 size = clcf->client_body_buffer_size; |
| 144 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
|
145 |
| 633 | 146 if (rb->rest < (size_t) size) { |
| 479 | 147 size = rb->rest; |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
148 |
| 633 | 149 if (r->request_body_in_single_buf) { |
| 150 size += preread; | |
| 151 } | |
| 152 | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
153 } else { |
|
303
00c5660d2707
nginx-0.0.3-2004-04-01-20:20:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
299
diff
changeset
|
154 size = clcf->client_body_buffer_size; |
| 633 | 155 |
| 156 /* disable copying buffer for r->request_body_in_single_buf */ | |
| 157 b = NULL; | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
158 } |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
159 |
| 501 | 160 rb->buf = ngx_create_temp_buf(r->pool, size); |
| 161 if (rb->buf == NULL) { | |
| 479 | 162 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 163 } | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
164 |
| 501 | 165 cl = ngx_alloc_chain_link(r->pool); |
| 166 if (cl == NULL) { | |
| 479 | 167 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
| 168 } | |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
169 |
| 479 | 170 cl->buf = rb->buf; |
| 171 cl->next = NULL; | |
| 172 | |
| 633 | 173 if (b && r->request_body_in_single_buf) { |
| 174 size = b->last - b->pos; | |
| 175 ngx_memcpy(rb->buf->pos, b->pos, size); | |
| 176 rb->buf->last += size; | |
| 177 | |
| 178 next = &rb->bufs; | |
| 179 } | |
| 180 | |
| 181 *next = cl; | |
| 182 | |
| 183 if (r->request_body_in_file_only || r->request_body_in_single_buf) { | |
| 184 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
|
185 |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
186 } else { |
| 633 | 187 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
|
188 } |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
189 |
| 509 | 190 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
|
191 |
| 509 | 192 return ngx_http_do_read_client_request_body(r); |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
193 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
194 |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
195 |
| 501 | 196 static void |
| 509 | 197 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
|
198 { |
| 509 | 199 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
|
200 |
| 509 | 201 if (r->connection->read->timedout) { |
| 577 | 202 r->connection->timedout = 1; |
| 633 | 203 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
|
204 return; |
|
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
205 } |
|
46b7eeb8a116
nginx-0.0.3-2004-03-30-19:59:50 import
Igor Sysoev <igor@sysoev.ru>
parents:
297
diff
changeset
|
206 |
| 509 | 207 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
|
208 |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
209 if (rc >= NGX_HTTP_SPECIAL_RESPONSE) { |
| 633 | 210 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
|
211 } |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
212 } |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
213 |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
214 |
| 501 | 215 static ngx_int_t |
| 509 | 216 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
|
217 { |
|
290
87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
171
diff
changeset
|
218 size_t size; |
|
87e73f067470
nginx-0.0.2-2004-03-16-10:10:12 import
Igor Sysoev <igor@sysoev.ru>
parents:
171
diff
changeset
|
219 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
|
220 ngx_buf_t *b; |
| 509 | 221 ngx_connection_t *c; |
| 479 | 222 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
|
223 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
|
224 |
| 509 | 225 c = r->connection; |
| 479 | 226 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
|
227 |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
228 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
|
229 "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
|
230 |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
231 for ( ;; ) { |
| 479 | 232 if (rb->buf->last == rb->buf->end) { |
| 233 | |
| 633 | 234 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
|
235 return NGX_HTTP_INTERNAL_SERVER_ERROR; |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
236 } |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
237 |
| 633 | 238 rb->to_write = rb->bufs->next ? rb->bufs->next : rb->bufs; |
| 479 | 239 rb->buf->last = rb->buf->start; |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
240 } |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
241 |
| 479 | 242 size = rb->buf->end - rb->buf->last; |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
243 |
| 479 | 244 if (size > rb->rest) { |
| 245 size = rb->rest; | |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
246 } |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
247 |
| 479 | 248 n = c->recv(c, rb->buf->last, size); |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
249 |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
250 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, |
| 461 | 251 "http client request body recv %z", n); |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
252 |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
253 if (n == NGX_AGAIN) { |
| 573 | 254 break; |
|
162
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
255 } |
|
96993d4d5067
nginx-0.0.1-2003-10-28-00:01:00 import
Igor Sysoev <igor@sysoev.ru>
parents:
160
diff
changeset
|
256 |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
257 if (n == 0) { |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
258 ngx_log_error(NGX_LOG_INFO, c->log, 0, |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
259 "client closed prematurely connection"); |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
260 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
261 |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
262 if (n == 0 || n == NGX_ERROR) { |
| 583 | 263 c->error = 1; |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
264 return NGX_HTTP_BAD_REQUEST; |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
265 } |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
266 |
| 479 | 267 rb->buf->last += n; |
| 268 rb->rest -= n; | |
| 475 | 269 r->request_length += n; |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
270 |
| 479 | 271 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
|
272 break; |
|
5cfd65b8b0a7
nginx-0.0.3-2004-03-23-09:01:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
293
diff
changeset
|
273 } |
|
5cfd65b8b0a7
nginx-0.0.3-2004-03-23-09:01:52 import
Igor Sysoev <igor@sysoev.ru>
parents:
293
diff
changeset
|
274 |
| 479 | 275 if (rb->buf->last < rb->buf->end) { |
|
292
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
276 break; |
|
a472bfb778b3
nginx-0.0.3-2004-03-17-00:26:01 import
Igor Sysoev <igor@sysoev.ru>
parents:
290
diff
changeset
|
277 } |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
278 } |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
279 |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
280 ngx_log_debug1(NGX_LOG_DEBUG_HTTP, c->log, 0, |
| 479 | 281 "http client request body rest %uz", rb->rest); |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
282 |
| 479 | 283 if (rb->rest) { |
| 573 | 284 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); |
| 285 ngx_add_timer(c->read, clcf->client_body_timeout); | |
| 286 | |
| 287 if (ngx_handle_read_event(c->read, 0) == NGX_ERROR) { | |
| 288 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 289 } | |
| 290 | |
|
293
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
291 return NGX_AGAIN; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
292 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
293 |
| 573 | 294 if (c->read->timer_set) { |
| 295 ngx_del_timer(c->read); | |
| 296 } | |
| 297 | |
| 633 | 298 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
|
299 |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
300 /* save the last part */ |
| 479 | 301 |
| 633 | 302 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
|
303 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
|
304 } |
|
160
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
305 |
| 501 | 306 b = ngx_calloc_buf(r->pool); |
| 307 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
|
308 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
|
309 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
310 |
|
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
|
311 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
|
312 b->file_pos = 0; |
| 479 | 313 b->file_last = rb->temp_file->file.offset; |
| 314 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
|
315 |
| 479 | 316 if (rb->bufs->next) { |
| 317 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
|
318 |
|
e7e094d34162
nginx-0.0.1-2003-10-27-11:53:49 import
Igor Sysoev <igor@sysoev.ru>
parents:
83
diff
changeset
|
319 } else { |
| 479 | 320 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
|
321 } |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
322 } |
|
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
323 |
| 633 | 324 if (r->request_body_in_file_only && rb->bufs->next) { |
| 325 rb->bufs = rb->bufs->next; | |
| 326 } | |
| 327 | |
| 479 | 328 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
|
329 |
|
ec3c049681fd
nginx-0.0.3-2004-03-19-08:25:53 import
Igor Sysoev <igor@sysoev.ru>
parents:
292
diff
changeset
|
330 return NGX_OK; |
|
82
fccdb921e8b8
nginx-0.0.1-2003-04-25-18:43:13 import
Igor Sysoev <igor@sysoev.ru>
parents:
diff
changeset
|
331 } |
| 633 | 332 |
| 333 | |
| 334 static ngx_int_t | |
| 335 ngx_http_write_request_body(ngx_http_request_t *r, ngx_chain_t *body) | |
| 336 { | |
| 337 ssize_t n; | |
| 338 ngx_temp_file_t *tf; | |
| 339 ngx_http_request_body_t *rb; | |
| 340 ngx_http_core_loc_conf_t *clcf; | |
| 341 | |
| 342 rb = r->request_body; | |
| 343 | |
| 344 if (rb->temp_file == NULL) { | |
| 345 tf = ngx_pcalloc(r->pool, sizeof(ngx_temp_file_t)); | |
| 346 if (tf == NULL) { | |
| 347 return NGX_ERROR; | |
| 348 } | |
| 349 | |
| 350 clcf = ngx_http_get_module_loc_conf(r, ngx_http_core_module); | |
| 351 | |
| 352 tf->file.fd = NGX_INVALID_FILE; | |
| 353 tf->file.log = r->connection->log; | |
| 354 tf->path = clcf->client_body_temp_path; | |
| 355 tf->pool = r->pool; | |
| 356 tf->warn = "a client request body is buffered to a temporary file"; | |
| 357 tf->persistent = r->request_body_in_persistent_file; | |
| 358 | |
| 359 if (r->request_body_file_group_access) { | |
| 360 tf->mode = 0660; | |
| 361 } | |
| 362 | |
| 363 rb->temp_file = tf; | |
| 364 } | |
| 365 | |
| 366 n = ngx_write_chain_to_temp_file(rb->temp_file, body); | |
| 367 | |
| 368 /* TODO: n == 0 or not complete and level event */ | |
| 369 | |
| 370 if (n == NGX_ERROR) { | |
| 371 return NGX_ERROR; | |
| 372 } | |
| 373 | |
| 374 rb->temp_file->offset += n; | |
| 375 | |
| 376 return NGX_OK; | |
| 377 } | |
| 378 | |
| 379 | |
| 380 static void | |
| 381 ngx_http_finalize_request_body(ngx_http_request_t *r, ngx_int_t rc) | |
| 382 { | |
| 383 if (r->request_body->temp_file | |
| 384 && r->request_body_in_persistent_file | |
| 385 && r->request_body_delete_incomplete_file) | |
| 386 { | |
| 387 if (ngx_delete_file(r->request_body->temp_file->file.name.data) | |
| 388 == NGX_FILE_ERROR) | |
| 389 { | |
| 390 ngx_log_error(NGX_LOG_CRIT, r->connection->log, ngx_errno, | |
| 391 ngx_delete_file_n " \"%s\" failed", | |
| 392 r->request_body->temp_file->file.name.data); | |
| 393 } | |
| 394 } | |
| 395 | |
| 396 ngx_http_finalize_request(r, rc); | |
| 397 } | |
| 398 | |
| 399 | |
| 400 ngx_int_t | |
| 401 ngx_http_discard_body(ngx_http_request_t *r) | |
| 402 { | |
| 403 ssize_t size; | |
| 404 ngx_event_t *rev; | |
| 405 | |
| 406 if (r != r->main) { | |
| 407 return NGX_OK; | |
| 408 } | |
| 409 | |
| 410 rev = r->connection->read; | |
| 411 | |
| 412 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, rev->log, 0, "http set discard body"); | |
| 413 | |
| 414 if (rev->timer_set) { | |
| 415 ngx_del_timer(rev); | |
| 416 } | |
| 417 | |
| 418 if (r->headers_in.content_length_n <= 0) { | |
| 419 return NGX_OK; | |
| 420 } | |
| 421 | |
| 422 r->discard_body = 1; | |
| 423 | |
| 424 size = r->header_in->last - r->header_in->pos; | |
| 425 | |
| 426 if (size) { | |
| 427 if (r->headers_in.content_length_n > size) { | |
| 428 r->headers_in.content_length_n -= size; | |
| 429 | |
| 430 } else { | |
| 431 r->header_in->pos += r->headers_in.content_length_n; | |
| 432 r->headers_in.content_length_n = 0; | |
| 433 return NGX_OK; | |
| 434 } | |
| 435 } | |
| 436 | |
| 437 r->read_event_handler = ngx_http_read_discarded_body_handler; | |
| 438 | |
| 439 if (ngx_handle_read_event(rev, 0) == NGX_ERROR) { | |
| 440 return NGX_HTTP_INTERNAL_SERVER_ERROR; | |
| 441 } | |
| 442 | |
| 443 return ngx_http_read_discarded_body(r); | |
| 444 } | |
| 445 | |
| 446 | |
| 447 static void | |
| 448 ngx_http_read_discarded_body_handler(ngx_http_request_t *r) | |
| 449 { | |
| 450 ngx_int_t rc; | |
| 451 | |
| 452 rc = ngx_http_read_discarded_body(r); | |
| 453 | |
| 454 if (rc == NGX_AGAIN) { | |
| 455 if (ngx_handle_read_event(r->connection->read, 0) == NGX_ERROR) { | |
| 456 ngx_http_finalize_request(r, rc); | |
| 457 return; | |
| 458 } | |
| 459 } | |
| 460 | |
| 461 if (rc != NGX_OK) { | |
| 462 ngx_http_finalize_request(r, rc); | |
| 463 } | |
| 464 } | |
| 465 | |
| 466 | |
| 467 static ngx_int_t | |
| 468 ngx_http_read_discarded_body(ngx_http_request_t *r) | |
| 469 { | |
| 470 ssize_t size, n; | |
| 471 u_char buffer[NGX_HTTP_DISCARD_BUFFER_SIZE]; | |
| 472 | |
| 473 ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0, | |
| 474 "http read discarded body"); | |
| 475 | |
| 476 if (r->headers_in.content_length_n == 0) { | |
| 477 return NGX_OK; | |
| 478 } | |
| 479 | |
| 480 | |
| 481 size = r->headers_in.content_length_n; | |
| 482 | |
| 483 if (size > NGX_HTTP_DISCARD_BUFFER_SIZE) { | |
| 484 size = NGX_HTTP_DISCARD_BUFFER_SIZE; | |
| 485 } | |
| 486 | |
| 487 n = r->connection->recv(r->connection, buffer, size); | |
| 488 | |
| 489 if (n == NGX_ERROR) { | |
| 490 | |
| 491 r->connection->error = 1; | |
| 492 | |
| 493 /* | |
| 494 * if a client request body is discarded then we already set | |
| 495 * some HTTP response code for client and we can ignore the error | |
| 496 */ | |
| 497 | |
| 498 return NGX_OK; | |
| 499 } | |
| 500 | |
| 501 if (n == NGX_AGAIN) { | |
| 502 return NGX_AGAIN; | |
| 503 } | |
| 504 | |
| 505 r->headers_in.content_length_n -= n; | |
| 506 | |
| 507 return NGX_OK; | |
| 508 } |