alx/mu4e
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'index-sleep-exp-backoff'

Browse Source
This commit is contained in:
Dirk-Jan C. Binnema
2025-06-30 21:49:48 +03:00
parent 9763ca0830 0d7ddba9fd
commit 2c3ee5bd7b
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
lib/mu-server.cc
View File

@ -828,10 +828,18 @@ Server::Private::do_index(const Indexer::Config& conf)
{ {
StopWatch sw{"indexing"}; StopWatch sw{"indexing"};
indexer().start(conf); indexer().start(conf);
std::chrono::milliseconds sleep_duration(125); // initial 125ms
while (indexer().is_running()) { while (indexer().is_running()) {
std::this_thread::sleep_for(std::chrono::milliseconds(2000)); std::this_thread::sleep_for(sleep_duration);
output_sexp(get_stats(indexer().progress(), "running"), output_sexp(get_stats(indexer().progress(), "running"),
Server::OutputFlags::Flush); Server::OutputFlags::Flush);
// Exponential backoff: doubling sleep duration up to 2s
if (sleep_duration < std::chrono::milliseconds(2000)) {
sleep_duration *= 2;
if (sleep_duration > std::chrono::milliseconds(2000)) {
sleep_duration = std::chrono::milliseconds(2000);
}
}
} }
output_sexp(get_stats(indexer().progress(), "complete"), output_sexp(get_stats(indexer().progress(), "complete"),
Server::OutputFlags::Flush); Server::OutputFlags::Flush);