|
1 | 1 | 'use strict'; |
2 | | -var common = require('../common'); |
3 | | -var assert = require('assert'); |
| 2 | + |
| 3 | +const common = require('../common'); |
4 | 4 |
|
5 | 5 | if (!common.hasCrypto) { |
6 | 6 | common.skip('missing crypto'); |
7 | 7 | return; |
8 | 8 | } |
9 | | -var tls = require('tls'); |
10 | 9 |
|
11 | | -var net = require('net'); |
12 | | -var fs = require('fs'); |
| 10 | +const assert = require('assert'); |
| 11 | +const tls = require('tls'); |
| 12 | + |
| 13 | +const net = require('net'); |
| 14 | +const fs = require('fs'); |
13 | 15 |
|
14 | | -var options = { |
| 16 | +const options = { |
15 | 17 | key: fs.readFileSync(common.fixturesDir + '/test_key.pem'), |
16 | 18 | cert: fs.readFileSync(common.fixturesDir + '/test_cert.pem') |
17 | 19 | }; |
18 | 20 |
|
19 | | -var bonkers = Buffer.alloc(1024 * 1024, 42); |
| 21 | +const bonkers = Buffer.alloc(1024 * 1024, 42); |
20 | 22 |
|
21 | | -var server = tls.createServer(options, function(c) { |
| 23 | +const server = tls.createServer(options, function(c) { |
22 | 24 |
|
23 | | -}).listen(0, function() { |
24 | | - var client = net.connect(this.address().port, function() { |
| 25 | +}).listen(0, common.mustCall(function() { |
| 26 | + const client = net.connect(this.address().port, common.mustCall(function() { |
25 | 27 | client.write(bonkers); |
26 | | - }); |
| 28 | + })); |
27 | 29 |
|
28 | | - var once = false; |
29 | | - |
30 | | - var writeAgain = setTimeout(function() { |
| 30 | + const writeAgain = setImmediate(function() { |
31 | 31 | client.write(bonkers); |
32 | 32 | }); |
33 | 33 |
|
34 | | - client.on('error', function(err) { |
35 | | - if (!once) { |
36 | | - clearTimeout(writeAgain); |
37 | | - once = true; |
38 | | - client.destroy(); |
39 | | - server.close(); |
40 | | - } |
41 | | - }); |
| 34 | + client.once('error', common.mustCall(function(err) { |
| 35 | + clearImmediate(writeAgain); |
| 36 | + client.destroy(); |
| 37 | + server.close(); |
| 38 | + })); |
42 | 39 |
|
43 | | - client.on('close', function(hadError) { |
| 40 | + client.on('close', common.mustCall(function(hadError) { |
44 | 41 | assert.strictEqual(hadError, true, 'Client never errored'); |
45 | | - }); |
46 | | -}); |
| 42 | + })); |
| 43 | +})); |
0 commit comments