From d2c4f5082f371bbbfc01972d177799dc42e255a9 Mon Sep 17 00:00:00 2001 From: Joyee Cheung Date: Sat, 3 Feb 2018 22:45:30 +0800 Subject: [PATCH] fs: throw readdirSync errors in JS MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit PR-URL: https://github.com/nodejs/node/pull/18871 Refs: https://github.com/nodejs/node/issues/18106 Reviewed-By: Michaƫl Zasso Reviewed-By: James M Snell Reviewed-By: Ruben Bridgewater --- lib/fs.js | 6 +++++- src/node_file.cc | 32 +++++++++++++++++++++++--------- 2 files changed, 28 insertions(+), 10 deletions(-) diff --git a/lib/fs.js b/lib/fs.js index e6ba189fe81..7e80bb68007 100644 --- a/lib/fs.js +++ b/lib/fs.js @@ -819,7 +819,11 @@ fs.readdirSync = function(path, options) { options = getOptions(options, {}); path = getPathFromURL(path); validatePath(path); - return binding.readdir(pathModule.toNamespacedPath(path), options.encoding); + const ctx = { path }; + const result = binding.readdir(pathModule.toNamespacedPath(path), + options.encoding, undefined, ctx); + handleErrorFromBinding(ctx); + return result; }; fs.fstat = function(fd, callback) { diff --git a/src/node_file.cc b/src/node_file.cc index e3c9801b8a8..88662fad4e5 100644 --- a/src/node_file.cc +++ b/src/node_file.cc @@ -1090,7 +1090,8 @@ static void RealPath(const FunctionCallbackInfo& args) { static void ReadDir(const FunctionCallbackInfo& args) { Environment* env = Environment::GetCurrent(args); - CHECK_GE(args.Length(), 1); + const int argc = args.Length(); + CHECK_GE(argc, 3); BufferValue path(env->isolate(), args[0]); CHECK_NE(*path, nullptr); @@ -1098,13 +1099,19 @@ static void ReadDir(const FunctionCallbackInfo& args) { const enum encoding encoding = ParseEncoding(env->isolate(), args[1], UTF8); FSReqBase* req_wrap = GetReqWrap(env, args[2]); - if (req_wrap != nullptr) { + if (req_wrap != nullptr) { // readdir(path, encoding, req) AsyncCall(env, req_wrap, args, "scandir", encoding, AfterScanDir, uv_fs_scandir, *path, 0 /*flags*/); - } else { - SYNC_CALL(scandir, *path, *path, 0 /*flags*/) + } else { // readdir(path, encoding, undefined, ctx) + CHECK_EQ(argc, 4); + fs_req_wrap req_wrap; + int err = SyncCall(env, args[3], &req_wrap, "scandir", + uv_fs_scandir, *path, 0 /*flags*/); + if (err < 0) { + return; // syscall failed, no need to continue, error info is in ctx + } - CHECK_GE(SYNC_REQ.result, 0); + CHECK_GE(req_wrap.req.result, 0); int r; Local names = Array::New(env->isolate(), 0); Local fn = env->push_values_to_array_function(); @@ -1114,11 +1121,17 @@ static void ReadDir(const FunctionCallbackInfo& args) { for (int i = 0; ; i++) { uv_dirent_t ent; - r = uv_fs_scandir_next(&SYNC_REQ, &ent); + r = uv_fs_scandir_next(&(req_wrap.req), &ent); if (r == UV_EOF) break; - if (r != 0) - return env->ThrowUVException(r, "readdir", "", *path); + if (r != 0) { + Local ctx = args[3].As(); + ctx->Set(env->context(), env->errno_string(), + Integer::New(env->isolate(), r)).FromJust(); + ctx->Set(env->context(), env->syscall_string(), + OneByteString(env->isolate(), "readdir")).FromJust(); + return; + } Local error; MaybeLocal filename = StringBytes::Encode(env->isolate(), @@ -1126,7 +1139,8 @@ static void ReadDir(const FunctionCallbackInfo& args) { encoding, &error); if (filename.IsEmpty()) { - env->isolate()->ThrowException(error); + Local ctx = args[3].As(); + ctx->Set(env->context(), env->error_string(), error).FromJust(); return; }