| 186 buf->cursize += r; |
186 buf->cursize += r; |
| 187 } |
187 } |
| 188 |
188 |
| 189 if(!err) { |
189 if(!err) { |
| 190 if(http_parser_validate(parser)) { |
190 if(http_parser_validate(parser)) { |
| |
191 http_parser_update_request(parser, request); |
| 191 // process request |
192 // process request |
| 192 r = handle_request(request, NULL, NULL); // TODO: use correct thread pool |
193 r = handle_request(request, NULL, NULL); // TODO: use correct thread pool |
| 193 } else { |
194 } else { |
| 194 log_ereport(LOG_FAILURE, "basic_run_session: http parser validation failed"); |
195 log_ereport(LOG_FAILURE, "basic_run_session: http parser validation failed"); |
| 195 fatal_error(request, 400); |
196 fatal_error(request, 400); |
| 504 log_ereport(LOG_FAILURE, "http_parser_validate failed"); |
505 log_ereport(LOG_FAILURE, "http_parser_validate failed"); |
| 505 fatal_error(request, 400); |
506 fatal_error(request, 400); |
| 506 event->finish = evt_request_error; |
507 event->finish = evt_request_error; |
| 507 return 0; |
508 return 0; |
| 508 } |
509 } |
| |
510 http_parser_update_request(parser, request); |
| 509 |
511 |
| 510 /* |
512 /* |
| 511 * process request |
513 * process request |
| 512 * |
514 * |
| 513 * We return 0 to finish request input. The event handler than stops |
515 * We return 0 to finish request input. The event handler than stops |