diff --git a/src/networking.cpp b/src/networking.cpp index 5ff886cf9..dd2928879 100644 --- a/src/networking.cpp +++ b/src/networking.cpp @@ -1082,7 +1082,7 @@ void copyClientOutputBuffer(client *dst, client *src) { /* Return true if the specified client has pending reply buffers to write to * the socket. */ int clientHasPendingReplies(client *c) { - return (c->bufpos || listLength(c->reply)) && !(c->flags & CLIENT_CLOSE_ASAP); + return (c->bufpos || listLength(c->reply)); } static std::atomic rgacceptsInFlight[MAX_EVENT_LOOPS];