|
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