Skip to content

Commit 64d6883

Browse files
author
Sandro Santilli
committed
Ensure connect callback is invoked on premature socket hangup
Closes brianc#534
1 parent 51a28c2 commit 64d6883

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

Diff for: lib/client.js

+8
Original file line numberDiff line numberDiff line change
@@ -170,9 +170,17 @@ Client.prototype.connect = function(callback) {
170170
return self.emit('error', error);
171171
}
172172
callback(error);
173+
callback = null;
173174
});
174175

175176
con.once('end', function() {
177+
if ( callback ) {
178+
// haven't received a connection message yet !
179+
var err = new Error("Stream unexpectedly ended before getting ready for query execution");
180+
callback(err);
181+
callback = null;
182+
return;
183+
}
176184
if(self.activeQuery) {
177185
var disconnectError = new Error('Stream unexpectedly ended during query execution');
178186
self.activeQuery.handleError(disconnectError);

0 commit comments

Comments
 (0)