redis/node-redis
1
0
Fork 0
mirror of https://github.com/redis/node-redis.git synced 2025-08-09 00:22:08 +03:00
Code Activity

Merge branch 'uber-fix_recon'

Browse Source
This commit is contained in:
Bryce Baril
2014-07-10 20:52:10 -07:00
parent c68b3f7bd3 c687d2e4fd
commit b12817c448
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
index.js
View File

@@ -81,6 +81,14 @@ function RedisClient(stream, options) {
this.old_state = null;
this.install_stream_listeners();
events.EventEmitter.call(this);
}
util.inherits(RedisClient, events.EventEmitter);
exports.RedisClient = RedisClient;
RedisClient.prototype.install_stream_listeners = function() {
var self = this;
this.stream.on("connect", function () {
@@ -107,11 +115,7 @@ function RedisClient(stream, options) {
self.should_buffer = false;
self.emit("drain");
});
events.EventEmitter.call(this);
}
util.inherits(RedisClient, events.EventEmitter);
exports.RedisClient = RedisClient;
};
RedisClient.prototype.initialize_retry_vars = function () {
this.retry_timer = null;
@@ -520,7 +524,8 @@ RedisClient.prototype.connection_gone = function (why) {
return;
}
self.stream.connect(self.port, self.host);
self.stream = net.createConnection(self.port, self.host);
self.install_stream_listeners();
self.retry_timer = null;
}, this.retry_delay);
};