summaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
authorKelebek1 <eeeedddccc@hotmail.co.uk>2022-07-27 23:31:41 +0200
committerMorph <39850852+Morph1984@users.noreply.github.com>2022-08-02 07:01:54 +0200
commit83a24ad638a2c3ff628fe109391586be9bd3a45d (patch)
tree3ac77d8c6876200075bd6c68eebc6f4098df1422 /src
parentRework multi-core vsync (diff)
downloadyuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.tar
yuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.tar.gz
yuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.tar.bz2
yuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.tar.lz
yuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.tar.xz
yuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.tar.zst
yuzu-83a24ad638a2c3ff628fe109391586be9bd3a45d.zip
Diffstat (limited to 'src')
-rw-r--r--src/common/thread.h4
-rw-r--r--src/core/core_timing.cpp38
2 files changed, 31 insertions, 11 deletions
diff --git a/src/common/thread.h b/src/common/thread.h
index 1552f58e0..e17a7850f 100644
--- a/src/common/thread.h
+++ b/src/common/thread.h
@@ -54,6 +54,10 @@ public:
is_set = false;
}
+ [[nodiscard]] bool IsSet() {
+ return is_set;
+ }
+
private:
std::condition_variable condvar;
std::mutex mutex;
diff --git a/src/core/core_timing.cpp b/src/core/core_timing.cpp
index 2dbb99c8b..b45c1b918 100644
--- a/src/core/core_timing.cpp
+++ b/src/core/core_timing.cpp
@@ -243,17 +243,17 @@ std::optional<s64> CoreTiming::Advance() {
basic_lock.lock();
if (evt.reschedule_time != 0) {
+ const auto next_schedule_time{new_schedule_time.has_value()
+ ? new_schedule_time.value().count()
+ : evt.reschedule_time};
+
// If this event was scheduled into a pause, its time now is going to be way behind.
// Re-set this event to continue from the end of the pause.
- auto next_time{evt.time + evt.reschedule_time};
+ auto next_time{evt.time + next_schedule_time};
if (evt.time < pause_end_time) {
- next_time = pause_end_time + evt.reschedule_time;
+ next_time = pause_end_time + next_schedule_time;
}
- const auto next_schedule_time{new_schedule_time.has_value()
- ? new_schedule_time.value().count()
- : evt.reschedule_time};
-
event_queue.emplace_back(
Event{next_time, event_fifo_id++, evt.user_data, evt.type, next_schedule_time});
std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>());
@@ -264,8 +264,7 @@ std::optional<s64> CoreTiming::Advance() {
}
if (!event_queue.empty()) {
- const s64 next_time = event_queue.front().time - global_timer;
- return next_time;
+ return event_queue.front().time;
} else {
return std::nullopt;
}
@@ -278,11 +277,28 @@ void CoreTiming::ThreadLoop() {
paused_set = false;
const auto next_time = Advance();
if (next_time) {
- if (*next_time > 0) {
- std::chrono::nanoseconds next_time_ns = std::chrono::nanoseconds(*next_time);
- event.WaitFor(next_time_ns);
+ // There are more events left in the queue, sleep until the next event.
+ const auto diff_ns{*next_time - GetGlobalTimeNs().count()};
+ if (diff_ns > 0) {
+ // Only try to sleep if the remaining time is >= 1ms. Take off 500 microseconds
+ // from the target time to account for possible over-sleeping, and spin the
+ // remaining.
+ const auto sleep_time_ns{diff_ns - 500LL * 1'000LL};
+ const auto sleep_time_ms{sleep_time_ns / 1'000'000LL};
+ if (sleep_time_ms >= 1) {
+ event.WaitFor(std::chrono::nanoseconds(sleep_time_ns));
+ }
+
+ const auto end_time{std::chrono::nanoseconds(*next_time)};
+ while (!paused && !event.IsSet() && GetGlobalTimeNs() < end_time) {
+ }
+
+ if (event.IsSet()) {
+ event.Reset();
+ }
}
} else {
+ // Queue is empty, wait until another event is scheduled and signals us to continue.
wait_set = true;
event.Wait();
}