|
1 | 1 | #include "inspector_socket.h"
|
2 | 2 |
|
3 |
| -#ifdef NODE_EXPERIMENTAL_HTTP_DEFAULT |
4 | 3 | #define NODE_EXPERIMENTAL_HTTP
|
5 |
| -#endif |
6 | 4 | #include "http_parser_adaptor.h"
|
7 | 5 |
|
8 | 6 | #include "util-inl.h"
|
@@ -437,13 +435,8 @@ class HttpHandler : public ProtocolHandler {
|
437 | 435 | explicit HttpHandler(InspectorSocket* inspector, TcpHolder::Pointer tcp)
|
438 | 436 | : ProtocolHandler(inspector, std::move(tcp)),
|
439 | 437 | parsing_value_(false) {
|
440 |
| -#ifdef NODE_EXPERIMENTAL_HTTP_DEFAULT |
441 | 438 | llhttp_init(&parser_, HTTP_REQUEST, &parser_settings);
|
442 | 439 | llhttp_settings_init(&parser_settings);
|
443 |
| -#else /* !NODE_EXPERIMENTAL_HTTP_DEFAULT */ |
444 |
| - http_parser_init(&parser_, HTTP_REQUEST); |
445 |
| - http_parser_settings_init(&parser_settings); |
446 |
| -#endif /* NODE_EXPERIMENTAL_HTTP_DEFAULT */ |
447 | 440 | parser_settings.on_header_field = OnHeaderField;
|
448 | 441 | parser_settings.on_header_value = OnHeaderValue;
|
449 | 442 | parser_settings.on_message_complete = OnMessageComplete;
|
@@ -488,17 +481,12 @@ class HttpHandler : public ProtocolHandler {
|
488 | 481 |
|
489 | 482 | void OnData(std::vector<char>* data) override {
|
490 | 483 | parser_errno_t err;
|
491 |
| -#ifdef NODE_EXPERIMENTAL_HTTP_DEFAULT |
492 | 484 | err = llhttp_execute(&parser_, data->data(), data->size());
|
493 | 485 |
|
494 | 486 | if (err == HPE_PAUSED_UPGRADE) {
|
495 | 487 | err = HPE_OK;
|
496 | 488 | llhttp_resume_after_upgrade(&parser_);
|
497 | 489 | }
|
498 |
| -#else /* !NODE_EXPERIMENTAL_HTTP_DEFAULT */ |
499 |
| - http_parser_execute(&parser_, &parser_settings, data->data(), data->size()); |
500 |
| - err = HTTP_PARSER_ERRNO(&parser_); |
501 |
| -#endif /* NODE_EXPERIMENTAL_HTTP_DEFAULT */ |
502 | 490 | data->clear();
|
503 | 491 | if (err != HPE_OK) {
|
504 | 492 | CancelHandshake();
|
|
0 commit comments