Added handler for socket errors

2015-06-13 16:25:40 +02:00
parent 93fdf8c83a
commit ad26a641c8
1 changed files with 8 additions and 0 deletions
@@ -760,6 +760,14 @@ function session(sock) {
 		log.debug('larvitsmpp: lib/session.js: session() - sock.on(close) - socket closed');
 	});

+	sock.on('error', function() {
+		log.warn('larvitsmpp: lib/session.js: session() - sock.on(error) - Socket error detected!');
+		if (returnObj.enqLinkTimer) {
+			log.debug('larvitsmpp: lib/session.js: session() - sock.on(error) - enqLinkTimer found, clearing.');
+			clearTimeout(returnObj.enqLinkTimer);
+		}
+	});
+
 	return returnObj;
 }