net: always publish to 'net.client.socket' diagnostics channel · nodejs/node@b0e0b1a
11'use strict';
22const common = require('../common');
3+const Countdown = require('../common/countdown');
34const assert = require('assert');
45const net = require('net');
56const dc = require('diagnostics_channel');
@@ -18,19 +19,23 @@ function testDiagnosticChannel(subscribers, test, after) {
18191920const testSuccessfulListen = common.mustCall(() => {
2021let cb;
21-const server = net.createServer(common.mustCall((socket) => {
22- socket.destroy();
22+const netClientSocketCount = 3;
23+const countdown = new Countdown(netClientSocketCount, () => {
2324server.close();
2425cb();
25-}));
26+});
27+const server = net.createServer(common.mustCall((socket) => {
28+socket.destroy();
29+countdown.dec();
30+}, netClientSocketCount));
26312732dc.subscribe('net.client.socket', common.mustCall(({ socket }) => {
2833assert.strictEqual(isNetSocket(socket), true);
29-}));
34+}, netClientSocketCount));
30353136dc.subscribe('net.server.socket', common.mustCall(({ socket }) => {
3237assert.strictEqual(isNetSocket(socket), true);
33-}));
38+}, netClientSocketCount));
34393540testDiagnosticChannel(
3641{
@@ -48,8 +53,13 @@ const testSuccessfulListen = common.mustCall(() => {
4853common.mustCall((callback) => {
4954cb = callback;
5055server.listen({ port: 0, customOption: true }, () => {
56+// All supported ways of creating a net client socket connection.
5157const { port } = server.address();
5258net.connect(port);
59+60+net.createConnection(port);
61+62+new net.Socket().connect(port);
5363});
5464}),
5565testFailingListen