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('error', onError);
|
||||||
conn.once('data', function (chunk) {
|
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);
|
conn.removeListener('error', onError);
|
||||||
peek(conn, chunk, opts);
|
peek(conn, chunk, opts);
|
||||||
});
|
});
|
||||||
|
|
|
@ -56,7 +56,12 @@ module.exports.create = function (deps, config, tcpMods) {
|
||||||
|
|
||||||
socket.on('error', function (err) {
|
socket.on('error', function (err) {
|
||||||
console.log('wrapped TLS socket error', 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) {
|
writer.on('error', function (err) {
|
||||||
console.error('socket-pair writer error', err);
|
console.error('socket-pair writer error', err);
|
||||||
|
|
Loading…
Reference in New Issue