We should still send replies even if an async close is pending

Former-commit-id: 572bcca9c2e7985782909cca22ef9e381bea55b4
This commit is contained in:
John Sully 2020-05-10 23:56:29 -04:00
parent 344699b2ce
commit 4477a8b145

View File

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