summaryrefslogtreecommitdiff
path: root/test/sequential/test-dgram-pingpong.js
blob: 33b01fbe22a9b93eab66498302c1879fb1857033 (plain)
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)));