fixup

Signed-off-by: Matteo Collina <[email protected]>

test/parallel/test-fs-watch-recursive-add-folder.js

@@ -1,10 +1,15 @@
 'use strict';
 
 const common = require('../common');
+const { setTimeout } = require('timers/promises');
 
 if (common.isIBMi)
   common.skip('IBMi does not support `fs.watch()`');
 
+// fs-watch on folders have limited capability in AIX.
+// The testcase makes use of folder watching, and causes
+// hang. This behavior is documented. Skip this for AIX.
+
 if (common.isAIX)
   common.skip('folder watch capability is limited in AIX.');
 
@@ -16,27 +21,30 @@ const tmpdir = require('../common/tmpdir');
 const testDir = tmpdir.path;
 tmpdir.refresh();
 
-// Add a folder to already watching folder
+(async () => {
+  // Add a folder to already watching folder
 
-const rootDirectory = fs.mkdtempSync(testDir + path.sep);
-const testDirectory = path.join(rootDirectory, 'test-2');
-fs.mkdirSync(testDirectory);
+  const rootDirectory = fs.mkdtempSync(testDir + path.sep);
+  const testDirectory = path.join(rootDirectory, 'test-2');
+  fs.mkdirSync(testDirectory);
 
-const testFile = path.join(testDirectory, 'folder-2');
+  const testFile = path.join(testDirectory, 'folder-2');
 
-const watcher = fs.watch(testDirectory, { recursive: true });
-let watcherClosed = false;
-watcher.on('change', function(event, filename) {
-  assert.strictEqual(event, 'rename');
+  const watcher = fs.watch(testDirectory, { recursive: true });
+  let watcherClosed = false;
+  watcher.on('change', function(event, filename) {
+    assert.strictEqual(event, 'rename');
 
-  if (filename === path.basename(testFile)) {
-    watcher.close();
-    watcherClosed = true;
-  }
-});
+    if (filename === path.basename(testFile)) {
+      watcher.close();
+      watcherClosed = true;
+    }
+  });
 
-fs.mkdirSync(testFile);
+  await setTimeout(common.platformTimeout(100));
+  fs.mkdirSync(testFile);
 
-process.once('exit', function() {
-  assert(watcherClosed, 'watcher Object was not closed');
-});
+  process.once('exit', function() {
+    assert(watcherClosed, 'watcher Object was not closed');
+  });
+})().then(common.mustCall());