In addition to 'aborted' emit 'close' from incoming requests
Closes GH-160.
This commit is contained in:
parent
5287703cce
commit
f423ec90fc
@ -952,6 +952,7 @@ function connectionListener(socket) {
|
||||
while (incoming.length) {
|
||||
var req = incoming.shift();
|
||||
req.emit('aborted');
|
||||
req.emit('close');
|
||||
}
|
||||
// abort socket._httpMessage ?
|
||||
}
|
||||
|
34
test/simple/test-http-response-close.js
Normal file
34
test/simple/test-http-response-close.js
Normal file
@ -0,0 +1,34 @@
|
||||
var common = require('../common');
|
||||
var assert = require('assert');
|
||||
var http = require('http');
|
||||
|
||||
var gotEnd = false;
|
||||
|
||||
var server = http.createServer(function(req, res) {
|
||||
res.writeHead(200);
|
||||
res.write('a');
|
||||
|
||||
req.on('close', function() {
|
||||
console.error("aborted");
|
||||
gotEnd = true;
|
||||
});
|
||||
});
|
||||
server.listen(common.PORT);
|
||||
|
||||
server.addListener('listening', function() {
|
||||
console.error("make req");
|
||||
http.get({
|
||||
port: common.PORT
|
||||
}, function(res) {
|
||||
console.error("got res");
|
||||
res.on('data', function(data) {
|
||||
console.error("destroy res");
|
||||
res.destroy();
|
||||
server.close();
|
||||
});
|
||||
});
|
||||
});
|
||||
|
||||
process.on('exit', function() {
|
||||
assert.ok(gotEnd);
|
||||
});
|
Loading…
x
Reference in New Issue
Block a user