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)