fix #318: debug ports not being released when terminating a pool

josdejong · Nov 7, 2022 · 5d4309d · 5d4309d
1 parent bc22074
commit 5d4309d
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/HISTORY.md b/HISTORY.md
@@ -2,6 +2,11 @@
 https://github.com/josdejong/workerpool
 
 
+## 2022-11-07, version 6.3.1
+
+- Fix #318: debug ports not being released when terminating a pool.
+
+
 ## 2022-10-24, version 6.3.0
 
 - Implement option `workerThreadOpts` to pass options to a worker of type 

diff --git a/src/Pool.js b/src/Pool.js
@@ -25,7 +25,7 @@ function Pool(script, options) {
 
   this.forkArgs = Object.freeze(options.forkArgs || []);
   this.forkOpts = Object.freeze(options.forkOpts || {});
-  this.workerThreadOpts = Object.freeze(options.workerThreadOpts || {}) 
+  this.workerThreadOpts = Object.freeze(options.workerThreadOpts || {})
   this.debugPortStart = (options.debugPortStart || 43210);
   this.nodeWorker = options.nodeWorker;
   this.workerType = options.workerType || options.nodeWorker || 'auto'
@@ -326,6 +326,7 @@ Pool.prototype.terminate = function (force, timeout) {
   this.tasks.length = 0;
 
   var f = function (worker) {
+    DEBUG_PORT_ALLOCATOR.releasePort(worker.debugPort);
     this._removeWorkerFromList(worker);
   };
   var removeWorker = f.bind(this);