File: test-dgram-pingpong.js

package info (click to toggle)
nodejs 20.19.2%2Bdfsg-1
  • links: PTS, VCS
  • area: main
  • in suites: sid, trixie
  • size: 219,072 kB
  • sloc: cpp: 1,277,408; javascript: 565,332; ansic: 129,476; python: 58,536; sh: 3,841; makefile: 2,725; asm: 1,732; perl: 248; lisp: 222; xml: 42
file content (46 lines) | stat: -rw-r--r-- 1,097 bytes parent folder | download | duplicates (5)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
'use strict';
const common = require('../common');
const assert = require('assert');
const dgram = require('dgram');

function pingPongTest(port, host) {

  const server = dgram.createSocket('udp4', common.mustCall((msg, rinfo) => {
    assert.strictEqual(msg.toString('ascii'), 'PING');
    server.send('PONG', 0, 4, rinfo.port, rinfo.address);
  }));

  server.on('error', function(e) {
    throw e;
  });

  server.on('listening', function() {
    console.log(`server listening on ${port}`);

    const client = dgram.createSocket('udp4');

    client.on('message', function(msg) {
      assert.strictEqual(msg.toString('ascii'), 'PONG');

      client.close();
      server.close();
    });

    client.on('error', function(e) {
      throw e;
    });

    console.log(`Client sending to ${port}`);

    function clientSend() {
      client.send('PING', 0, 4, port, 'localhost');
    }

    clientSend();
  });
  server.bind(port, host);
  return server;
}

const server = pingPongTest(common.PORT, 'localhost');
server.on('close', common.mustCall(pingPongTest.bind(undefined, common.PORT)));