denshooter/mxtasking
1
0
Fork 0
mirror of https://github.com/mmueller41/mxtasking.git synced 2026-01-21 12:42:57 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fixed incorrect pinning of worker threads.

Browse Source
This commit is contained in:
Michael Mueller
2023-03-27 16:34:34 +02:00
parent de5ba5d9c8
commit d32c7af315
1 changed files with 15 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/mx/tasking/worker.cpp
View File

@@ -4,8 +4,14 @@
#include "task.h"
#include <cassert>
#include <mx/system/builtin.h>
#include <mx/system/environment.h>
#include <mx/system/topology.h>
#include <mx/util/random.h>
#include <base/thread.h>
#include <base/affinity.h>
#include <chrono>
#include <base/log.h>
#include <trace/timestamp.h>
using namespace mx::tasking;
@@ -21,6 +27,13 @@ Worker::Worker(const std::uint16_t id, const std::uint16_t target_core_id, const
void Worker::execute()
{
{
Genode::Thread *self = Genode::Thread::myself();
Genode::Affinity::Location loc = system::Environment::location(_target_core_id);
self->pin(loc);
}
while (this->_is_running == false)
{
system::builtin::pause();
@@ -31,6 +44,8 @@ void Worker::execute()
assert(this->_target_core_id == core_id && "Worker not pinned to correct core.");
const auto channel_id = this->_channel.id();
while (this->_is_running)
{
if constexpr (config::memory_reclamation() == config::UpdateEpochPeriodically)