|
1 | 1 | 'use strict'; |
2 | | -var common = require('../common'); |
3 | | -var assert = require('assert'); |
4 | | -var http = require('http'); |
5 | | -var net = require('net'); |
| 2 | +const common = require('../common'); |
| 3 | +const assert = require('assert'); |
| 4 | +const http = require('http'); |
| 5 | +const net = require('net'); |
6 | 6 |
|
7 | 7 | var server = http.createServer(function(req, res) { |
8 | | - console.log('got request. setting 1 second timeout'); |
9 | | - var s = req.connection.setTimeout(500); |
10 | | - assert.ok(s instanceof net.Socket); |
11 | | - req.connection.on('timeout', function() { |
| 8 | + console.log('got request. setting 500ms timeout'); |
| 9 | + var socket = req.connection.setTimeout(500); |
| 10 | + assert.ok(socket instanceof net.Socket); |
| 11 | + req.connection.on('timeout', common.mustCall(function() { |
12 | 12 | req.connection.destroy(); |
13 | 13 | console.error('TIMEOUT'); |
14 | 14 | server.close(); |
15 | | - }); |
| 15 | + })); |
16 | 16 | }); |
17 | 17 |
|
18 | 18 | server.listen(0, function() { |
19 | 19 | console.log(`Server running at http://127.0.0.1:${this.address().port}/`); |
20 | 20 |
|
21 | | - var errorTimer = setTimeout(function() { |
22 | | - throw new Error('Timeout was not successful'); |
23 | | - }, common.platformTimeout(2000)); |
24 | | - |
25 | | - var x = http.get({port: this.address().port, path: '/'}); |
26 | | - x.on('error', function() { |
27 | | - clearTimeout(errorTimer); |
| 21 | + var request = http.get({port: this.address().port, path: '/'}); |
| 22 | + request.on('error', common.mustCall(function() { |
28 | 23 | console.log('HTTP REQUEST COMPLETE (this is good)'); |
29 | | - }); |
30 | | - x.end(); |
31 | | - |
| 24 | + })); |
| 25 | + request.end(); |
32 | 26 | }); |