fluencelabs/redis
1
0
Fork 0
mirror of https://github.com/fluencelabs/redis synced 2025-03-30 22:31:03 +00:00
Code Issues Projects Releases Wiki Activity

Rewrite comment that was no longer valid

Browse Source
This commit is contained in:
Pieter Noordhuis 2010-10-28 16:59:05 +01:00
parent a3a323e0e5
commit 4794d88f15
1 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/networking.c
View File

@ -798,12 +798,7 @@ int processMultibulkBuffer(redisClient *c) {
void processInputBuffer(redisClient *c) { void processInputBuffer(redisClient *c) {
/* Keep processing while there is something in the input buffer */ /* Keep processing while there is something in the input buffer */
while(sdslen(c->querybuf)) { while(sdslen(c->querybuf)) {
/* Before to process the input buffer, make sure the client is not /* Immediately abort if the client is in the middle of something. */
* waitig for a blocking operation such as BLPOP. Note that the first
* iteration the client is never blocked, otherwise the processInputBuffer
* would not be called at all, but after the execution of the first commands
* in the input buffer the client may be blocked, and the "goto again"
* will try to reiterate. The following line will make it return asap. */
if (c->flags & REDIS_BLOCKED || c->flags & REDIS_IO_WAIT) return; if (c->flags & REDIS_BLOCKED || c->flags & REDIS_IO_WAIT) return;
/* REDIS_CLOSE_AFTER_REPLY closes the connection once the reply is /* REDIS_CLOSE_AFTER_REPLY closes the connection once the reply is