Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBastian Krol <bastian.krol@instana.com>2018-10-01 18:11:25 +0300
committerDaniel Bevenius <daniel.bevenius@gmail.com>2018-10-10 09:45:56 +0300
commiteb9748d222061381236f19cbe162cf9eb2e034ad (patch)
tree88d7412a51fc3966d059cff654002c4d9b160348 /src/node_http_parser.cc
parent45c70b0ce79c5c606247356bf4697dae6f60c810 (diff)
async_hooks: add missing async_hooks destroys in AsyncReset
This adds missing async_hooks destroy calls for sockets (in _http_agent.js) and HTTP parsers. We need to emit a destroy in AsyncWrap#AsyncReset before assigning a new async_id when the instance has already been in use and is being recycled, because in that case, we have already emitted an init for the "old" async_id. This also removes a duplicated init call for HTTP parser: Each time a new parser was created, AsyncReset was being called via the C++ Parser class constructor (super constructor AsyncWrap) and also via Parser::Reinitialize. PR-URL: https://github.com/nodejs/node/pull/23272 Fixes: https://github.com/nodejs/node/issues/19859 Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: James M Snell <jasnell@gmail.com>
Diffstat (limited to 'src/node_http_parser.cc')
-rw-r--r--src/node_http_parser.cc10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/node_http_parser.cc b/src/node_http_parser.cc
index 5d093b27c39..9850b4f6982 100644
--- a/src/node_http_parser.cc
+++ b/src/node_http_parser.cc
@@ -465,6 +465,8 @@ class Parser : public AsyncWrap, public StreamListener {
Environment* env = Environment::GetCurrent(args);
CHECK(args[0]->IsInt32());
+ CHECK(args[1]->IsBoolean());
+ bool isReused = args[1]->IsTrue();
http_parser_type type =
static_cast<http_parser_type>(args[0].As<Int32>()->Value());
@@ -473,8 +475,12 @@ class Parser : public AsyncWrap, public StreamListener {
ASSIGN_OR_RETURN_UNWRAP(&parser, args.Holder());
// Should always be called from the same context.
CHECK_EQ(env, parser->env());
- // The parser is being reused. Reset the async id and call init() callbacks.
- parser->AsyncReset();
+ // This parser has either just been created or it is being reused.
+ // We must only call AsyncReset for the latter case, because AsyncReset has
+ // already been called via the constructor for the former case.
+ if (isReused) {
+ parser->AsyncReset();
+ }
parser->Init(type);
}