This is an automated email from the ASF dual-hosted git repository. chewbranca pushed a commit to branch dedicated-ioq-search-function in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit deef12eff39bd7294dd3940ca1c0b9b2b6751241 Author: Russell Branca <[email protected]> AuthorDate: Tue Jul 26 11:22:32 2022 -0700 Add ioq:call_search --- src/dreyfus/src/clouseau_rpc.erl | 2 +- src/ioq/src/ioq.erl | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/src/dreyfus/src/clouseau_rpc.erl b/src/dreyfus/src/clouseau_rpc.erl index 908182793..d49d8839a 100644 --- a/src/dreyfus/src/clouseau_rpc.erl +++ b/src/dreyfus/src/clouseau_rpc.erl @@ -102,7 +102,7 @@ connected() -> end. rpc(Ref, Msg) -> - ioq:call(Ref, Msg, erlang:get(io_priority)). + ioq:call_search(Ref, Msg, erlang:get(io_priority)). clouseau() -> list_to_atom(config:get("dreyfus", "name", "[email protected]")). diff --git a/src/ioq/src/ioq.erl b/src/ioq/src/ioq.erl index 945e455ce..038d63bae 100644 --- a/src/ioq/src/ioq.erl +++ b/src/ioq/src/ioq.erl @@ -14,7 +14,7 @@ -behaviour(gen_server). -behaviour(config_listener). --export([start_link/0, call/3]). +-export([start_link/0, call/3, call_search/3]). -export([get_queue_lengths/0]). -export([get_io_priority/0, set_io_priority/1, maybe_set_io_priority/1]). -export([init/1, handle_call/3, handle_cast/2, handle_info/2, code_change/3, terminate/2]). @@ -55,6 +55,9 @@ maybe_set_io_priority(Priority) -> start_link() -> gen_server:start_link({local, ?MODULE}, ?MODULE, [], []). +call_search(Fd, Msg, Metadata) -> + call(Fd, Msg, Metadata). + call(Fd, Msg, Metadata) -> Priority = io_class(Msg, Metadata), case bypass(Priority) of
