From 73f4325a5eb06bc5f2bc9f12840f1df8359056ad Mon Sep 17 00:00:00 2001
From: Anna Henningsen <anna@addaleax.net>
Date: Tue, 17 Jul 2018 03:05:04 +0200
Subject: [PATCH] fs: improve fs.watch ENOSPC error message

Providing `No space left on device` is misleading in this case.
Replace it with something that describes it more accurately.

Refs: https://stackoverflow.com/questions/22475849/node-js-error-enospc/32600959
---
 lib/internal/errors.js                        |  2 +-
 lib/internal/fs/watchers.js                   |  5 +-
 test/sequential/test-fs-watch-system-limit.js | 50 +++++++++++++++++++
 3 files changed, 55 insertions(+), 2 deletions(-)
 create mode 100644 test/sequential/test-fs-watch-system-limit.js

diff --git a/lib/internal/errors.js b/lib/internal/errors.js
index 6d6bfb7d4db689..74966532c8f616 100644
--- a/lib/internal/errors.js
+++ b/lib/internal/errors.js
@@ -244,7 +244,7 @@ function getMessage(key, args) {
  */
 function uvException(ctx) {
   const [ code, uvmsg ] = errmap.get(ctx.errno);
-  let message = `${code}: ${uvmsg}, ${ctx.syscall}`;
+  let message = `${code}: ${ctx.description || uvmsg}, ${ctx.syscall}`;
 
   let path;
   let dest;
diff --git a/lib/internal/fs/watchers.js b/lib/internal/fs/watchers.js
index 3db3a5cc7cd4a4..b247c643bf0dbf 100644
--- a/lib/internal/fs/watchers.js
+++ b/lib/internal/fs/watchers.js
@@ -7,6 +7,7 @@ const {
   StatWatcher: _StatWatcher
 } = process.binding('fs');
 const { FSEvent } = internalBinding('fs_event_wrap');
+const { UV_ENOSPC } = internalBinding('uv');
 const { EventEmitter } = require('events');
 const {
   getStatsFromBinding,
@@ -165,7 +166,9 @@ FSWatcher.prototype.start = function(filename,
     const error = errors.uvException({
       errno: err,
       syscall: 'watch',
-      path: filename
+      path: filename,
+      description: err === UV_ENOSPC ?
+        'System limit for number of file watchers reached' : ''
     });
     error.filename = filename;
     throw error;
diff --git a/test/sequential/test-fs-watch-system-limit.js b/test/sequential/test-fs-watch-system-limit.js
new file mode 100644
index 00000000000000..2e7066a6916acc
--- /dev/null
+++ b/test/sequential/test-fs-watch-system-limit.js
@@ -0,0 +1,50 @@
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const child_process = require('child_process');
+const stream = require('stream');
+
+if (!common.isLinux)
+  common.skip('The fs watch limit is OS-dependent');
+
+const processes = [];
+const gatherStderr = new stream.PassThrough();
+gatherStderr.setEncoding('utf8');
+gatherStderr.setMaxListeners(Infinity);
+
+let finished = false;
+function spawnProcesses() {
+  for (let i = 0; i < 10; ++i) {
+    const proc = child_process.spawn(
+      process.execPath,
+      [ '-e',
+        `process.chdir(${JSON.stringify(__dirname)});
+        for (const file of fs.readdirSync('.'))
+          fs.watch(file, () => {});`
+      ], { stdio: ['inherit', 'inherit', 'pipe'] });
+    proc.stderr.pipe(gatherStderr);
+    processes.push(proc);
+  }
+
+  setTimeout(() => {
+    if (!finished && processes.length < 200)
+      spawnProcesses();
+  }, 100);
+}
+
+spawnProcesses();
+
+let accumulated = '';
+gatherStderr.on('data', common.mustCallAtLeast((chunk) => {
+  accumulated += chunk;
+  // console.log(chunk);
+  if (accumulated.includes('Error:') && !finished) {
+    assert(
+      accumulated.includes('ENOSPC: System limit for number ' +
+                           'of file watchers reached'),
+      accumulated);
+    console.log(`done after ${processes.length} processes, cleaning up`);
+    finished = true;
+    processes.forEach((proc) => proc.kill());
+  }
+}, 1));