From deef12eff39bd7294dd3940ca1c0b9b2b6751241 Mon Sep 17 00:00:00 2001 From: Russell Branca Date: Tue, 26 Jul 2022 11:22:32 -0700 Subject: [PATCH] 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 90818279373..d49d8839a7b 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 945e455cedc..038d63bae6f 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