[couchdb-ioq] branch ioq-per-shard-or-user updated: Let ioq_server use ioq_file records

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chewbranca pushed a commit to branch ioq-per-shard-or-user
in repository https://gitbox.apache.org/repos/asf/couchdb-ioq.git


The following commit(s) were added to refs/heads/ioq-per-shard-or-user by this push:
     new 1cbb9f2  Let ioq_server use ioq_file records
1cbb9f2 is described below

commit 1cbb9f22c2796a4f3314a71390b0d3e3825792b3
Author: Russell Branca <ch...@apache.org>
AuthorDate: Thu Sep 2 15:13:39 2021 -0700

    Let ioq_server use ioq_file records
---
 src/ioq_server.erl | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/ioq_server.erl b/src/ioq_server.erl
index c9fd79b..4419692 100644
--- a/src/ioq_server.erl
+++ b/src/ioq_server.erl
@@ -74,7 +74,7 @@ call(Fd, Msg, Priority) ->
             RW = rw(Msg),
             catch couch_stats:increment_counter([couchdb, io_queue_bypassed, Class]),
             catch couch_stats:increment_counter([couchdb, io_queue_bypassed, RW]),
-            gen_server:call(Fd, Msg, infinity);
+            gen_server:call(ioq:fd_pid(Fd), Msg, infinity);
         _ ->
             gen_server:call(?MODULE, Request, infinity)
     end.
@@ -406,12 +406,13 @@ make_next_request(State) ->
 submit_request(Request, State) ->
     #request{
         channel = Channel,
-        fd = Fd,
+        fd = IOF,
         msg = Call,
         t0 = T0,
         class = IOClass
     } = Request,
     #state{reqs = Reqs, counters = Counters} = State,
+    Fd = ioq:fd_pid(IOF),
 
     % make the request
     Ref = erlang:monitor(process, Fd),