caleb-brown/redict
1
0
Fork 0
mirror of https://codeberg.org/redict/redict.git synced 2025-01-23 08:38:27 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Use amount of I/O not ops to trigger aofReadDiffFromParent().

Browse Source
This commit is contained in:
antirez 2014-07-04 16:03:46 +02:00
parent 62f9d34c56
commit cc24447a1a
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/aof.c
View File

@ -965,8 +965,8 @@ int rewriteAppendOnlyFile(char *filename) {
char tmpfile[256]; char tmpfile[256];
int j; int j;
long long now = mstime(); long long now = mstime();
unsigned long ops = 0;
char byte; char byte;
size_t processed = 0;
/* Note that we have to use a different temp name here compared to the /* Note that we have to use a different temp name here compared to the
* one used by rewriteAppendOnlyFileBackground() function. */ * one used by rewriteAppendOnlyFileBackground() function. */
@ -1038,7 +1038,10 @@ int rewriteAppendOnlyFile(char *filename) {
if (rioWriteBulkLongLong(&aof,expiretime) == 0) goto werr; if (rioWriteBulkLongLong(&aof,expiretime) == 0) goto werr;
} }
/* Read some diff from the parent process from time to time. */ /* Read some diff from the parent process from time to time. */
if (ops++ % 1000) aofReadDiffFromParent(); if (aof.processed_bytes > processed+REDIS_AOF_AUTOSYNC_BYTES) {
processed = aof.processed_bytes;
aofReadDiffFromParent();
}
} }
dictReleaseIterator(di); dictReleaseIterator(di);
} }