http_parser: revert d77c3bf

As noted in #5555 the changes to
http_parser to use `MakeCallback` have caused a regression that stops
Throws from propagating inside of the http client libs.

A test and more information can be found at https://gist.github.com/TheAlphaNerd/6615a27684deb682dfe7

This revert is being applied directly to v5.x
As such will have no PR-URL.

Fix: #5555

Author: Myles Borins

src/async-wrap.h

@@ -17,7 +17,6 @@ namespace node {
   V(FSREQWRAP)                                                                \
   V(GETADDRINFOREQWRAP)                                                       \
   V(GETNAMEINFOREQWRAP)                                                       \
-  V(HTTPPARSER)                                                               \
   V(JSSTREAM)                                                                 \
   V(PIPEWRAP)                                                                 \
   V(PIPECONNECTWRAP)                                                          \

src/node_http_parser.cc

@@ -2,8 +2,8 @@
 #include "node_buffer.h"
 #include "node_http_parser.h"
 
-#include "async-wrap.h"
-#include "async-wrap-inl.h"
+#include "base-object.h"
+#include "base-object-inl.h"
 #include "env.h"
 #include "env-inl.h"
 #include "stream_base.h"
@@ -147,10 +147,10 @@ struct StringPtr {
 };
 
 
-class Parser : public AsyncWrap {
+class Parser : public BaseObject {
  public:
   Parser(Environment* env, Local<Object> wrap, enum http_parser_type type)
-      : AsyncWrap(env, wrap, AsyncWrap::PROVIDER_HTTPPARSER),
+      : BaseObject(env, wrap),
         current_buffer_len_(0),
         current_buffer_data_(nullptr) {
     Wrap(object(), this);
@@ -164,11 +164,6 @@ class Parser : public AsyncWrap {
   }
 
 
-  size_t self_size() const override {
-    return sizeof(*this);
-  }
-
-
   HTTP_CB(on_message_begin) {
     num_fields_ = num_values_ = 0;
     url_.Reset();
@@ -290,10 +285,8 @@ class Parser : public AsyncWrap {
 
     argv[A_UPGRADE] = Boolean::New(env()->isolate(), parser_.upgrade);
 
-    Environment::AsyncCallbackScope callback_scope(env());
-
     Local<Value> head_response =
-        MakeCallback(cb.As<Function>(), ARRAY_SIZE(argv), argv);
+        cb.As<Function>()->Call(obj, ARRAY_SIZE(argv), argv);
 
     if (head_response.IsEmpty()) {
       got_exception_ = true;
@@ -328,7 +321,7 @@ class Parser : public AsyncWrap {
       Integer::NewFromUnsigned(env()->isolate(), length)
     };
 
-    Local<Value> r = MakeCallback(cb.As<Function>(), ARRAY_SIZE(argv), argv);
+    Local<Value> r = cb.As<Function>()->Call(obj, ARRAY_SIZE(argv), argv);
 
     if (r.IsEmpty()) {
       got_exception_ = true;
@@ -351,9 +344,7 @@ class Parser : public AsyncWrap {
     if (!cb->IsFunction())
       return 0;
 
-    Environment::AsyncCallbackScope callback_scope(env());
-
-    Local<Value> r = MakeCallback(cb.As<Function>(), 0, nullptr);
+    Local<Value> r = cb.As<Function>()->Call(obj, 0, nullptr);
 
     if (r.IsEmpty()) {
       got_exception_ = true;
@@ -593,7 +584,7 @@ class Parser : public AsyncWrap {
     parser->current_buffer_len_ = nread;
     parser->current_buffer_data_ = buf->base;
 
-    parser->MakeCallback(cb.As<Function>(), 1, &ret);
+    cb.As<Function>()->Call(obj, 1, &ret);
 
     parser->current_buffer_len_ = 0;
     parser->current_buffer_data_ = nullptr;
@@ -680,7 +671,7 @@ class Parser : public AsyncWrap {
       url_.ToString(env())
     };
 
-    Local<Value> r = MakeCallback(cb.As<Function>(), ARRAY_SIZE(argv), argv);
+    Local<Value> r = cb.As<Function>()->Call(obj, ARRAY_SIZE(argv), argv);
 
     if (r.IsEmpty())
       got_exception_ = true;

test/parallel/test-async-wrap-check-providers.js

@@ -11,7 +11,6 @@ const tls = require('tls');
 const zlib = require('zlib');
 const ChildProcess = require('child_process').ChildProcess;
 const StreamWrap = require('_stream_wrap').StreamWrap;
-const HTTPParser = process.binding('http_parser').HTTPParser;
 const async_wrap = process.binding('async_wrap');
 const pkeys = Object.keys(async_wrap.Providers);
 
@@ -107,8 +106,6 @@ zlib.createGzip();
 
 new ChildProcess();
 
-new HTTPParser(HTTPParser.REQUEST);
-
 process.on('exit', function() {
   if (keyList.length !== 0) {
     process._rawDebug('Not all keys have been used:');