summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGarren Smith <garren.smith@gmail.com>2019-08-15 15:08:48 +0200
committergarren smith <garren.smith@gmail.com>2019-08-15 17:02:13 +0200
commitba3cd0a6fd44c69e0a020a7c7af38db361a2c888 (patch)
tree1f7a525212b427df0b54855a5458956d1168edd9
parent3f447c4028e3980ea1803d200415a8c2373cb208 (diff)
downloadcouchdb-ba3cd0a6fd44c69e0a020a7c7af38db361a2c888.tar.gz
only fetch 1 query server for indexing
-rw-r--r--src/couch_views/src/couch_views_indexer.erl7
1 files changed, 5 insertions, 2 deletions
diff --git a/src/couch_views/src/couch_views_indexer.erl b/src/couch_views/src/couch_views_indexer.erl
index edee332f3..bebbd1a7a 100644
--- a/src/couch_views/src/couch_views_indexer.erl
+++ b/src/couch_views/src/couch_views_indexer.erl
@@ -215,7 +215,7 @@ write_docs(TxDb, Mrst, Docs, State) ->
couch_views_fdb:set_update_seq(TxDb, Sig, LastSeq).
-start_query_server(#mrst{} = Mrst) ->
+start_query_server(#mrst{qserver = nil} = Mrst) ->
#mrst{
language = Language,
lib = Lib,
@@ -223,7 +223,10 @@ start_query_server(#mrst{} = Mrst) ->
} = Mrst,
Defs = [View#mrview.def || View <- Views],
{ok, QServer} = couch_query_servers:start_doc_map(Language, Defs, Lib),
- Mrst#mrst{qserver = QServer}.
+ Mrst#mrst{qserver = QServer};
+
+start_query_server(#mrst{} = Mrst) ->
+ Mrst.
report_progress(State, UpdateType) ->