diff --git a/src/networking.c b/src/networking.c index 60f1b798..0ca43378 100644 --- a/src/networking.c +++ b/src/networking.c @@ -1751,7 +1751,7 @@ void flushSlavesOutputBuffers(void) { events = aeGetFileEvents(server.el,slave->fd); if (events & AE_WRITABLE && slave->replstate == SLAVE_STATE_ONLINE && - listLength(slave->reply)) + clientHasPendingReplies(slave)) { writeToClient(slave->fd,slave,0); }