Commit 6e09ad1c authored by antirez's avatar antirez
Browse files

Return ASAP from checkClientOutputBufferLimits() if c->reply_bytes is zero.

parent 48a32944
...@@ -1329,7 +1329,7 @@ int checkClientOutputBufferLimits(redisClient *c) { ...@@ -1329,7 +1329,7 @@ int checkClientOutputBufferLimits(redisClient *c) {
* called from contexts where the client can't be freed safely, i.e. from the * called from contexts where the client can't be freed safely, i.e. from the
* lower level functions pushing data inside the client output buffers. */ * lower level functions pushing data inside the client output buffers. */
void asyncCloseClientOnOutputBufferLimitReached(redisClient *c) { void asyncCloseClientOnOutputBufferLimitReached(redisClient *c) {
if (c->flags & REDIS_CLOSE_ASAP) return; if (c->reply_bytes == 0 || c->flags & REDIS_CLOSE_ASAP) return;
if (checkClientOutputBufferLimits(c)) { if (checkClientOutputBufferLimits(c)) {
sds client = getClientInfoString(c); sds client = getClientInfoString(c);
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment