diff --git a/src/replication.c b/src/replication.c index d585ff1f..439dbba2 100644 --- a/src/replication.c +++ b/src/replication.c @@ -602,9 +602,11 @@ void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { return; } if ((nwritten = write(fd,buf,buflen)) == -1) { - redisLog(REDIS_VERBOSE,"Write error sending DB to slave: %s", - strerror(errno)); - freeClient(slave); + if (errno != EAGAIN) { + redisLog(REDIS_WARNING,"Write error sending DB to slave: %s", + strerror(errno)); + freeClient(slave); + } return; } slave->repldboff += nwritten; @@ -616,6 +618,7 @@ void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { slave->repl_ack_time = server.unixtime; if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, sendReplyToClient, slave) == AE_ERR) { + redisLog(REDIS_WARNING,"Unable to register writable event for slave bulk transfer: %s", strerror(errno)); freeClient(slave); return; }