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 01:03:32 UTC

(couchdb-ioq) branch couch-stats-resource-tracker created (now 35c8e84)

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

chewbranca pushed a change to branch couch-stats-resource-tracker
in repository https://gitbox.apache.org/repos/asf/couchdb-ioq.git


      at 35c8e84  Increment csrt ioq called

This branch includes the following new commits:

     new 35c8e84  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 couch-stats-resource-tracker
in repository https://gitbox.apache.org/repos/asf/couchdb-ioq.git

commit 35c8e84579e810e49c62c63cb8f2b71935aa684d
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)