diff options
| -rw-r--r-- | src/networking.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/networking.c b/src/networking.c index 60f1b798e..0ca433787 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); } |