diff --git a/src/aof.c b/src/aof.c index 4f7e9392f..9497813b2 100644 --- a/src/aof.c +++ b/src/aof.c @@ -221,6 +221,7 @@ static void killAppendOnlyChild(void) { server.aof_rewrite_time_start = -1; /* Close pipes used for IPC between the two processes. */ aofClosePipes(); + closeChildInfoPipe(); updateDictResizePolicy(); } diff --git a/src/db.c b/src/db.c index 5ce3a2950..6e7b46ac5 100644 --- a/src/db.c +++ b/src/db.c @@ -451,6 +451,7 @@ void flushallCommand(client *c) { if (server.rdb_child_pid != -1) { kill(server.rdb_child_pid,SIGUSR1); rdbRemoveTempFile(server.rdb_child_pid); + closeChildInfoPipe(); updateDictResizePolicy(); } if (server.saveparamslen > 0) { diff --git a/src/replication.c b/src/replication.c index 57f5131ae..a10b10133 100644 --- a/src/replication.c +++ b/src/replication.c @@ -1256,6 +1256,7 @@ void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { (long) server.rdb_child_pid); kill(server.rdb_child_pid,SIGUSR1); rdbRemoveTempFile(server.rdb_child_pid); + closeChildInfoPipe(); updateDictResizePolicy(); }