refactor: cleanup debug code

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>

diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts
index f931a46670771b6564405000ed6f96943cc29d5f..a963f6bde00d3e1a9b374ea757aad903b83919ff 100644 (file)
--- a/src/pools/abstract-pool.ts
+++ b/src/pools/abstract-pool.ts
@@ -245,14 +245,6 @@ export abstract class AbstractPool<
     }
   }
 
-  private get starting (): boolean {
-    return this.workerNodes.some(workerNode => !workerNode.info.started)
-  }
-
-  private get started (): boolean {
-    return this.workerNodes.some(workerNode => workerNode.info.started)
-  }
-
   /** @inheritDoc */
   public get info (): PoolInfo {
     return {
@@ -770,7 +762,7 @@ export abstract class AbstractPool<
       if (this.emitter != null) {
         this.emitter.emit(PoolEvents.error, error)
       }
-      if (this.opts.restartWorkerOnError === true && !this.starting) {
+      if (this.opts.restartWorkerOnError === true) {
         this.createAndSetupWorker()
       }
     })

diff --git a/src/worker/cluster-worker.ts b/src/worker/cluster-worker.ts
index 16dddd2969bd50193c4fb43e762d607f08f4ca08..180a5273f464cfee65f5a4b0d6d4f1a8032200fc 100644 (file)
--- a/src/worker/cluster-worker.ts
+++ b/src/worker/cluster-worker.ts
@@ -41,9 +41,6 @@ export class ClusterWorker<
       cluster.worker as Worker,
       opts
     )
-    if (!this.isMain) {
-      this.sendToMainWorker({ workerId: this.id, started: true })
-    }
   }
 
   /** @inheritDoc */
@@ -53,7 +50,6 @@ export class ClusterWorker<
 
   /** @inheritDoc */
   protected sendToMainWorker (message: MessageValue<Response>): void {
-    console.log('sending message to main worker(cluster)', message)
     this.getMainWorker().send(message)
   }
 

diff --git a/src/worker/thread-worker.ts b/src/worker/thread-worker.ts
index 7a766a958ccbb41c9b29bbe76c04890eec61604d..2b3df58361eb28a9d0ccc2f694208bb0e4426c02 100644 (file)
--- a/src/worker/thread-worker.ts
+++ b/src/worker/thread-worker.ts
@@ -46,9 +46,6 @@ export class ThreadWorker<
       parentPort as MessagePort,
       opts
     )
-    if (!this.isMain) {
-      this.sendToMainWorker({ workerId: this.id, started: true })
-    }
   }
 
   protected get id (): number {
@@ -57,7 +54,6 @@ export class ThreadWorker<
 
   /** @inheritDoc */
   protected sendToMainWorker (message: MessageValue<Response>): void {
-    console.log('sending message to main worker(thread)', message)
     this.getMainWorker().postMessage(message)
   }
 }

diff --git a/tests/pools/abstract/abstract-pool.test.js b/tests/pools/abstract/abstract-pool.test.js
index 7c42d34a99f09efd9b3314ecff6ce14ac016783f..023b56b414c4c3453d269c5f5605d0e69a8c4275 100644 (file)
--- a/tests/pools/abstract/abstract-pool.test.js
+++ b/tests/pools/abstract/abstract-pool.test.js
@@ -407,9 +407,6 @@ describe('Abstract pool test suite', () => {
       maxQueuedTasks: 0,
       failedTasks: 0
     })
-    for (const workerNode of pool.workerNodes) {
-      console.log('thread:workerNode.info', workerNode.info)
-    }
     await pool.destroy()
     pool = new DynamicClusterPool(
       numberOfWorkers,
@@ -431,9 +428,6 @@ describe('Abstract pool test suite', () => {
       maxQueuedTasks: 0,
       failedTasks: 0
     })
-    for (const workerNode of pool.workerNodes) {
-      console.log('cluster:workerNode.info', workerNode.info)
-    }
     await pool.destroy()
   })