hyprwm/hyprlock
1
0
Fork 0
mirror of https://github.com/hyprwm/hyprlock.git synced 2024-11-16 23:05:58 +01:00
Code Issues Projects Releases Packages Wiki Activity

core: fixup timer thread operations

Browse source
This commit is contained in:
Vaxry 2024-02-20 00:31:11 +00:00
parent d45b0e35b1
commit 96f2818915
2 changed files with 13 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/core/hyprlock.cpp
View file

@ -165,7 +165,11 @@ void CHyprlock::run() {
m_sLoopState.timersMutex.unlock(); m_sLoopState.timersMutex.unlock();
std::unique_lock lk(m_sLoopState.timerRequestMutex); std::unique_lock lk(m_sLoopState.timerRequestMutex);
m_sLoopState.timerCV.wait_for(lk, std::chrono::milliseconds((int)least + 1), [this] { return m_sLoopState.event; }); m_sLoopState.timerCV.wait_for(lk, std::chrono::milliseconds((int)least + 1), [this] { return m_sLoopState.timerEvent; });
m_sLoopState.timerEvent = false;
if (m_bTerminate)
break;
// notify main // notify main
std::lock_guard<std::mutex> lg2(m_sLoopState.eventLoopMutex); std::lock_guard<std::mutex> lg2(m_sLoopState.eventLoopMutex);
@ -230,6 +234,9 @@ void CHyprlock::run() {
} while (ret > 0); } while (ret > 0);
} }
std::lock_guard<std::mutex> lg2(m_sLoopState.timerRequestMutex);
m_sLoopState.timerCV.notify_all();
Debug::log(LOG, "Reached the end, exiting"); Debug::log(LOG, "Reached the end, exiting");
} }
@ -493,5 +500,8 @@ size_t CHyprlock::getPasswordBufferLen() {
std::shared_ptr<CTimer> CHyprlock::addTimer(const std::chrono::system_clock::duration& timeout, std::function<void(std::shared_ptr<CTimer> self, void* data)> cb_, void* data) { std::shared_ptr<CTimer> CHyprlock::addTimer(const std::chrono::system_clock::duration& timeout, std::function<void(std::shared_ptr<CTimer> self, void* data)> cb_, void* data) {
std::lock_guard<std::mutex> lg(m_sLoopState.timersMutex); std::lock_guard<std::mutex> lg(m_sLoopState.timersMutex);
return m_vTimers.emplace_back(std::make_shared<CTimer>(timeout, cb_, data)); const auto T = m_vTimers.emplace_back(std::make_shared<CTimer>(timeout, cb_, data));
m_sLoopState.timerEvent = true;
m_sLoopState.timerCV.notify_all();
return T;
} }

1
src/core/hyprlock.hpp
View file

@ -81,6 +81,7 @@ class CHyprlock {
std::condition_variable timerCV; std::condition_variable timerCV;
std::mutex timerRequestMutex; std::mutex timerRequestMutex;
bool timerEvent = false;
} m_sLoopState; } m_sLoopState;
std::vector<std::unique_ptr<COutput>> m_vOutputs; std::vector<std::unique_ptr<COutput>> m_vOutputs;