diff options
| author | Russell Branca <chewbranca@apache.org> | 2022-07-26 11:22:32 -0700 |
|---|---|---|
| committer | Russell Branca <chewbranca@apache.org> | 2022-07-26 11:22:32 -0700 |
| commit | deef12eff39bd7294dd3940ca1c0b9b2b6751241 (patch) | |
| tree | 042cfa411b67fa629dee64b780c491ebd9e81897 | |
| parent | 74f12c74d393fc1a35fee3fe1fbf5db372525879 (diff) | |
| download | couchdb-deef12eff39bd7294dd3940ca1c0b9b2b6751241.tar.gz | |
Add ioq:call_search
| -rw-r--r-- | src/dreyfus/src/clouseau_rpc.erl | 2 | ||||
| -rw-r--r-- | 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", "clouseau@127.0.0.1")). 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 |