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)