Skip to content

Commit 6bcc8cd

Browse files
committed
Track workers starting
1 parent 2155c9d commit 6bcc8cd

File tree

1 file changed

+16
-2
lines changed
  • src/BenchmarksApps/TechEmpower/nextjs

1 file changed

+16
-2
lines changed

src/BenchmarksApps/TechEmpower/nextjs/server.ts

Lines changed: 16 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,13 +33,27 @@ if (!dev) {
3333
//console.log(`server.js found at: ${server}`);
3434

3535
if (cluster.isPrimary) {
36-
console.log(`Primary ${process.pid} is running`);
36+
console.log(`Primary is running on process ${process.pid}`);
3737

38+
cluster.setupPrimary({ silent: true });
3839
const numCPUs = os.cpus().length;
3940

4041
// Fork workers
42+
let listening = 0;
4143
for (let i = 0; i < numCPUs; i++) {
42-
cluster.fork();
44+
const w = cluster.fork();
45+
w.process.stdout?.on('data', (chunk) => {
46+
const msg = chunk.toString().trim();
47+
if (msg.startsWith('Listening on port')) {
48+
listening++;
49+
console.log(`Worker ${listening} of ${numCPUs} on process ${w.process.pid}: ${msg}`);
50+
if (listening == numCPUs) {
51+
console.log('All workers listening.');
52+
}
53+
} else {
54+
console.log(`Worker ${w.id}: ${msg}`)
55+
}
56+
});
4357
}
4458

4559
cluster.on('exit', (worker, code, signal) => {

0 commit comments

Comments
 (0)