mirror of
https://github.com/nodejs/node.git
synced 2025-05-04 13:07:46 +00:00

Read all pending data out of the socket on `error` event and ensure that no `data`/`end` handlers will be invoked on `socket.destroy()`. Otherwise following assertion happens: AssertionError: null == true at TLSSocket.socketOnData (_http_client.js:308:3) at TLSSocket.emit (events.js:107:17) at TLSSocket.Readable.read (_stream_readable.js:373:10) at TLSSocket.socketCloseListener (_http_client.js:229:10) at TLSSocket.emit (events.js:129:20) at TCP.close (net.js:476:12) Fix: https://github.com/joyent/node/issues/9348 PR-URL: https://github.com/iojs/io.js/pull/1103 Reviewed-By: Rod Vagg <rod@vagg.org> Reviewed-By: Nicu Micleușanu <micnic90@gmail.com>
43 lines
885 B
JavaScript
43 lines
885 B
JavaScript
var net = require('net');
|
|
var http = require('http');
|
|
var util = require('util');
|
|
|
|
function Agent() {
|
|
http.Agent.call(this);
|
|
}
|
|
util.inherits(Agent, http.Agent);
|
|
|
|
Agent.prototype.createConnection = function() {
|
|
var self = this;
|
|
var socket = new net.Socket();
|
|
|
|
socket.on('error', function() {
|
|
socket.push('HTTP/1.1 200\r\n\r\n');
|
|
});
|
|
|
|
socket.on('newListener', function onNewListener(name) {
|
|
if (name !== 'error')
|
|
return;
|
|
socket.removeListener('newListener', onNewListener);
|
|
|
|
// Let other listeners to be set up too
|
|
process.nextTick(function() {
|
|
self.breakSocket(socket);
|
|
});
|
|
});
|
|
|
|
return socket;
|
|
};
|
|
|
|
Agent.prototype.breakSocket = function breakSocket(socket) {
|
|
socket.emit('error', new Error('Intentional error'));
|
|
};
|
|
|
|
var agent = new Agent();
|
|
|
|
http.request({
|
|
agent: agent
|
|
}).once('error', function() {
|
|
console.log('ignore');
|
|
});
|