You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@couchdb.apache.org by ch...@apache.org on 2024/02/14 00:58:56 UTC
(couchdb-ioq) branch 339-changes-feed-cost-accounting created (now da5b44a)
This is an automated email from the ASF dual-hosted git repository.
chewbranca pushed a change to branch 339-changes-feed-cost-accounting
in repository https://gitbox.apache.org/repos/asf/couchdb-ioq.git
at da5b44a Increment csrt ioq called
This branch includes the following new commits:
new da5b44a Increment csrt ioq called
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(couchdb-ioq) 01/01: Increment csrt ioq called
Posted by ch...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
chewbranca pushed a commit to branch 339-changes-feed-cost-accounting
in repository https://gitbox.apache.org/repos/asf/couchdb-ioq.git
commit da5b44a6056bc646ab4ff66cfca62debaa1e282c
Author: Russell Branca <ch...@apache.org>
AuthorDate: Tue Feb 13 16:58:42 2024 -0800
Increment csrt ioq called
---
src/ioq.erl | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/src/ioq.erl b/src/ioq.erl
index ca7cae7..ab97550 100644
--- a/src/ioq.erl
+++ b/src/ioq.erl
@@ -47,12 +47,16 @@ call(Pid, {prompt, _} = Msg, Priority) ->
call(Pid, {data, _} = Msg, Priority) ->
ioq_osq:call(Pid, Msg, Priority);
call(Fd, Msg, Priority) ->
+ %% TODO: should this key off of existing couch_stats like most things?
+ %% TODO: if so, which set of IOQ fields and to what granularity?
+ couch_stats_resource_tracker:ioq_called(),
case ioq2_enabled() of
false -> ioq_server:call(Fd, Msg, Priority);
true -> ioq_server2:call(Fd, Msg, Priority)
end.
call_search(Fd, Msg, Priority) ->
+ couch_stats_resource_tracker:ioq_called(), %% TODO: flag as search
case ioq2_enabled() of
false -> ioq_server:call(Fd, Msg, Priority);
true -> ioq_server2:call_search(Fd, Msg, Priority)