early-access version 2808

This commit is contained in:
pineappleEA 2022-06-30 13:30:20 +02:00
parent c77e0b9e33
commit eb6a9c8efb
3 changed files with 18 additions and 7 deletions

View File

@ -1,7 +1,7 @@
yuzu emulator early access yuzu emulator early access
============= =============
This is the source code for early-access 2807. This is the source code for early-access 2808.
## Legal Notice ## Legal Notice

View File

@ -6,6 +6,7 @@
#include <string> #include <string>
#include <tuple> #include <tuple>
#include "common/logging/log.h"
#include "common/microprofile.h" #include "common/microprofile.h"
#include "common/thread.h" #include "common/thread.h"
#include "core/core_timing.h" #include "core/core_timing.h"
@ -128,7 +129,7 @@ bool CoreTiming::IsRunning() const {
bool CoreTiming::HasPendingEvents() const { bool CoreTiming::HasPendingEvents() const {
std::unique_lock main_lock(event_mutex); std::unique_lock main_lock(event_mutex);
return !event_queue.empty(); return !event_queue.empty() || pending_events.load(std::memory_order_relaxed) != 0;
} }
void CoreTiming::ScheduleEvent(std::chrono::nanoseconds ns_into_future, void CoreTiming::ScheduleEvent(std::chrono::nanoseconds ns_into_future,
@ -139,6 +140,7 @@ void CoreTiming::ScheduleEvent(std::chrono::nanoseconds ns_into_future,
const u64 timeout = static_cast<u64>((GetGlobalTimeNs() + ns_into_future).count()); const u64 timeout = static_cast<u64>((GetGlobalTimeNs() + ns_into_future).count());
event_queue.emplace_back(Event{timeout, event_fifo_id++, user_data, event_type}); event_queue.emplace_back(Event{timeout, event_fifo_id++, user_data, event_type});
pending_events.fetch_add(1, std::memory_order_relaxed);
std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>()); std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>());
@ -158,6 +160,7 @@ void CoreTiming::UnscheduleEvent(const std::shared_ptr<EventType>& event_type,
if (itr != event_queue.end()) { if (itr != event_queue.end()) {
event_queue.erase(itr, event_queue.end()); event_queue.erase(itr, event_queue.end());
std::make_heap(event_queue.begin(), event_queue.end(), std::greater<>()); std::make_heap(event_queue.begin(), event_queue.end(), std::greater<>());
pending_events.fetch_sub(1, std::memory_order_relaxed);
} }
} }
@ -223,15 +226,21 @@ std::optional<s64> CoreTiming::Advance() {
Event evt = std::move(event_queue.front()); Event evt = std::move(event_queue.front());
std::pop_heap(event_queue.begin(), event_queue.end(), std::greater<>()); std::pop_heap(event_queue.begin(), event_queue.end(), std::greater<>());
event_queue.pop_back(); event_queue.pop_back();
event_mutex.unlock();
if (const auto event_type{evt.type.lock()}) { if (const auto event_type{evt.type.lock()}) {
std::unique_lock lk(event_type->guard); sequence_mutex.lock();
event_type->callback(evt.user_data, std::chrono::nanoseconds{static_cast<s64>( event_mutex.unlock();
GetGlobalTimeNs().count() - evt.time)});
event_type->guard.lock();
sequence_mutex.unlock();
const s64 delay = static_cast<s64>(GetGlobalTimeNs().count() - evt.time);
event_type->callback(evt.user_data, std::chrono::nanoseconds{delay});
event_type->guard.unlock();
event_mutex.lock();
pending_events.fetch_sub(1, std::memory_order_relaxed);
} }
event_mutex.lock();
global_timer = GetGlobalTimeNs().count(); global_timer = GetGlobalTimeNs().count();
} }

View File

@ -145,6 +145,7 @@ private:
// accomodated by the standard adaptor class. // accomodated by the standard adaptor class.
std::vector<Event> event_queue; std::vector<Event> event_queue;
u64 event_fifo_id = 0; u64 event_fifo_id = 0;
std::atomic<size_t> pending_events{};
std::shared_ptr<EventType> ev_lost; std::shared_ptr<EventType> ev_lost;
std::atomic<bool> has_started{}; std::atomic<bool> has_started{};
@ -156,6 +157,7 @@ private:
std::condition_variable wait_pause_cv; std::condition_variable wait_pause_cv;
std::condition_variable wait_signal_cv; std::condition_variable wait_signal_cv;
mutable std::mutex event_mutex; mutable std::mutex event_mutex;
mutable std::mutex sequence_mutex;
std::atomic<bool> paused_state{}; std::atomic<bool> paused_state{};
bool is_paused{}; bool is_paused{};