From d1c834e64714dafe39c0ad326ae16c52605831f1 Mon Sep 17 00:00:00 2001 From: Andrey Antukh Date: Tue, 1 Mar 2022 14:34:13 +0100 Subject: [PATCH] :bug: Fix minor issue on executors monitor --- backend/src/app/rpc/mutations/profile.clj | 1 - backend/src/app/worker.clj | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/backend/src/app/rpc/mutations/profile.clj b/backend/src/app/rpc/mutations/profile.clj index 4e2d207c8..07f3866b6 100644 --- a/backend/src/app/rpc/mutations/profile.clj +++ b/backend/src/app/rpc/mutations/profile.clj @@ -350,7 +350,6 @@ :opt-un [::lang ::theme])) (sv/defmethod ::update-profile - {::async/dispatch :default} [{:keys [pool] :as cfg} params] (db/with-atomic [conn pool] (let [profile (update-profile conn params)] diff --git a/backend/src/app/worker.clj b/backend/src/app/worker.clj index 44b72f63a..cf19b4138 100644 --- a/backend/src/app/worker.clj +++ b/backend/src/app/worker.clj @@ -79,9 +79,9 @@ (letfn [(log-stats [scheduler state] (doseq [[key ^ForkJoinPool executor] executors] (let [labels (into-array String [(name key)]) - active (.getActiveThreadCount executor) running (.getRunningThreadCount executor) queued (.getQueuedSubmissionCount executor) + active (.getPoolSize executor) steals (.getStealCount executor) steals-increment (- steals (or (get-in @state [key :steals]) 0)) steals-increment (if (neg? steals-increment) 0 steals-increment)]