aboutsummaryrefslogtreecommitdiff
path: root/src/zencompute/functionrunner.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2026-02-25 12:42:18 +0100
committerStefan Boberg <[email protected]>2026-02-25 12:42:18 +0100
commitefe3001263028a2932d38b559552e9903eb1250d (patch)
tree973253c5dcc947ba2277294c9e1cd17f3d84eb87 /src/zencompute/functionrunner.cpp
parentadded BaseRunnerGroup with all concrete RunnerGroup state+logic (diff)
downloadzen-efe3001263028a2932d38b559552e9903eb1250d.tar.xz
zen-efe3001263028a2932d38b559552e9903eb1250d.zip
added ZEN_TRACE_CPU to various functions
Diffstat (limited to 'src/zencompute/functionrunner.cpp')
-rw-r--r--src/zencompute/functionrunner.cpp3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/zencompute/functionrunner.cpp b/src/zencompute/functionrunner.cpp
index 6b04add46..ccd396980 100644
--- a/src/zencompute/functionrunner.cpp
+++ b/src/zencompute/functionrunner.cpp
@@ -6,6 +6,7 @@
# include <zencore/compactbinary.h>
# include <zencore/filesystem.h>
+# include <zencore/trace.h>
# include <fmt/format.h>
# include <vector>
@@ -74,6 +75,7 @@ BaseRunnerGroup::QueryCapacity()
SubmitResult
BaseRunnerGroup::SubmitAction(Ref<RunnerAction> Action)
{
+ ZEN_TRACE_CPU("BaseRunnerGroup::SubmitAction");
RwLock::SharedLockScope _(m_RunnersLock);
const int InitialIndex = m_NextSubmitIndex.load(std::memory_order_acquire);
@@ -115,6 +117,7 @@ BaseRunnerGroup::SubmitAction(Ref<RunnerAction> Action)
std::vector<SubmitResult>
BaseRunnerGroup::SubmitActions(const std::vector<Ref<RunnerAction>>& Actions)
{
+ ZEN_TRACE_CPU("BaseRunnerGroup::SubmitActions");
RwLock::SharedLockScope _(m_RunnersLock);
const int RunnerCount = gsl::narrow<int>(m_Runners.size());