Function testServer

test/parallel/test-child-process-fork-net-server.js:86–149

(callback)

  // Send net.Server to child and test by connecting.
  function testServer(callback) {

    // Destroy server execute callback when done.
    const countdown = new Countdown(2, common.mustCall(() => {
      server.on('close', common.mustCall(() => {
        debug('PARENT: server closed');
        child.send({ what: 'close' });
      }));
      server.close();
    }));

    // We expect 4 connections and close events.
    const connections = new Countdown(4, () => countdown.dec());
    const closed = new Countdown(4, () => countdown.dec());

    // Create server and send it to child.
    const server = net.createServer();

    // TODO(@jasnell): The specific number of times the connection
    // event is emitted appears to be variable across platforms.
    // Need to investigate why and whether it can be made
    // more consistent.
    server.on('connection', (socket) => {
      debug('PARENT: got connection');
      socket.destroy();
      connections.dec();
    });

    server.on('listening', common.mustCall(() => {
      debug('PARENT: server listening');
      child.send({ what: 'server' }, server);
    }));
    server.listen(0);

    // Handle client messages.
    // TODO(@jasnell): The specific number of times the message
    // event is emitted appears to be variable across platforms.
    // Need to investigate why and whether it can be made
    // more consistent.
    const messageHandlers = common.mustCallAtLeast((msg) => {
      if (msg.what === 'listening') {
        // Make connections.
        let socket;
        for (let i = 0; i < 4; i++) {
          socket = net.connect(server.address().port, common.mustCall(() => {
            debug('CLIENT: connected');
          }));
          socket.on('close', common.mustCall(() => {
            closed.dec();
            debug('CLIENT: closed');
          }));
        }

      } else if (msg.what === 'connection') {
        // Child got connection
        connections.dec();
      } else if (msg.what === 'close') {
        child.removeListener('message', messageHandlers);