Jämför commits

...

5 Incheckningar

2 ändrade filer med 16 tillägg och 1 borttagningar

Visa fil

@ -154,6 +154,16 @@ module.exports.create = function (deps, config) {
}
conn.once('error', onError);
conn.once('data', function (chunk) {
// //Adding this to track problems with error handling TODO: Remove this error handler.
// conn.once('error', function(err) {
// console.log("Received error in tcpHandler after removing error listener.",
// "Number of errorListeners:", conn.listenerCount("error"),
// "Error: ", err
// );
// if(conn.listenerCount("error") <= 1) {
// process.nextTick(function() {conn.emit("error", err);});
// }
// });
conn.removeListener('error', onError);
peek(conn, chunk, opts);
});

Visa fil

@ -56,7 +56,12 @@ module.exports.create = function (deps, config, tcpMods) {
socket.on('error', function (err) {
console.log('wrapped TLS socket error', err);
reader.emit('error', err);
if(reader.listenerCount("error")){
console.log("There are error handlers that should handle this emiting error.");
reader.emit('error', err);
} else {
console.log('Wrapped TLS socket had no error handlers for error. Socket object: ', reader);
}
});
writer.on('error', function (err) {
console.error('socket-pair writer error', err);