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

Add latency marker for process changes phase for FLASH

Browse Source 
Former-commit-id: 61e20b025d45b0af8ed60aab96246b30e4d0ed3d
This commit is contained in:
John Sully 2020-06-04 01:29:17 -04:00
parent bc846d047d
commit 9851fde2fa
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/server.cpp
View File

@ -2393,10 +2393,14 @@ void beforeSleep(struct aeEventLoop *eventLoop) {
// note: we also copy the DB pointer in case a DB swap is done while the lock is released // note: we also copy the DB pointer in case a DB swap is done while the lock is released
std::vector<redisDb*> vecdb; // note we cache the database pointer in case a dbswap is done while the lock is released std::vector<redisDb*> vecdb; // note we cache the database pointer in case a dbswap is done while the lock is released
if (!fFirstRun) { if (!fFirstRun) {
mstime_t storage_process_latency;
latencyStartMonitor(storage_process_latency);
for (int idb = 0; idb < cserver.dbnum; ++idb) { for (int idb = 0; idb < cserver.dbnum; ++idb) {
vecdb.push_back(g_pserver->db[idb]); vecdb.push_back(g_pserver->db[idb]);
g_pserver->db[idb]->processChanges(); g_pserver->db[idb]->processChanges();
} }
latencyEndMonitor(storage_process_latency);
latencyAddSampleIfNeeded("storage-process-changes", storage_process_latency);
} else { } else {
fFirstRun = false; fFirstRun = false;
} }