erki/skullc-peripherals
1
0
Fork 0
Code Issues Pull Requests Actions Projects Releases Wiki Activity

Threads: make actor and timer classes slightly more debuggable
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Erki 2021-07-03 01:22:24 +03:00
parent f4649142e5
commit c0f1ca6a87
2 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
Threads/Inc/threads_actor.hpp
View File

@ -32,11 +32,7 @@ public:
static_assert(std::is_trivially_copyable_v<value_type>, "Ts must be trivially copyable."); static_assert(std::is_trivially_copyable_v<value_type>, "Ts must be trivially copyable.");
Actor(const std::uint32_t queue_size, const char* name, const osPriority_t priority, const std::uint32_t stack_size) Actor(const std::uint32_t queue_size, const char* name, const osPriority_t priority, const std::uint32_t stack_size)
: thread_([](void* d) { : thread_(&Actor<CRTP, Ts...>::threadHandler_, this, name, priority, stack_size),
auto* dd = static_cast<Actor<CRTP, Ts...>*>(d);
(*dd)();
},
this, name, priority, stack_size),
msg_queue_(xQueueCreate(queue_size, sizeof(value_type))), signal_(this) msg_queue_(xQueueCreate(queue_size, sizeof(value_type))), signal_(this)
{ {
assert(msg_queue_); assert(msg_queue_);
@ -129,6 +125,12 @@ private:
} }
} }
static void threadHandler_(void* d)
{
auto* dd = static_cast<Actor<CRTP, Ts...>*>(d);
(*dd)();
}
Signal<value_type> signal_; Signal<value_type> signal_;
}; };

3
Threads/Src/threads_timer.cpp
View File

@ -82,7 +82,8 @@ void Timer::timeoutHandler_(TimerHandle_t timer)
if (!source) if (!source)
return; return;
static_cast<Timer*>(source)->signal_->emit(TimeoutSignal{}); auto* d = static_cast<Timer*>(source);
d->signal_->emit(TimeoutSignal{});
} }
}// namespace Threads }// namespace Threads