From 7822b0e14b74fc17b5797103aad84fab0b639ead Mon Sep 17 00:00:00 2001
From: Florian Fischer <florian.fischer@muhq.space>
Date: Fri, 8 Oct 2021 11:13:37 +0200
Subject: [PATCH] [AbstractWorkStealingStats] actually use hint stats
---
emper/strategies/AbstractWorkStealingScheduler.cpp | 2 ++
emper/strategies/AbstractWorkStealingWorkerStats.cpp | 2 ++
2 files changed, 4 insertions(+)
diff --git a/emper/strategies/AbstractWorkStealingScheduler.cpp b/emper/strategies/AbstractWorkStealingScheduler.cpp
index fba97e7d..976baada 100644
--- a/emper/strategies/AbstractWorkStealingScheduler.cpp
+++ b/emper/strategies/AbstractWorkStealingScheduler.cpp
@@ -168,6 +168,7 @@ popBottom:
if (stolen) {
fiber = (*stolen).first;
fiberSource = FiberSource::hintWsq;
+ emper::statsIncr(awss::stats.nextFiberFromHintLocal);
goto out;
}
} break;
@@ -177,6 +178,7 @@ popBottom:
if (fromAnywhere) {
fiber = (*fromAnywhere).first;
fiberSource = FiberSource::hintAq;
+ emper::statsIncr(awss::stats.nextFiberFromHintAnywhere);
goto out;
}
break;
diff --git a/emper/strategies/AbstractWorkStealingWorkerStats.cpp b/emper/strategies/AbstractWorkStealingWorkerStats.cpp
index c7adae3f..7e164d33 100644
--- a/emper/strategies/AbstractWorkStealingWorkerStats.cpp
+++ b/emper/strategies/AbstractWorkStealingWorkerStats.cpp
@@ -10,6 +10,8 @@ auto AbstractWorkStealingWorkerStats::operator+=(const AbstractWorkStealingWorke
scheduledFibersToOverflowQueue += other.scheduledFibersToOverflowQueue;
maxQueueLength = std::max(maxQueueLength, other.maxQueueLength);
nextFiberFromLocal += other.nextFiberFromLocal;
+ nextFiberFromHintLocal += other.nextFiberFromHintLocal;
+ nextFiberFromHintAnywhere += other.nextFiberFromHintAnywhere;
nextFiberStolen += other.nextFiberStolen;
nextFiberFromAnywhereQueue += other.nextFiberFromAnywhereQueue;
--
GitLab