mirrors/shadPS4
1
0
Fork 0
mirror of https://github.com/shadps4-emu/shadPS4.git synced 2025-07-25 19:44:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

support wait for multiple timers

Browse Source
This commit is contained in:
Fire Cube 2025-06-15 14:14:37 +02:00
parent 95d592ebf0
commit b312171e83
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/core/libraries/kernel/equeue.cpp
View File

@ -191,24 +191,29 @@ bool EqueueInternal::AddSmallTimer(EqueueEvent& ev) {
} }
int EqueueInternal::WaitForSmallTimer(SceKernelEvent* ev, int num, u32 micros) { int EqueueInternal::WaitForSmallTimer(SceKernelEvent* ev, int num, u32 micros) {
ASSERT(num == 1); // Could be extended to support more events if needed ASSERT(num >= 1);
auto curr_clock = std::chrono::steady_clock::now(); auto curr_clock = std::chrono::steady_clock::now();
const auto wait_end_us = (micros == 0) ? std::chrono::steady_clock::time_point::max() const auto wait_end_us = (micros == 0) ? std::chrono::steady_clock::time_point::max()
: curr_clock + std::chrono::microseconds{micros}; : curr_clock + std::chrono::microseconds{micros};
int count = 0;
do { do {
curr_clock = std::chrono::steady_clock::now(); curr_clock = std::chrono::steady_clock::now();
{ {
std::scoped_lock lock{m_mutex}; std::scoped_lock lock{m_mutex};
for (auto it = m_small_timers.begin(); it != m_small_timers.end(); ++it) { for (auto it = m_small_timers.begin(); it != m_small_timers.end() && count < num;) {
const SmallTimer& st = it->second; const SmallTimer& st = it->second;
if (curr_clock - st.added >= st.interval) { if (curr_clock - st.added >= st.interval) {
ev[0] = st.event; ev[count++] = st.event;
m_small_timers.erase(it); it = m_small_timers.erase(it);
return 1; } else {
++it;
} }
} }
if (count > 0)
return count;
} }
std::this_thread::yield(); std::this_thread::yield();
} while (curr_clock < wait_end_us); } while (curr_clock < wait_end_us);