Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorcjihrig <cjihrig@gmail.com>2018-09-27 16:49:38 +0300
committercjihrig <cjihrig@gmail.com>2018-09-30 18:03:54 +0300
commit6654c5945263a3ced718b94a89c70fdc9b061500 (patch)
tree00c601f4b30b431cfc40ce108b4873b431728fbf /lib/internal/cluster
parent97dad7e33b24ce4163fdf95b8a32300f25492aef (diff)
cluster: use Map to track round robin workers
PR-URL: https://github.com/nodejs/node/pull/23125 Reviewed-By: Gus Caplan <me@gus.host> Reviewed-By: Michaƫl Zasso <targos@protonmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com> Reviewed-By: Denys Otrishko <shishugi@gmail.com>
Diffstat (limited to 'lib/internal/cluster')
-rw-r--r--lib/internal/cluster/round_robin_handle.js16
1 files changed, 8 insertions, 8 deletions
diff --git a/lib/internal/cluster/round_robin_handle.js b/lib/internal/cluster/round_robin_handle.js
index e351f433ab8..9f09d9fbf76 100644
--- a/lib/internal/cluster/round_robin_handle.js
+++ b/lib/internal/cluster/round_robin_handle.js
@@ -2,7 +2,6 @@
const assert = require('assert');
const net = require('net');
const { sendHelper } = require('internal/cluster/utils');
-const getOwnPropertyNames = Object.getOwnPropertyNames;
const { internalBinding } = require('internal/bootstrap/loaders');
const uv = internalBinding('uv');
@@ -10,7 +9,7 @@ module.exports = RoundRobinHandle;
function RoundRobinHandle(key, address, port, addressType, fd) {
this.key = key;
- this.all = {};
+ this.all = new Map();
this.free = [];
this.handles = [];
this.handle = null;
@@ -32,8 +31,8 @@ function RoundRobinHandle(key, address, port, addressType, fd) {
}
RoundRobinHandle.prototype.add = function(worker, send) {
- assert(worker.id in this.all === false);
- this.all[worker.id] = worker;
+ assert(this.all.has(worker.id) === false);
+ this.all.set(worker.id, worker);
const done = () => {
if (this.handle.getsockname) {
@@ -62,16 +61,17 @@ RoundRobinHandle.prototype.add = function(worker, send) {
};
RoundRobinHandle.prototype.remove = function(worker) {
- if (worker.id in this.all === false)
+ const existed = this.all.delete(worker.id);
+
+ if (!existed)
return false;
- delete this.all[worker.id];
const index = this.free.indexOf(worker);
if (index !== -1)
this.free.splice(index, 1);
- if (getOwnPropertyNames(this.all).length !== 0)
+ if (this.all.size !== 0)
return false;
for (var handle; handle = this.handles.shift(); handle.close())
@@ -91,7 +91,7 @@ RoundRobinHandle.prototype.distribute = function(err, handle) {
};
RoundRobinHandle.prototype.handoff = function(worker) {
- if (worker.id in this.all === false) {
+ if (this.all.has(worker.id) === false) {
return; // Worker is closing (or has closed) the server.
}