fs: abort in-flight stat operations

Signed-off-by: Mert Can Altin <mertgold60@gmail.com>
PR-URL: #63143
Refs: #57775
Reviewed-By: Chemi Atlow <chemi@atlow.co.il>
Reviewed-By: James M Snell <jasnell@gmail.com>

Author: mertcanaltin

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false

doc/api/fs.md

@@ -1542,6 +1542,10 @@ link(2) documentation for more detail.
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v10.5.0
  pr-url: https://github.com/nodejs/node/pull/20220
  description: Accepts an additional `options` object to specify whether
@@ -1552,6 +1556,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the given
  symbolic link `path`.
 
@@ -2080,6 +2086,10 @@ Removes files and directories (modeled on the standard POSIX `rm` utility).
 <!-- YAML
 added: v10.0.0
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v25.7.0
  pr-url: https://github.com/nodejs/node/pull/61178
  description: Accepts a `throwIfNoEntry` option to specify whether
@@ -2097,6 +2107,8 @@ changes:
  * `throwIfNoEntry` {boolean} Whether an exception will be thrown
  if no file system entry exists, rather than returning `undefined`.
  **Default:** `true`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * Returns: {Promise} Fulfills with the {fs.Stats} object for the
  given `path`.
 
@@ -3437,6 +3449,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.95
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3460,6 +3476,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}
@@ -3802,6 +3820,10 @@ exception are given to the completion callback.
 <!-- YAML
 added: v0.1.30
 changes:
+ - version: REPLACEME
+ pr-url: https://github.com/nodejs/node/pull/63143
+ description: Accepts an additional `signal` option to allow aborting the
+ operation.
  - version: v18.0.0
  pr-url: https://github.com/nodejs/node/pull/41678
  description: Passing an invalid callback to the `callback` argument
@@ -3829,6 +3851,8 @@ changes:
 * `options` {Object}
  * `bigint` {boolean} Whether the numeric values in the returned
  {fs.Stats} object should be `bigint`. **Default:** `false`.
+ * `signal` {AbortSignal} An AbortSignal to cancel the operation.
+ **Default:** `undefined`.
 * `callback` {Function}
  * `err` {Error}
  * `stats` {fs.Stats}

lib/fs.js

@@ -139,6 +139,7 @@ const {
 const{
  isInt32,
  parseFileMode,
+ validateAbortSignal,
  validateBoolean,
  validateBuffer,
  validateEncoding,
@@ -383,6 +384,25 @@ function checkAborted(signal, callback) {
 returnfalse;
 }
 
+functionbindSignalToReq(req,signal,callback){
+if(!signal){
+req.oncomplete=callback;
+return;
+}
+letaborted=false;
+constonAbort=()=>{
+aborted=true;
+callback(newAbortError(undefined,{cause: signal.reason}));
+};
+kResistStopPropagation??=require('internal/event_target').kResistStopPropagation;
+signal.addEventListener('abort',onAbort,{__proto__: null,[kResistStopPropagation]: true});
+req.oncomplete=function(err,result){
+signal.removeEventListener('abort',onAbort);
+if(aborted)return;
+callback(err,result);
+};
+}
+
 /**
  * Asynchronously reads the entire contents of a file.
  * @param {string | Buffer | URL | number} path
@@ -1954,7 +1974,7 @@ function readdirSync(path, options) {
  * Invokes the callback with the `fs.Stats`
  * for the file descriptor.
  * @param {number} fd
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1965,23 +1985,28 @@ function fstat(fd, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
 }
 
 consth=vfsState.handlers;
 if(h!==null&&vfsResult(h.fstat(fd,options),callback))return;
 
 callback=makeStatsCallback(callback);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.fstat(fd,options.bigint,req);
 }
 
 /**
  * Retrieves the `fs.Stats` for the symbolic link
  * referred to by the `path`.
  * @param {string | Buffer | URL} path
- * @param {{ bigint?: boolean; }} [options]
+ * @param {{ bigint?: boolean, signal?: AbortSignal }} [options]
  * @param {(
  * err?: Error,
  * stats?: Stats
@@ -1992,6 +2017,10 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 if(typeofoptions==='function'){
 callback=options;
 options=kEmptyObject;
+}elseif(options===null||typeofoptions!=='object'){
+options=kEmptyObject;
+}else{
+options=getOptions(options,{bigint: false});
 }
 
 consth=vfsState.handlers;
@@ -2005,8 +2034,11 @@ function lstat(path, options = { __proto__: null, bigint: false }, callback) {
 return;
 }
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
+if(checkAborted(options.signal,callback))return;
+
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
+bindSignalToReq(req,options.signal,callback);
 binding.lstat(path,options.bigint,req);
 }
 
@@ -2036,11 +2068,12 @@ function stat(path, options = { __proto__: null, bigint: false, throwIfNoEntry:
 callback=makeStatsCallback(callback);
 path=getValidatedPath(path);
 
+if(options.signal!==undefined)validateAbortSignal(options.signal,'options.signal');
 if(checkAborted(options.signal,callback))return;
 
 constreq=newFSReqCallback(options.bigint);
-req.oncomplete=callback;
-binding.stat(getValidatedPath(path),options.bigint,req,options.throwIfNoEntry);
+bindSignalToReq(req,options.signal,callback);
+binding.stat(path,options.bigint,req,options.throwIfNoEntry);
 }
 
 functionstatfs(path,options={__proto__: null,bigint: false},callback){

lib/internal/fs/promises.js

@@ -12,8 +12,10 @@ const {
  PromisePrototypeThen,
  PromiseReject,
  PromiseResolve,
+ PromiseWithResolvers,
  SafeArrayIterator,
  SafePromisePrototypeFinally,
+ SafePromiseRace,
  Symbol,
  SymbolAsyncDispose,
  SymbolAsyncIterator,
@@ -1126,6 +1128,21 @@ function checkAborted(signal) {
 thrownewAbortError(undefined,{cause: signal.reason});
 }
 
+functionrejectWithReason(signal,reject){
+return()=>{
+reject(newAbortError(undefined,{cause: signal.reason}));
+};
+}
+
+asyncfunctionraceWithSignal(opPromise,signal){
+if(!signal)returnopPromise;
+const{promise: abortPromise, reject }=PromiseWithResolvers();
+// eslint-disable-next-line no-unused-vars
+using_=EventEmitter.addAbortListener(signal,
+rejectWithReason(signal,reject));
+returnawaitSafePromiseRace([opPromise,abortPromise]);
+}
+
 asyncfunctionwriteFileHandle(filehandle,data,signal,encoding){
 checkAborted(signal);
 if(isCustomIterable(data)){
@@ -1779,15 +1796,26 @@ async function symlink(target, path, type) {
 }
 
 asyncfunctionfstat(handle,options={__proto__: null,bigint: false}){
-constresult=awaitPromisePrototypeThen(
-binding.fstat(handle.fd,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.fstat(handle.fd,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionlstat(path,options={__proto__: null,bigint: false}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.lstat(path,options);
@@ -1798,24 +1826,34 @@ async function lstat(path, options = { __proto__: null, bigint: false }) {
 constresource=pathModule.toNamespacedPath(BufferIsBuffer(path) ? BufferToString(path) : path);
 thrownewERR_ACCESS_DENIED('Access to this API has been restricted','FileSystemRead',resource);
 }
-constresult=awaitPromisePrototypeThen(
-binding.lstat(path,options.bigint,kUsePromises),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.lstat(path,options.bigint,kUsePromises),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 returngetStatsFromBinding(result);
 }
 
 asyncfunctionstat(path,options={__proto__: null,bigint: false,throwIfNoEntry: true}){
+validateObject(options,'options');
+const{ signal }=options;
+if(signal!==undefined)validateAbortSignal(signal,'options.signal');
+checkAborted(signal);
 consth=vfsState.handlers;
 if(h!==null){
 constpromise=h.stat(path,options);
 if(promise!==undefined)returnawaitpromise;
 }
-constresult=awaitPromisePrototypeThen(
-binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
-undefined,
-handleErrorFromBinding,
+constresult=awaitraceWithSignal(
+PromisePrototypeThen(
+binding.stat(getValidatedPath(path),options.bigint,kUsePromises,options.throwIfNoEntry),
+undefined,
+handleErrorFromBinding,
+),
+signal,
 );
 
 // Binding will resolve undefined if UV_ENOENT or UV_ENOTDIR and throwIfNoEntry is false