This is an automated email from the ASF dual-hosted git repository. nickva pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/couchdb.git
commit 2eed4886d1853b97459ffd4f0c827e0cdd816a91 Author: Sam Smith <[email protected]> AuthorDate: Thu Jul 16 10:48:35 2026 +0100 sq - update gauge in dec_count and inc_count --- src/couch/src/couch_proc_manager.erl | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/couch/src/couch_proc_manager.erl b/src/couch/src/couch_proc_manager.erl index a95acc7c0..20ed2d50d 100644 --- a/src/couch/src/couch_proc_manager.erl +++ b/src/couch/src/couch_proc_manager.erl @@ -252,7 +252,6 @@ handle_info({'EXIT', Pid, spawn_error}, State) -> % Assert when removing that we always expect the opener to have been there [{Pid, #client{lang = Lang}}] = ets:take(?OPENING, Pid), dec_count(Lang), - couch_stats:update_gauge([couchdb, query_server, process_count], get_proc_count()), ok = flush_waiters(State, Lang), {noreply, State}; handle_info({'EXIT', Pid, Reason}, State) -> @@ -373,8 +372,7 @@ find_proc(Lang, DbPat, DDocKey) when spawn_proc(#client{} = Client) -> Pid = spawn_link(?MODULE, new_proc, [Client]), ets:insert(?OPENING, {Pid, Client}), - inc_count(Client#client.lang), - couch_stats:update_gauge([couchdb, query_server, process_count], get_proc_count()). + inc_count(Client#client.lang). % This instance was spawned without a client to replenish % the untagged pool asynchronously @@ -690,8 +688,7 @@ remove_proc(#proc{pid = Pid} = Proc) -> false -> ok end, - dec_count(Proc#proc.lang), - couch_stats:update_gauge([couchdb, query_server, process_count], get_proc_count()). + dec_count(Proc#proc.lang). flush_waiters(#state{} = State, Lang) -> #state{hard_limit = HardLimit, config = {[_ | _] = Cfg}} = State, @@ -803,10 +800,12 @@ foreach_proc(Fun) when is_function(Fun, 1) -> inc_count(Lang) -> ets:update_counter(?COUNTERS, Lang, 1, {Lang, 0}), + couch_stats:update_gauge([couchdb, query_server, process_count], get_proc_count()), ok. dec_count(Lang) -> ets:update_counter(?COUNTERS, Lang, -1, {Lang, 0}), + couch_stats:update_gauge([couchdb, query_server, process_count], get_proc_count()), ok. get_count(Lang) ->
