Skip to content

Commit

Permalink
Handle disapearance of request.socket.setTimeout
Browse files Browse the repository at this point in the history
  • Loading branch information
wdavidw committed Mar 4, 2011
1 parent c967376 commit 8d654e5
Showing 1 changed file with 11 additions and 8 deletions.
19 changes: 11 additions & 8 deletions lib/hbase-connection.js
Expand Up @@ -8,14 +8,17 @@ function createRequest(method,options, command, callback){
'content-type':'application/json',
'Accept': 'application/json'
});
request.socket.setTimeout(options.timeout);
request.socket.addListener("timeout", function() {
request.socket.destroy();
var e = new Error('408: Client Request Timeout');
e.code = 408;
e.body = 'Client Request Timeout';
callback(e);
});
// After node v0.3.4 or something, socket is no longer accessible
if( request.socket && request.socket.setTimeout ){
request.socket.setTimeout(options.timeout);
request.socket.addListener("timeout", function() {
request.socket.destroy();
var e = new Error('408: Client Request Timeout');
e.code = 408;
e.body = 'Client Request Timeout';
callback(e);
});
}
return request;
}

Expand Down

0 comments on commit 8d654e5

Please sign in to comment.