src: always call ReadStop() before Close()

For libuv-backed streams, always explicitly stop reading before closing the handle. PR-URL: #19377 Reviewed-By: Ben Noordhuis <[email protected]> Reviewed-By: James M Snell <[email protected]>
nodejs · May 14, 2018 · 7153bec · 7153bec
1 parent 61415dc
commit 7153bec
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 1 deletion.
diff --git a/src/handle_wrap.h b/src/handle_wrap.h
@@ -70,7 +70,8 @@ class HandleWrap : public AsyncWrap {
 
   inline uv_handle_t* GetHandle() const { return handle_; }
 
-  void Close(v8::Local<v8::Value> close_callback = v8::Local<v8::Value>());
+  virtual void Close(
+      v8::Local<v8::Value> close_callback = v8::Local<v8::Value>());
 
  protected:
   HandleWrap(Environment* env,

diff --git a/src/stream_wrap.cc b/src/stream_wrap.cc
@@ -373,6 +373,11 @@ void LibuvStreamWrap::AfterUvWrite(uv_write_t* req, int status) {
   req_wrap->Done(status);
 }
 
+void LibuvStreamWrap::Close(v8::Local<v8::Value> close_callback) {
+  ReadStop();
+  HandleWrap::Close(close_callback);
+}
+
 }  // namespace node
 
 NODE_BUILTIN_MODULE_CONTEXT_AWARE(stream_wrap,

diff --git a/src/stream_wrap.h b/src/stream_wrap.h
@@ -76,6 +76,8 @@ class LibuvStreamWrap : public HandleWrap, public StreamBase {
   ShutdownWrap* CreateShutdownWrap(v8::Local<v8::Object> object) override;
   WriteWrap* CreateWriteWrap(v8::Local<v8::Object> object) override;
 
+  void Close(v8::Local<v8::Value> close_callback) override;
+
  protected:
   LibuvStreamWrap(Environment* env,
                   v8::Local<v8::Object> object,