This is an automated email from the ASF dual-hosted git repository. rnewson pushed a commit to branch nouveau-ibrowse-improvements in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit 93d280bb916f5266ab18762039f1976b2839390d Author: Robert Newson <[email protected]> AuthorDate: Sat Sep 2 16:01:15 2023 +0100 fixes --- src/nouveau/src/nouveau_index_updater.erl | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/nouveau/src/nouveau_index_updater.erl b/src/nouveau/src/nouveau_index_updater.erl index 2e539eaa9..b5d63d97d 100644 --- a/src/nouveau/src/nouveau_index_updater.erl +++ b/src/nouveau/src/nouveau_index_updater.erl @@ -250,7 +250,11 @@ purge_index(ConnPid, Db, Index, IndexPurgeSeq) -> Acc0 = case couch_db:get_full_doc_info(Db, Id) of not_found -> - ok = nouveau_api:purge_doc(ConnPid, Index, Id, PurgeSeq), + {ok, ReqId} = nouveau_api:purge_doc(ConnPid, Index, Id, IndexPurgeSeq, PurgeSeq), + receive + {ibrowse_async_headers, ReqId, _Code, _Headers} -> + flush_reqid(ReqId) + end, Acc; FDI -> DI = couch_doc:to_doc_info(FDI), @@ -259,7 +263,7 @@ purge_index(ConnPid, Db, Index, IndexPurgeSeq) -> true -> Acc; false -> - update_or_delete_index(ConnPid, Db, Index, PurgeSeq, DI, Proc), + update_or_delete_index(ConnPid, Db, Index, IndexPurgeSeq, DI, Proc), [{Id, Rev} | Acc] end end,
