| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -19,10 +19,10 @@ if (cluster.isMaster) { | |||
| 19 | 19 | serialization | |
| 20 | 20 | }) { | |
| 21 | 21 | const expectedPerBroadcast = sendsPerBroadcast * workers; | |
| 22 | - var readies = 0; | ||
| 23 | - var broadcasts = 0; | ||
| 24 | - var msgCount = 0; | ||
| 25 | - var data; | ||
| 22 | + let readies = 0; | ||
| 23 | + let broadcasts = 0; | ||
| 24 | + let msgCount = 0; | ||
| 25 | + let data; | ||
| 26 | 26 | ||
| 27 | 27 | cluster.settings.serialization = serialization; | |
| 28 | 28 | ||
@@ -37,7 +37,7 @@ if (cluster.isMaster) { | |||
| 37 | 37 | throw new Error('Unsupported payload type'); | |
| 38 | 38 | } | |
| 39 | 39 | ||
| 40 | - for (var i = 0; i < workers; ++i) | ||
| 40 | + for (let i = 0; i < workers; ++i) | ||
| 41 | 41 | cluster.fork().on('online', onOnline).on('message', onMessage); | |
| 42 | 42 | ||
| 43 | 43 | function onOnline() { | |
@@ -48,16 +48,15 @@ if (cluster.isMaster) { | |||
| 48 | 48 | } | |
| 49 | 49 | ||
| 50 | 50 | function broadcast() { | |
| 51 | - var id; | ||
| 52 | 51 | if (broadcasts++ === n) { | |
| 53 | 52 | bench.end(n); | |
| 54 | - for (id in cluster.workers) | ||
| 53 | + for (const id in cluster.workers) | ||
| 55 | 54 | cluster.workers[id].disconnect(); | |
| 56 | 55 | return; | |
| 57 | 56 | } | |
| 58 | - for (id in cluster.workers) { | ||
| 57 | + for (const id in cluster.workers) { | ||
| 59 | 58 | const worker = cluster.workers[id]; | |
| 60 | - for (var i = 0; i < sendsPerBroadcast; ++i) | ||
| 59 | + for (let i = 0; i < sendsPerBroadcast; ++i) | ||
| 61 | 60 | worker.send(data); | |
| 62 | 61 | } | |
| 63 | 62 | } | |
| Back | FazBrowse Home | New Git URL |
0 commit comments