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

param socket_keepalive to set keep-alive on socket

Browse Source
This commit is contained in:
Mohit Gupta
2014-03-25 16:33:43 -07:00
parent 4672479b91
commit d313aa5dab
2 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
README.md
View File

@@ -192,6 +192,7 @@ every command on a client.
* `socket_nodelay`: defaults to `true`. Whether to call setNoDelay() on the TCP stream, which disables the * `socket_nodelay`: defaults to `true`. Whether to call setNoDelay() on the TCP stream, which disables the
Nagle algorithm on the underlying socket. Setting this option to `false` can result in additional throughput at the Nagle algorithm on the underlying socket. Setting this option to `false` can result in additional throughput at the
cost of more latency. Most applications will want this set to `true`. cost of more latency. Most applications will want this set to `true`.
* `socket_keepalive` defaults to `false`. Whether the keep-alive functionality is enabled on the underlying socket.
* `no_ready_check`: defaults to `false`. When a connection is established to the Redis server, the server might still * `no_ready_check`: defaults to `false`. When a connection is established to the Redis server, the server might still
be loading the database from disk. While loading, the server not respond to any commands. To work around this, be loading the database from disk. While loading, the server not respond to any commands. To work around this,
`node_redis` has a "ready check" which sends the `INFO` command to the server. The response from the `INFO` command `node_redis` has a "ready check" which sends the `INFO` command to the server. The response from the `INFO` command

4
index.js
View File

@@ -43,6 +43,9 @@ function RedisClient(stream, options) {
if (this.options.socket_nodelay === undefined) { if (this.options.socket_nodelay === undefined) {
this.options.socket_nodelay = true; this.options.socket_nodelay = true;
} }
if (this.options.socket_keepalive === undefined) {
this.options.socket_keepalive = false;
}
this.should_buffer = false; this.should_buffer = false;
this.command_queue_high_water = this.options.command_queue_high_water || 1000; this.command_queue_high_water = this.options.command_queue_high_water || 1000;
this.command_queue_low_water = this.options.command_queue_low_water || 0; this.command_queue_low_water = this.options.command_queue_low_water || 0;
@@ -249,6 +252,7 @@ RedisClient.prototype.on_connect = function () {
if (this.options.socket_nodelay) { if (this.options.socket_nodelay) {
this.stream.setNoDelay(); this.stream.setNoDelay();
} }
this.stream.setKeepAlive(this.options.socket_keepalive);
this.stream.setTimeout(0); this.stream.setTimeout(0);
this.init_parser(); this.init_parser();