RGBCube/serenity
1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-07-24 21:37:34 +00:00
Code Issues Activity Actions

Kernel: Expose timers via a TimerId type

Browse source 
The public consumers of the timer API shouldn't need to know
the how timer id's are tracked internally. Expose a typedef
instead to allow the internal implementation to be protected
from potential churn in the future.

It's also just good API design.
This commit is contained in:
Brian Gianforcaro 2020-04-26 12:59:27 -07:00 • committed by Andreas Kling
parent 13c122b8b2
commit eeb5318c25
3 changed files with 10 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

2
Kernel/Thread.cpp
View file

@ -893,7 +893,7 @@ Thread::BlockResult Thread::wait_on(WaitQueue& queue, timeval* timeout, Atomic<b
set_state(State::Queued); set_state(State::Queued);
queue.enqueue(*current); queue.enqueue(*current);
u64 timer_id = 0; TimerId timer_id {};
if (timeout) { if (timeout) {
timer_id = TimerQueue::the().add_timer(*timeout, [&]() { timer_id = TimerQueue::the().add_timer(*timeout, [&]() {
wake_from_queue(); wake_from_queue();

6
Kernel/TimerQueue.cpp
View file

@ -47,7 +47,7 @@ TimerQueue::TimerQueue()
m_ticks_per_second = TimeManagement::the().ticks_per_second(); m_ticks_per_second = TimeManagement::the().ticks_per_second();
} }
u64 TimerQueue::add_timer(NonnullOwnPtr<Timer>&& timer) TimerId TimerQueue::add_timer(NonnullOwnPtr<Timer>&& timer)
{ {
ASSERT(timer->expires >= g_uptime); ASSERT(timer->expires >= g_uptime);
@ -64,7 +64,7 @@ u64 TimerQueue::add_timer(NonnullOwnPtr<Timer>&& timer)
return m_timer_id_count; return m_timer_id_count;
} }
u64 TimerQueue::add_timer(timeval& deadline, Function<void()>&& callback) TimerId TimerQueue::add_timer(timeval& deadline, Function<void()>&& callback)
{ {
NonnullOwnPtr timer = make<Timer>(); NonnullOwnPtr timer = make<Timer>();
timer->expires = g_uptime + seconds_to_ticks(deadline.tv_sec) + microseconds_to_ticks(deadline.tv_usec); timer->expires = g_uptime + seconds_to_ticks(deadline.tv_sec) + microseconds_to_ticks(deadline.tv_usec);
@ -72,7 +72,7 @@ u64 TimerQueue::add_timer(timeval& deadline, Function<void()>&& callback)
return add_timer(move(timer)); return add_timer(move(timer));
} }
bool TimerQueue::cancel_timer(u64 id) bool TimerQueue::cancel_timer(TimerId id)
{ {
auto it = m_timer_queue.find([id](auto& timer) { return timer->id == id; }); auto it = m_timer_queue.find([id](auto& timer) { return timer->id == id; });
if (it.is_end()) if (it.is_end())

10
Kernel/TimerQueue.h
View file

@ -34,8 +34,10 @@
namespace Kernel { namespace Kernel {
typedef u64 TimerId;
struct Timer { struct Timer {
u64 id; TimerId id;
u64 expires; u64 expires;
Function<void()> callback; Function<void()> callback;
bool operator<(const Timer& rhs) const bool operator<(const Timer& rhs) const
@ -56,9 +58,9 @@ class TimerQueue {
public: public:
static TimerQueue& the(); static TimerQueue& the();
u64 add_timer(NonnullOwnPtr<Timer>&&); TimerId add_timer(NonnullOwnPtr<Timer>&&);
u64 add_timer(timeval& timeout, Function<void()>&& callback); TimerId add_timer(timeval& timeout, Function<void()>&& callback);
bool cancel_timer(u64 id); bool cancel_timer(TimerId id);
void fire(); void fire();
private: private: