emacs
/
mu
mirror of https://github.com/djcb/mu.git
1
0
Fork 0
Code Issues Releases Wiki Activity

indexer: fix race condition 

It was possible for the worker to stop before the work was even started; and
then we might wait forever for the queue to become empty.
This commit is contained in:
Dirk-Jan C. Binnema 2021-11-22 21:52:01 +02:00
parent d0bb0f215a
commit 0ade4ecfa7
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
lib/index/mu-indexer.cc
View File

@ -198,13 +198,14 @@ Indexer::Private::worker()
g_debug("started worker");
while (state_ == IndexState::Scanning || !fq_.empty()) {
while (state_ == IndexState::Scanning) {
if (!fq_.pop(item, 250ms))
continue;
try {
std::unique_lock lock{lock_};
store_.add_message(item, true /*use-transaction*/);
store_.add_message(item, true /*use-transaction*/);
++progress_.updated;
} catch (const Mu::Error& er) {
@ -261,9 +262,12 @@ Indexer::Private::start(const Indexer::Config& conf)
conf_.scan ? "yes" : "no",
conf_.cleanup ? "yes" : "no");
workers_.emplace_back(std::thread([this] { worker(); }));
state_.change_to(IndexState::Scanning);
{
/* kick off the first worker, which will spawn more if needed. */
std::lock_guard<std::mutex> wlock{wlock_};
workers_.emplace_back(std::thread([this] { worker(); }));
}
scanner_worker_ = std::thread([this] {
progress_ = {};