Actually use ae_flags to add AE_BARRIER if needed.

Many thanks to @Plasma that spotted this problem reviewing the code.
This commit is contained in:
antirez 2018-02-28 18:03:51 +01:00
parent 7a73db7512
commit 3a5bf75ede

View File

@ -1058,7 +1058,7 @@ int handleClientsWithPendingWrites(void) {
{ {
ae_flags |= AE_BARRIER; ae_flags |= AE_BARRIER;
} }
if (aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, if (aeCreateFileEvent(server.el, c->fd, ae_flags,
sendReplyToClient, c) == AE_ERR) sendReplyToClient, c) == AE_ERR)
{ {
freeClientAsync(c); freeClientAsync(c);