diff options
author | Andreas Kling <awesomekling@gmail.com> | 2019-04-18 01:37:23 +0200 |
---|---|---|
committer | Andreas Kling <awesomekling@gmail.com> | 2019-04-18 01:37:23 +0200 |
commit | 8e0611201e875b97cd4ad6cef3426e5a76d8119e (patch) | |
tree | 74a0bc9a1fb31cf163fa11b443bbba5fa3b11d96 /LibCore | |
parent | ab539460de91cae51edbbfba2836c8e886092246 (diff) | |
download | serenity-8e0611201e875b97cd4ad6cef3426e5a76d8119e.zip |
CEventLoop: Consolidate gettimeofday() syscalls.
Diffstat (limited to 'LibCore')
-rw-r--r-- | LibCore/CEventLoop.cpp | 19 | ||||
-rw-r--r-- | LibCore/CEventLoop.h | 4 |
2 files changed, 13 insertions, 10 deletions
diff --git a/LibCore/CEventLoop.cpp b/LibCore/CEventLoop.cpp index d18da8fc65..7fccd26109 100644 --- a/LibCore/CEventLoop.cpp +++ b/LibCore/CEventLoop.cpp @@ -170,16 +170,19 @@ void CEventLoop::wait_for_event() ASSERT_NOT_REACHED(); } + timeval now; + gettimeofday(&now, nullptr); + for (auto& it : *s_timers) { auto& timer = *it.value; - if (!timer.has_expired()) + if (!timer.has_expired(now)) continue; #ifdef CEVENTLOOP_DEBUG dbgprintf("CEventLoop: Timer %d has expired, sending CTimerEvent to %p\n", timer.timer_id, timer.owner); #endif post_event(*timer.owner, make<CTimerEvent>(timer.timer_id)); if (timer.should_reload) { - timer.reload(); + timer.reload(now); } else { // FIXME: Support removing expired timers that don't want to reload. ASSERT_NOT_REACHED(); @@ -200,16 +203,14 @@ void CEventLoop::wait_for_event() process_file_descriptors_after_select(rfds); } -bool CEventLoop::EventLoopTimer::has_expired() const +bool CEventLoop::EventLoopTimer::has_expired(const timeval& now) const { - timeval now; - gettimeofday(&now, nullptr); return now.tv_sec > fire_time.tv_sec || (now.tv_sec == fire_time.tv_sec && now.tv_usec >= fire_time.tv_usec); } -void CEventLoop::EventLoopTimer::reload() +void CEventLoop::EventLoopTimer::reload(const timeval& now) { - gettimeofday(&fire_time, nullptr); + fire_time = now; fire_time.tv_sec += interval / 1000; fire_time.tv_usec += (interval % 1000) * 1000; } @@ -232,7 +233,9 @@ int CEventLoop::register_timer(CObject& object, int milliseconds, bool should_re auto timer = make<EventLoopTimer>(); timer->owner = object.make_weak_ptr(); timer->interval = milliseconds; - timer->reload(); + timeval now; + gettimeofday(&now, nullptr); + timer->reload(now); timer->should_reload = should_reload; int timer_id = ++s_next_timer_id; // FIXME: This will eventually wrap around. ASSERT(timer_id); // FIXME: Aforementioned wraparound. diff --git a/LibCore/CEventLoop.h b/LibCore/CEventLoop.h index 9f97461711..509c0ebd73 100644 --- a/LibCore/CEventLoop.h +++ b/LibCore/CEventLoop.h @@ -65,8 +65,8 @@ private: bool should_reload { false }; WeakPtr<CObject> owner; - void reload(); - bool has_expired() const; + void reload(const timeval& now); + bool has_expired(const timeval& now) const; }; static HashMap<int, OwnPtr<EventLoopTimer>>* s_timers; |