Lines Matching refs:aof_buf
292 if (sdslen(server.aof_buf) == 0) return; in flushAppendOnlyFile()
325 nwritten = write(server.aof_fd,server.aof_buf,sdslen(server.aof_buf)); in flushAppendOnlyFile()
344 if (nwritten != (signed)sdslen(server.aof_buf)) { in flushAppendOnlyFile()
367 (long long)sdslen(server.aof_buf)); in flushAppendOnlyFile()
403 sdsrange(server.aof_buf,nwritten,-1); in flushAppendOnlyFile()
420 if ((sdslen(server.aof_buf)+sdsavail(server.aof_buf)) < 4000) { in flushAppendOnlyFile()
421 sdsclear(server.aof_buf); in flushAppendOnlyFile()
423 sdsfree(server.aof_buf); in flushAppendOnlyFile()
424 server.aof_buf = sdsempty(); in flushAppendOnlyFile()
549 server.aof_buf = sdscatlen(server.aof_buf,buf,sdslen(buf)); in feedAppendOnlyFile()
1465 sdsfree(server.aof_buf); in backgroundRewriteDoneHandler()
1466 server.aof_buf = sdsempty(); in backgroundRewriteDoneHandler()