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

Build fixes from cherry-pick

Browse Source 
Former-commit-id: 70efd87cf71bb230e8b53d1c4ed3dd91997b4d23
This commit is contained in:
John Sully 2020-07-13 16:09:03 +00:00
parent af10f809b4
commit ad5ad52841
1 changed files with 5 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/server.cpp
View File

@ -2306,26 +2306,22 @@ int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) {
g_pserver->rdb_bgsave_scheduled = 0; g_pserver->rdb_bgsave_scheduled = 0;
} }
<<<<<<< HEAD
if (cserver.storage_memory_model == STORAGE_WRITEBACK && g_pserver->m_pstorageFactory) { if (cserver.storage_memory_model == STORAGE_WRITEBACK && g_pserver->m_pstorageFactory) {
run_with_period(g_pserver->storage_flush_period) { run_with_period(g_pserver->storage_flush_period) {
flushStorageWeak(); flushStorageWeak();
} }
} }
g_pserver->asyncworkqueue->AddWorkFunction([]{ bool fAnySnapshots = false;
g_pserver->db[0]->consolidate_snapshot(); for (int idb = 0; idb < cserver.dbnum && !fAnySnapshots; ++idb)
}, true /*HiPri*/); fAnySnapshots = fAnySnapshots || g_pserver->db[0]->FSnapshot();
if (fAnySnapshots)
=======
if (g_pserver->db[0]->FSnapshot()) // BUG only db 0?!
{ {
g_pserver->asyncworkqueue->AddWorkFunction([]{ g_pserver->asyncworkqueue->AddWorkFunction([]{
g_pserver->db[0]->consolidate_snapshot(); g_pserver->db[0]->consolidate_snapshot();
}, true /*HiPri*/); }, true /*HiPri*/);
} }
>>>>>>> dd700f1d6... Remove unnecessary work from critical path (Latency Fixes)
/* Fire the cron loop modules event. */ /* Fire the cron loop modules event. */
RedisModuleCronLoopV1 ei = {REDISMODULE_CRON_LOOP_VERSION,g_pserver->hz}; RedisModuleCronLoopV1 ei = {REDISMODULE_CRON_LOOP_VERSION,g_pserver->hz};
moduleFireServerEvent(REDISMODULE_EVENT_CRON_LOOP, moduleFireServerEvent(REDISMODULE_EVENT_CRON_LOOP,
@ -4163,16 +4159,6 @@ int processCommand(client *c, int callFlags, AeLocker &locker) {
queueMultiCommand(c); queueMultiCommand(c);
addReply(c,shared.queued); addReply(c,shared.queued);
} else { } else {
<<<<<<< HEAD
#if 0
if (cserver.cthreads >= 2 && !g_fTestMode && g_pserver->m_pstorageFactory == nullptr && listLength(g_pserver->monitors) == 0 && c->cmd->proc == getCommand)
{
if (getCommandAsync(c))
return C_OK;
}
#endif
=======
>>>>>>> dd700f1d6... Remove unnecessary work from critical path (Latency Fixes)
locker.arm(c); locker.arm(c);
incrementMvccTstamp(); incrementMvccTstamp();
call(c,callFlags); call(c,callFlags);