diff options
Diffstat (limited to 'src/lib/workers-list.js')
| -rw-r--r-- | src/lib/workers-list.js | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/lib/workers-list.js b/src/lib/workers-list.js index 3f2246e..c779ec2 100644 --- a/src/lib/workers-list.js +++ b/src/lib/workers-list.js @@ -35,11 +35,12 @@ class WorkersList { /** * @param {Connection} connection * @param {string[]} targets + * @param {string} name */ - add(connection, targets) { - this.logger.info(`add: connection from ${connection.remoteAddr()}, targets ${JSON.stringify(targets)}`) + add(connection, {targets, name}) { + this.logger.info(`add: connection from ${connection.remoteAddr()}, name ${name}, targets ${JSON.stringify(targets)}`) - this.workers.push({connection, targets}) + this.workers.push({connection, targets, name}) connection.on('close', () => { this.logger.info(`connection from ${connection.remoteAddr()} closed, removing worker`) this.workers = this.workers.filter(worker => { @@ -161,7 +162,8 @@ class WorkersList { const workerInfo = { remoteAddr: worker.connection.socket?.remoteAddress, remotePort: worker.connection.socket?.remotePort, - targets: worker.targets + targets: worker.targets, + name: worker.name, } if (pollWorkers) { |