◐ Shell
clean mode source ↗

net: always publish to 'net.client.socket' diagnostics channel · nodejs/node@b0e0b1a

11

'use strict';

22

const common = require('../common');

3+

const Countdown = require('../common/countdown');

34

const assert = require('assert');

45

const net = require('net');

56

const dc = require('diagnostics_channel');

@@ -18,19 +19,23 @@ function testDiagnosticChannel(subscribers, test, after) {

18191920

const testSuccessfulListen = common.mustCall(() => {

2021

let cb;

21-

const server = net.createServer(common.mustCall((socket) => {

22-

socket.destroy();

22+

const netClientSocketCount = 3;

23+

const countdown = new Countdown(netClientSocketCount, () => {

2324

server.close();

2425

cb();

25-

}));

26+

});

27+

const server = net.createServer(common.mustCall((socket) => {

28+

socket.destroy();

29+

countdown.dec();

30+

}, netClientSocketCount));

26312732

dc.subscribe('net.client.socket', common.mustCall(({ socket }) => {

2833

assert.strictEqual(isNetSocket(socket), true);

29-

}));

34+

}, netClientSocketCount));

30353136

dc.subscribe('net.server.socket', common.mustCall(({ socket }) => {

3237

assert.strictEqual(isNetSocket(socket), true);

33-

}));

38+

}, netClientSocketCount));

34393540

testDiagnosticChannel(

3641

{

@@ -48,8 +53,13 @@ const testSuccessfulListen = common.mustCall(() => {

4853

common.mustCall((callback) => {

4954

cb = callback;

5055

server.listen({ port: 0, customOption: true }, () => {

56+

// All supported ways of creating a net client socket connection.

5157

const { port } = server.address();

5258

net.connect(port);

59+60+

net.createConnection(port);

61+62+

new net.Socket().connect(port);

5363

});

5464

}),

5565

testFailingListen