Lines Matching refs:aof_fd
210 aof_fsync(server.aof_fd); in stopAppendOnly()
211 close(server.aof_fd); in stopAppendOnly()
213 server.aof_fd = -1; in stopAppendOnly()
241 server.aof_fd = open(server.aof_filename,O_WRONLY|O_APPEND|O_CREAT,0644); in startAppendOnly()
243 if (server.aof_fd == -1) { in startAppendOnly()
258 close(server.aof_fd); in startAppendOnly()
325 nwritten = write(server.aof_fd,server.aof_buf,sdslen(server.aof_buf)); in flushAppendOnlyFile()
370 if (ftruncate(server.aof_fd, server.aof_current_size) == -1) { in flushAppendOnlyFile()
438 aof_fsync(server.aof_fd); /* Let's try to get this data on the disk */ in flushAppendOnlyFile()
444 if (!sync_in_progress) aof_background_fsync(server.aof_fd); in flushAppendOnlyFile()
747 if (server.aof_fd != -1 && lseek(server.aof_fd,0,SEEK_END) == -1) { in loadAppendOnlyFile()
1346 if (redis_fstat(server.aof_fd,&sb) == -1) { in aofUpdateCurrentSize()
1419 if (server.aof_fd == -1) { in backgroundRewriteDoneHandler()
1447 if (server.aof_fd == -1) { in backgroundRewriteDoneHandler()
1453 oldfd = server.aof_fd; in backgroundRewriteDoneHandler()
1454 server.aof_fd = newfd; in backgroundRewriteDoneHandler()