Lines Matching refs:parser
39 // agility. A Buffer is read from a socket and passed to parser.execute().
40 // The parser then issues callbacks with slices of the data
41 // parser.onMessageBegin
42 // parser.onPath
43 // parser.onBody
127 // to leak references. See issue #2438 and test-http-parser-bad-ref.js.
210 void Push(Parser* parser) {
211 all_connections_.insert(parser);
214 void Pop(Parser* parser) {
215 all_connections_.erase(parser);
218 void PushActive(Parser* parser) {
219 active_connections_.insert(parser);
222 void PopActive(Parser* parser) {
223 active_connections_.erase(parser);
555 Parser* parser;
556 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
558 delete parser;
563 Parser* parser;
564 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
568 parser->EmitTraceEventDestroy();
569 parser->EmitDestroy();
573 Parser* parser;
574 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
576 if (parser->connectionsList_ != nullptr) {
577 parser->connectionsList_->Pop(parser);
578 parser->connectionsList_->PopActive(parser);
595 // var bytesParsed = parser->execute(buffer);
597 Parser* parser;
598 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
602 Local<Value> ret = parser->Execute(buffer.data(), buffer.length());
610 Parser* parser;
611 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
613 Local<Value> ret = parser->Execute(nullptr, 0);
653 Parser* parser;
654 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
656 CHECK_EQ(env, parser->env());
663 parser->set_provider_type(provider);
664 parser->AsyncReset(args[1].As<Object>());
665 parser->Init(type, max_http_header_size, lenient_flags);
668 parser->connectionsList_ = connectionsList;
673 parser->last_message_start_ = uv_hrtime();
677 parser->connectionsList_->Push(parser);
678 parser->connectionsList_->PushActive(parser);
680 parser->connectionsList_ = nullptr;
687 Parser* parser;
688 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
690 CHECK_EQ(env, parser->env());
693 llhttp_pause(&parser->parser_);
695 llhttp_resume(&parser->parser_);
701 Parser* parser;
702 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
706 stream->PushStreamListener(parser);
711 Parser* parser;
712 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
715 if (parser->stream_ == nullptr)
718 parser->stream_->RemoveStreamListener(parser);
723 Parser* parser;
724 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
727 parser->env(),
728 parser->current_buffer_data_,
729 parser->current_buffer_len_).ToLocalChecked();
735 Parser* parser;
736 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
738 if (parser->last_message_start_ == 0) {
743 double duration = (uv_hrtime() - parser->last_message_start_) / 1e6;
748 Parser* parser;
749 ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
751 args.GetReturnValue().Set(parser->headers_completed_);
774 // Once we’re done here, either indicate that the HTTP parser buffer
789 // Ignore, empty reads have special meaning in http parser
1013 // a member function of Parser into a C-style HTTP parser callback.
1018 Parser* parser = ContainerOf(&Parser::parser_, p);
1019 int rv = (parser->*Member)(std::forward<Args>(args)...);
1021 rv = parser->MaybePause();
1063 for (auto parser : list->all_connections_) {
1064 result.emplace_back(parser->object());
1080 for (auto parser : list->all_connections_) {
1081 if (parser->last_message_start_ == 0) {
1082 result.emplace_back(parser->object());
1099 for (auto parser : list->active_connections_) {
1100 result.emplace_back(parser->object());
1149 Parser* parser = *iter;
1154 (!parser->headers_completed_ && headers_deadline > 0 &&
1155 parser->last_message_start_ < headers_deadline) ||
1158 parser->last_message_start_ < request_deadline)
1160 result.emplace_back(parser->object());
1162 list->active_connections_.erase(parser);