summaryrefslogtreecommitdiff
path: root/test
diff options
context:
space:
mode:
authorSantiago Gimeno <santiago.gimeno@gmail.com>2016-03-12 17:25:08 +0100
committerClaudio Rodriguez <cjrodr@yahoo.com>2016-04-02 13:57:54 -0300
commit8d1d3bb71435ee68385cb79b06095f1bca294b88 (patch)
tree80834ac66b38d2feefbbcababc3beb74a6daba96 /test
parent82c2996e2df042848f2c088f31d97b224509d439 (diff)
downloadandroid-node-v8-8d1d3bb71435ee68385cb79b06095f1bca294b88.tar.gz
android-node-v8-8d1d3bb71435ee68385cb79b06095f1bca294b88.tar.bz2
android-node-v8-8d1d3bb71435ee68385cb79b06095f1bca294b88.zip
test: refactor http-end-throw-socket-handling
Remove timer to avoid the test timing out occasionally. PR-URL: https://github.com/nodejs/node/pull/5676 Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Claudio Rodriguez <cjrodr@yahoo.com>
Diffstat (limited to 'test')
-rw-r--r--test/parallel/test-http-end-throw-socket-handling.js40
1 files changed, 16 insertions, 24 deletions
diff --git a/test/parallel/test-http-end-throw-socket-handling.js b/test/parallel/test-http-end-throw-socket-handling.js
index 204c0f7333..d6cc81d98a 100644
--- a/test/parallel/test-http-end-throw-socket-handling.js
+++ b/test/parallel/test-http-end-throw-socket-handling.js
@@ -1,6 +1,6 @@
'use strict';
-var common = require('../common');
-var assert = require('assert');
+const common = require('../common');
+const assert = require('assert');
// Make sure that throwing in 'end' handler doesn't lock
// up the socket forever.
@@ -8,40 +8,32 @@ var assert = require('assert');
// This is NOT a good way to handle errors in general, but all
// the same, we should not be so brittle and easily broken.
-var http = require('http');
+const http = require('http');
-var n = 0;
-var server = http.createServer(function(req, res) {
+let n = 0;
+const server = http.createServer((req, res) => {
if (++n === 10) server.close();
res.end('ok');
});
-server.listen(common.PORT, function() {
- for (var i = 0; i < 10; i++) {
- var options = { port: common.PORT };
-
- var req = http.request(options, function(res) {
+server.listen(common.PORT, common.mustCall(() => {
+ for (let i = 0; i < 10; i++) {
+ const options = { port: common.PORT };
+ const req = http.request(options, (res) => {
res.resume();
- res.on('end', function() {
+ res.on('end', common.mustCall(() => {
throw new Error('gleep glorp');
- });
+ }));
});
req.end();
}
-});
+}));
-setTimeout(function() {
- process.removeListener('uncaughtException', catcher);
- throw new Error('Taking too long!');
-}, common.platformTimeout(1000)).unref();
-
-process.on('uncaughtException', catcher);
-var errors = 0;
-function catcher() {
+let errors = 0;
+process.on('uncaughtException', () => {
errors++;
-}
+});
-process.on('exit', function() {
+process.on('exit', () => {
assert.equal(errors, 10);
- console.log('ok');
});