X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fabstract-worker.ts;h=950738b26f0a47f16f0f1eadd93be5f759a8024d;hb=310de0aa5d5b3887a4de4ef6a0b42e7b7a560987;hp=ff31fc7cb1879e19435c7942ca34c80b1a5a2051;hpb=30369cc0f200d553cfc72fce6e8685c66fa1e344;p=poolifier.git diff --git a/src/worker/abstract-worker.ts b/src/worker/abstract-worker.ts index ff31fc7c..950738b2 100644 --- a/src/worker/abstract-worker.ts +++ b/src/worker/abstract-worker.ts @@ -320,24 +320,25 @@ export abstract class AbstractWorker< protected messageListener (message: MessageValue): void { if (this.isMain) { throw new Error('Cannot handle message to worker in main worker') + } else if (message.workerId == null) { + throw new Error('Message worker id is not set') } else if (message.workerId != null && message.workerId !== this.id) { throw new Error( `Message worker id ${message.workerId} does not match the worker id ${this.id}` ) - } else if (message.workerId === this.id) { - if (message.statistics != null) { - // Statistics message received - this.statistics = message.statistics - } else if (message.checkActive != null) { - // Check active message received - message.checkActive ? this.startCheckActive() : this.stopCheckActive() - } else if (message.taskId != null && message.data != null) { - // Task message received - this.run(message) - } else if (message.kill === true) { - // Kill message received - this.handleKillMessage(message) - } + } + if (message.statistics != null) { + // Statistics message received + this.statistics = message.statistics + } else if (message.checkActive != null) { + // Check active message received + message.checkActive ? this.startCheckActive() : this.stopCheckActive() + } else if (message.taskId != null && message.data != null) { + // Task message received + this.run(message) + } else if (message.kill === true) { + // Kill message received + this.handleKillMessage(message) } } @@ -473,26 +474,27 @@ export abstract class AbstractWorker< fn: TaskSyncFunction, task: Task ): void { + const { name, taskId, data } = task try { - let taskPerformance = this.beginTaskPerformance(task.name) - const res = fn(task.data) + let taskPerformance = this.beginTaskPerformance(name) + const res = fn(data) taskPerformance = this.endTaskPerformance(taskPerformance) this.sendToMainWorker({ data: res, taskPerformance, workerId: this.id, - taskId: task.taskId + taskId }) } catch (e) { const errorMessage = this.handleError(e as Error | string) this.sendToMainWorker({ taskError: { - name: task.name ?? DEFAULT_TASK_NAME, + name: name ?? DEFAULT_TASK_NAME, message: errorMessage, - data: task.data + data }, workerId: this.id, - taskId: task.taskId + taskId }) } finally { this.updateLastTaskTimestamp() @@ -509,15 +511,16 @@ export abstract class AbstractWorker< fn: TaskAsyncFunction, task: Task ): void { - let taskPerformance = this.beginTaskPerformance(task.name) - fn(task.data) + const { name, taskId, data } = task + let taskPerformance = this.beginTaskPerformance(name) + fn(data) .then((res) => { taskPerformance = this.endTaskPerformance(taskPerformance) this.sendToMainWorker({ data: res, taskPerformance, workerId: this.id, - taskId: task.taskId + taskId }) return null }) @@ -525,12 +528,12 @@ export abstract class AbstractWorker< const errorMessage = this.handleError(e as Error | string) this.sendToMainWorker({ taskError: { - name: task.name ?? DEFAULT_TASK_NAME, + name: name ?? DEFAULT_TASK_NAME, message: errorMessage, - data: task.data + data }, workerId: this.id, - taskId: task.taskId + taskId }) }) .finally(() => {