From 4a95eda9d7aee7f8d371ac3baf07f1ab55d56326 Mon Sep 17 00:00:00 2001 From: Chao Shen Date: Tue, 27 Mar 2018 11:33:16 +0800 Subject: [PATCH] Fix lost index update. --- src/import_pipeline.cc | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/src/import_pipeline.cc b/src/import_pipeline.cc index 90e1ac09..4c0102ba 100644 --- a/src/import_pipeline.cc +++ b/src/import_pipeline.cc @@ -548,13 +548,10 @@ bool IndexMergeIndexUpdates() { IterationLoop loop; while (loop.Next()) { optional to_join = queue->on_indexed.TryPopBack(); - if (!to_join) { - queue->on_indexed.PushFront(std::move(*root)); - return did_merge; - } - + if (!to_join) + break; did_merge = true; - Timer time; + // Timer time; root->update.Merge(std::move(to_join->update)); // time.ResetAndPrint("Joined querydb updates for files: " + // StringJoinMap(root->update.files_def_update, @@ -563,6 +560,7 @@ bool IndexMergeIndexUpdates() { //})); } + queue->on_indexed.PushFront(std::move(*root)); return did_merge; }