xref: /third_party/node/test/parallel/test-cluster-worker-disconnect-on-error.js (revision 1cb0ef41)
  • Home
  • History
  • Annotate Annotate
  • Line#
  • Scopes#
  • Navigate#
  • Raw
  • Download
  • only in /third_party/node/test/parallel/
11cb0ef41Sopenharmony_ci'use strict';
21cb0ef41Sopenharmony_ciconst common = require('../common');
31cb0ef41Sopenharmony_ciconst http = require('http');
41cb0ef41Sopenharmony_ciconst cluster = require('cluster');
51cb0ef41Sopenharmony_ciconst assert = require('assert');
61cb0ef41Sopenharmony_ci
71cb0ef41Sopenharmony_cicluster.schedulingPolicy = cluster.SCHED_NONE;
81cb0ef41Sopenharmony_ci
91cb0ef41Sopenharmony_ciconst server = http.createServer();
101cb0ef41Sopenharmony_ciif (cluster.isPrimary) {
111cb0ef41Sopenharmony_ci  let worker;
121cb0ef41Sopenharmony_ci
131cb0ef41Sopenharmony_ci  server.listen(0, common.mustSucceed(() => {
141cb0ef41Sopenharmony_ci    assert(worker);
151cb0ef41Sopenharmony_ci
161cb0ef41Sopenharmony_ci    worker.send({ port: server.address().port });
171cb0ef41Sopenharmony_ci  }));
181cb0ef41Sopenharmony_ci
191cb0ef41Sopenharmony_ci  worker = cluster.fork();
201cb0ef41Sopenharmony_ci  worker.on('exit', common.mustCall(() => {
211cb0ef41Sopenharmony_ci    server.close();
221cb0ef41Sopenharmony_ci  }));
231cb0ef41Sopenharmony_ci} else {
241cb0ef41Sopenharmony_ci  process.on('message', common.mustCall((msg) => {
251cb0ef41Sopenharmony_ci    assert(msg.port);
261cb0ef41Sopenharmony_ci
271cb0ef41Sopenharmony_ci    server.listen(msg.port);
281cb0ef41Sopenharmony_ci    server.on('error', common.mustCall((e) => {
291cb0ef41Sopenharmony_ci      cluster.worker.disconnect();
301cb0ef41Sopenharmony_ci    }));
311cb0ef41Sopenharmony_ci  }));
321cb0ef41Sopenharmony_ci}
33

Indexes created Thu Nov 07 10:32:03 CST 2024