| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -273,6 +273,7 @@ overrides: | |||
| 273 | 273 | - ./internal/assert.js | |
| 274 | 274 | - ./internal/child_process/*.js | |
| 275 | 275 | - ./internal/cli_table.js | |
| 276 | + - ./internal/cluster/*.js | ||
| 276 | 277 | - ./internal/debugger/inspect.js | |
| 277 | 278 | - ./internal/events/*.js | |
| 278 | 279 | - ./internal/fixed_queue.js | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -36,7 +36,7 @@ cluster._setupWorker = function() { | |||
| 36 | 36 | const worker = new Worker({ | |
| 37 | 37 | id: +process.env.NODE_UNIQUE_ID | 0, | |
| 38 | 38 | process: process, | |
| 39 | - state: 'online' | ||
| 39 | + state: 'online', | ||
| 40 | 40 | }); | |
| 41 | 41 | ||
| 42 | 42 | cluster.worker = worker; | |
@@ -92,7 +92,7 @@ cluster._getServer = function(obj, options, cb) { | |||
| 92 | 92 | act: 'queryServer', | |
| 93 | 93 | index, | |
| 94 | 94 | data: null, | |
| 95 | - ...options | ||
| 95 | + ...options, | ||
| 96 | 96 | }; | |
| 97 | 97 | ||
| 98 | 98 | message.address = address; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -12,7 +12,7 @@ const { | |||
| 12 | 12 | const { | |
| 13 | 13 | codes: { | |
| 14 | 14 | ERR_SOCKET_BAD_PORT, | |
| 15 | - } | ||
| 15 | + }, | ||
| 16 | 16 | } = require('internal/errors'); | |
| 17 | 17 | ||
| 18 | 18 | const assert = require('internal/assert'); | |
@@ -66,7 +66,7 @@ cluster.setupPrimary = function(options) { | |||
| 66 | 66 | execArgv: process.execArgv, | |
| 67 | 67 | silent: false, | |
| 68 | 68 | ...cluster.settings, | |
| 69 | - ...options | ||
| 69 | + ...options, | ||
| 70 | 70 | }; | |
| 71 | 71 | ||
| 72 | 72 | // Tell V8 to write profile data for each process to a separate file. | |
@@ -135,7 +135,7 @@ function createWorkerProcess(id, env) { | |||
| 135 | 135 | execArgv: execArgv, | |
| 136 | 136 | stdio: cluster.settings.stdio, | |
| 137 | 137 | gid: cluster.settings.gid, | |
| 138 | - uid: cluster.settings.uid | ||
| 138 | + uid: cluster.settings.uid, | ||
| 139 | 139 | }); | |
| 140 | 140 | } | |
| 141 | 141 | ||
@@ -164,7 +164,7 @@ cluster.fork = function(env) { | |||
| 164 | 164 | const workerProcess = createWorkerProcess(id, env); | |
| 165 | 165 | const worker = new Worker({ | |
| 166 | 166 | id: id, | |
| 167 | - process: workerProcess | ||
| 167 | + process: workerProcess, | ||
| 168 | 168 | }); | |
| 169 | 169 | ||
| 170 | 170 | worker.on('message', function(message, handle) { | |
@@ -316,7 +316,7 @@ function queryServer(worker, message) { | |||
| 316 | 316 | key, | |
| 317 | 317 | ack: message.seq, | |
| 318 | 318 | data, | |
| 319 | - ...reply | ||
| 319 | + ...reply, | ||
| 320 | 320 | }, handle); | |
| 321 | 321 | }); | |
| 322 | 322 | } | |
@@ -326,7 +326,7 @@ function listening(worker, message) { | |||
| 326 | 326 | addressType: message.addressType, | |
| 327 | 327 | address: message.address, | |
| 328 | 328 | port: message.port, | |
| 329 | - fd: message.fd | ||
| 329 | + fd: message.fd, | ||
| 330 | 330 | }; | |
| 331 | 331 | ||
| 332 | 332 | worker.state = 'listening'; | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -7,7 +7,7 @@ const { | |||
| 7 | 7 | ||
| 8 | 8 | module.exports = { | |
| 9 | 9 | sendHelper, | |
| 10 | - internal | ||
| 10 | + internal, | ||
| 11 | 11 | }; | |
| 12 | 12 | ||
| 13 | 13 | const callbacks = new SafeMap(); | |
| Back | FazBrowse Home | New Git URL |
0 commit comments