src: pass along errors from StreamBase req obj creations

addaleax · addaleax · commit 469cdacd59ce · 2019-02-09T00:45:31.000+01:00
PR-URL: #25822 Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
diff --git a/src/stream_base-inl.h b/src/stream_base-inl.h
@@ -163,9 +163,11 @@ inline int StreamBase::Shutdown(v8::Local<v8::Object> req_wrap_obj) {
   HandleScope handle_scope(env->isolate());
 
   if (req_wrap_obj.IsEmpty()) {
-    req_wrap_obj =
-        env->shutdown_wrap_template()
-            ->NewInstance(env->context()).ToLocalChecked();
+    if (!env->shutdown_wrap_template()
+             ->NewInstance(env->context())
+             .ToLocal(&req_wrap_obj)) {
+      return UV_EBUSY;
+    }
     StreamReq::ResetObject(req_wrap_obj);
   }
 
@@ -211,9 +213,11 @@ inline StreamWriteResult StreamBase::Write(
   HandleScope handle_scope(env->isolate());
 
   if (req_wrap_obj.IsEmpty()) {
-    req_wrap_obj =
-        env->write_wrap_template()
-            ->NewInstance(env->context()).ToLocalChecked();
+    if (!env->write_wrap_template()
+             ->NewInstance(env->context())
+             .ToLocal(&req_wrap_obj)) {
+      return StreamWriteResult { false, UV_EBUSY, nullptr, 0 };
+    }
     StreamReq::ResetObject(req_wrap_obj);
   }
 
