| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
1 parent 9e4ce6f commit c5e806c
1 file changed
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1,46 +1,43 @@ | |||
| 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 | + })); | ||
| Back | FazBrowse Home | New Git URL |
0 commit comments