X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=plocate.cpp;h=28a9c28bfe52065b8425fffdb4ffef661b501865;hb=19e638d54b74f7593ba607ab53b430385b7ae531;hp=a1cd97a4a4645c08880b014d4799f9d4c33182f6;hpb=fd6198891d6fd9642effc0843fef6f23b991af3e;p=plocate

diff --git a/plocate.cpp b/plocate.cpp
index a1cd97a..28a9c28 100644
--- a/plocate.cpp
+++ b/plocate.cpp
@@ -367,7 +367,7 @@ uint64_t scan_all_docids(const vector<Needle> &needles, int fd, const Corpus &co
 				string compressed;
 
 				{
-					unique_lock<mutex> lock(mu);
+					unique_lock lock(mu);
 					queue_added.wait(lock, [&work_queue, &done] { return !work_queue.empty() || done; });
 					if (done && work_queue.empty()) {
 						return;
@@ -397,7 +397,7 @@ uint64_t scan_all_docids(const vector<Needle> &needles, int fd, const Corpus &co
 		complete_pread(fd, &compressed[0], io_len, offsets[io_docid]);
 
 		{
-			unique_lock<mutex> lock(mu);
+			unique_lock lock(mu);
 			queue_removed.wait(lock, [&work_queue] { return work_queue.size() < 256; });  // Allow ~2MB of data queued up.
 			work_queue.emplace_back(io_docid, last_docid, move(compressed));
 			queue_added.notify_one();  // Avoid the thundering herd.