diff options
| author | Russell Branca <chewbranca@apache.org> | 2019-04-12 22:17:53 +0000 |
|---|---|---|
| committer | Russell Branca <chewbranca@apache.org> | 2019-04-12 22:42:39 +0000 |
| commit | 75d86c49c86f4e7e299d2d05a741c4ef68a144fb (patch) | |
| tree | 983539cbe1fdbf3e2fded0861f7f8987673cd805 | |
| parent | 7083d1ec2587a44e568b3d87c82d6a03209d8c64 (diff) | |
| download | couchdb-75d86c49c86f4e7e299d2d05a741c4ef68a144fb.tar.gz | |
Use dedicated search IOQ channel
| -rw-r--r-- | src/dreyfus_index_updater.erl | 2 | ||||
| -rw-r--r-- | src/dreyfus_rpc.erl | 6 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/dreyfus_index_updater.erl b/src/dreyfus_index_updater.erl index 40fd0c377..3720cb63c 100644 --- a/src/dreyfus_index_updater.erl +++ b/src/dreyfus_index_updater.erl @@ -28,7 +28,7 @@ update(IndexPid, Index) -> ddoc_id = DDocId, name = IndexName } = Index, - erlang:put(io_priority, {view_update, DbName, IndexName}), + erlang:put(io_priority, {search, DbName, IndexName}), {ok, Db} = couch_db:open_int(DbName, []), try TotalUpdateChanges = couch_db:count_changes_since(Db, CurSeq), diff --git a/src/dreyfus_rpc.erl b/src/dreyfus_rpc.erl index 97a0526a9..5542bd029 100644 --- a/src/dreyfus_rpc.erl +++ b/src/dreyfus_rpc.erl @@ -38,7 +38,7 @@ group2(DbName, DDoc, IndexName, QueryArgs) -> call(Fun, DbName, DDoc, IndexName, QueryArgs0) -> QueryArgs = dreyfus_util:upgrade(QueryArgs0), - erlang:put(io_priority, {interactive, DbName}), + erlang:put(io_priority, {search, DbName}), check_interactive_mode(), {ok, Db} = get_or_create_db(DbName, []), #index_query_args{ @@ -75,7 +75,7 @@ info(DbName, DDoc, IndexName) -> dreyfus_util:time([rpc, info], MFA). info_int(DbName, DDoc, IndexName) -> - erlang:put(io_priority, {interactive, DbName}), + erlang:put(io_priority, {search, DbName}), check_interactive_mode(), case dreyfus_index:design_doc_to_index(DDoc, IndexName) of {ok, Index} -> @@ -91,7 +91,7 @@ info_int(DbName, DDoc, IndexName) -> end. disk_size(DbName, DDoc, IndexName) -> - erlang:put(io_priority, {interactive, DbName}), + erlang:put(io_priority, {search, DbName}), check_interactive_mode(), case dreyfus_index:design_doc_to_index(DDoc, IndexName) of {ok, Index} -> |