| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -261,6 +261,7 @@ overrides: | |||
| 261 | 261 | - ./internal/assert.js | |
| 262 | 262 | - ./internal/child_process/*.js | |
| 263 | 263 | - ./internal/cli_table.js | |
| 264 | + - ./internal/cluster/*.js | ||
| 264 | 265 | - ./internal/debugger/inspect.js | |
| 265 | 266 | - ./internal/events/*.js | |
| 266 | 267 | - ./internal/fixed_queue.js | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -35,7 +35,7 @@ cluster._setupWorker = function() { | |||
| 35 | 35 | const worker = new Worker({ | |
| 36 | 36 | id: +process.env.NODE_UNIQUE_ID | 0, | |
| 37 | 37 | process: process, | |
| 38 | - state: 'online' | ||
| 38 | + state: 'online', | ||
| 39 | 39 | }); | |
| 40 | 40 | ||
| 41 | 41 | cluster.worker = worker; | |
@@ -91,7 +91,7 @@ cluster._getServer = function(obj, options, cb) { | |||
| 91 | 91 | act: 'queryServer', | |
| 92 | 92 | index, | |
| 93 | 93 | data: null, | |
| 94 | - ...options | ||
| 94 | + ...options, | ||
| 95 | 95 | }; | |
| 96 | 96 | ||
| 97 | 97 | 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