gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Periodically FLASH flush write queues during RDB load

Browse Source 
Former-commit-id: 721129b18263eabfc2a29556a2b7a9a861110953
This commit is contained in:
John Sully 2020-04-21 21:39:36 -04:00
parent 437a1d54cd
commit f29756e4cb
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/rdb.cpp
View File

@ -2486,13 +2486,13 @@ int rdbLoadRio(rio *rdb, int rdbflags, rdbSaveInfo *rsi) {
do this every 16 keys to limit the perf impact */ do this every 16 keys to limit the perf impact */
if (g_pserver->m_pstorageFactory && (ckeysLoaded % 16) == 0) if (g_pserver->m_pstorageFactory && (ckeysLoaded % 16) == 0)
{ {
if (getMaxmemoryState(NULL,NULL,NULL,NULL) != C_OK) if (getMaxmemoryState(NULL,NULL,NULL,NULL) != C_OK || (ckeysLoaded % (1024)) == 0)
{ {
for (int idb = 0; idb < cserver.dbnum; ++idb) for (int idb = 0; idb < cserver.dbnum; ++idb)
{ {
g_pserver->db[idb]->processChanges(); g_pserver->db[idb]->processChanges();
g_pserver->db[idb]->commitChanges(); g_pserver->db[idb]->commitChanges();
g_pserver->db[idb]->trackChanges(true); g_pserver->db[idb]->trackChanges(false);
} }
freeMemoryIfNeeded(); freeMemoryIfNeeded();
} }