redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-06 02:15:48 +03:00
Code Activity

Improve retry logic.

Browse Source
This commit is contained in:
Matt Ranney
2010-09-23 16:58:19 -07:00
parent a6bfae83b9
commit 9e65e6a6a8
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
index.js
View File

@@ -390,18 +390,18 @@ function RedisClient(stream) {
}); });
this.stream.on("close", function () { this.stream.on("close", function () {
self.connection_gone(); self.connection_gone("close");
}); });
this.stream.on("end", function () { this.stream.on("end", function () {
self.connection_gone(); self.connection_gone("end");
}); });
events.EventEmitter.call(this); events.EventEmitter.call(this);
} }
sys.inherits(RedisClient, events.EventEmitter); sys.inherits(RedisClient, events.EventEmitter);
RedisClient.prototype.connection_gone = function () { RedisClient.prototype.connection_gone = function (why) {
var self = this; var self = this;
// If a retry is already in progress, just let that happen // If a retry is already in progress, just let that happen
@@ -409,8 +409,11 @@ RedisClient.prototype.connection_gone = function () {
return; return;
} }
// Note that this may trigger another "close" or "end" event
self.stream.destroy();
if (exports.debug_mode) { if (exports.debug_mode) {
console.warn("Redis connection is gone."); console.warn("Redis connection is gone from " + why + " event.");
} }
self.connected = false; self.connected = false;
self.emit("end"); self.emit("end");
@@ -436,8 +439,8 @@ RedisClient.prototype.connection_gone = function () {
console.log("Retrying connection..."); console.log("Retrying connection...");
} }
self.retry_delay = self.retry_delay * self.retry_backoff; self.retry_delay = self.retry_delay * self.retry_backoff;
self.stream.destroy();
self.stream.connect(self.port, self.host); self.stream.connect(self.port, self.host);
self.retry_timer = null;
}, self.retry_delay); }, self.retry_delay);
}; };