Lines Matching refs:aof
1018 rio aof; in rewriteAppendOnlyFile() local
1036 rioInitWithFile(&aof,fp); in rewriteAppendOnlyFile()
1038 rioSetAutoSync(&aof,AOF_AUTOSYNC_BYTES); in rewriteAppendOnlyFile()
1051 if (rioWrite(&aof,selectcmd,sizeof(selectcmd)-1) == 0) goto werr; in rewriteAppendOnlyFile()
1052 if (rioWriteBulkLongLong(&aof,j) == 0) goto werr; in rewriteAppendOnlyFile()
1073 if (rioWrite(&aof,cmd,sizeof(cmd)-1) == 0) goto werr; in rewriteAppendOnlyFile()
1075 if (rioWriteBulkObject(&aof,&key) == 0) goto werr; in rewriteAppendOnlyFile()
1076 if (rioWriteBulkObject(&aof,o) == 0) goto werr; in rewriteAppendOnlyFile()
1078 if (rewriteListObject(&aof,&key,o) == 0) goto werr; in rewriteAppendOnlyFile()
1080 if (rewriteSetObject(&aof,&key,o) == 0) goto werr; in rewriteAppendOnlyFile()
1082 if (rewriteSortedSetObject(&aof,&key,o) == 0) goto werr; in rewriteAppendOnlyFile()
1084 if (rewriteHashObject(&aof,&key,o) == 0) goto werr; in rewriteAppendOnlyFile()
1091 if (rioWrite(&aof,cmd,sizeof(cmd)-1) == 0) goto werr; in rewriteAppendOnlyFile()
1092 if (rioWriteBulkObject(&aof,&key) == 0) goto werr; in rewriteAppendOnlyFile()
1093 if (rioWriteBulkLongLong(&aof,expiretime) == 0) goto werr; in rewriteAppendOnlyFile()
1096 if (aof.processed_bytes > processed+1024*10) { in rewriteAppendOnlyFile()
1097 processed = aof.processed_bytes; in rewriteAppendOnlyFile()
1147 if (rioWrite(&aof,server.aof_child_diff,sdslen(server.aof_child_diff)) == 0) in rewriteAppendOnlyFile()