mirror of https://github.com/nodejs/node.git
If http.Client has an error, do not continue to reconnect.
parent
8cfdd326a8
commit
c457b829e2
|
@ -321,6 +321,7 @@ node.http.Server = function (RequestHandler, options) {
|
|||
node.http.Client = function (port, host) {
|
||||
var connection = new node.http.LowLevelClient();
|
||||
var requests = [];
|
||||
var self = this;
|
||||
|
||||
function ClientRequest (method, uri, header_lines) {
|
||||
|
||||
|
@ -403,7 +404,12 @@ node.http.Client = function (port, host) {
|
|||
requests[0].flush();
|
||||
};
|
||||
|
||||
connection.onDisconnect = function () {
|
||||
connection.onDisconnect = function (had_error) {
|
||||
if (had_error) {
|
||||
if (self.onError) self.onError();
|
||||
return;
|
||||
}
|
||||
|
||||
//node.debug("HTTP CLIENT: disconnect");
|
||||
// If there are more requests to handle, reconnect.
|
||||
if (requests.length > 0) {
|
||||
|
|
|
@ -1,5 +1,9 @@
|
|||
var c = new node.http.Client(8000, "127.0.0.1");
|
||||
|
||||
c.onError = function () {
|
||||
puts("http client connection error.");
|
||||
};
|
||||
|
||||
var req = c.get("/bytes/123", [["Accept", "*/*"]]);
|
||||
req.finish(function (res) {
|
||||
puts("response 1: " + res.statusCode.toString());
|
||||
|
|
Loading…
Reference in New Issue