Compare commits
5 Commits
master
...
v1.1-error
Author | SHA1 | Date |
---|---|---|
|
a254958bf6 | |
|
c2c7ed40d5 | |
|
4b9db320c0 | |
|
9eb96be46c | |
|
089d85df67 |
|
@ -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);
|
||||
});
|
||||
|
|
|
@ -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);
|
||||
|
|
Loading…
Reference in New Issue