xref: /third_party/node/test/parallel/test-diagnostics-channel-net.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 assert = require('assert');
41cb0ef41Sopenharmony_ciconst net = require('net');
51cb0ef41Sopenharmony_ciconst dc = require('diagnostics_channel');
61cb0ef41Sopenharmony_ci
71cb0ef41Sopenharmony_ciconst isNetSocket = (socket) => socket instanceof net.Socket;
81cb0ef41Sopenharmony_ci
91cb0ef41Sopenharmony_cidc.subscribe('net.client.socket', common.mustCall(({ socket }) => {
101cb0ef41Sopenharmony_ci  assert.strictEqual(isNetSocket(socket), true);
111cb0ef41Sopenharmony_ci}));
121cb0ef41Sopenharmony_ci
131cb0ef41Sopenharmony_cidc.subscribe('net.server.socket', common.mustCall(({ socket }) => {
141cb0ef41Sopenharmony_ci  assert.strictEqual(isNetSocket(socket), true);
151cb0ef41Sopenharmony_ci}));
161cb0ef41Sopenharmony_ci
171cb0ef41Sopenharmony_ciconst server = net.createServer(common.mustCall((socket) => {
181cb0ef41Sopenharmony_ci  socket.destroy();
191cb0ef41Sopenharmony_ci  server.close();
201cb0ef41Sopenharmony_ci}));
211cb0ef41Sopenharmony_ci
221cb0ef41Sopenharmony_ciserver.listen(() => {
231cb0ef41Sopenharmony_ci  const { port } = server.address();
241cb0ef41Sopenharmony_ci  net.connect(port);
251cb0ef41Sopenharmony_ci});
26

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