diff options
| author | 2018-08-12 17:47:15 -0500 | |
|---|---|---|
| committer | 2018-08-12 18:40:56 -0500 | |
| commit | 0135b328edb1b58d1ff97cfdc35e05f02cec1c2a (patch) | |
| tree | a06b72074fc7ef0ae0e69c9ecf83773adabb1308 /src | |
| parent | Merge pull request #1029 from bunnei/fix-out-attrib (diff) | |
| download | yuzu-0135b328edb1b58d1ff97cfdc35e05f02cec1c2a.tar.gz yuzu-0135b328edb1b58d1ff97cfdc35e05f02cec1c2a.tar.xz yuzu-0135b328edb1b58d1ff97cfdc35e05f02cec1c2a.zip | |
Kernel/Thread: Always use the threadsafe option when scheduling wakeups.
WakeAfterDelay might be called from any host thread, so err on the side of caution and use the thread-safe CoreTiming::ScheduleEventThreadsafe.
Note that CoreTiming is still far from thread-safe, there may be more things we have to work on for it to be up to par with what we want.
Diffstat (limited to 'src')
| -rw-r--r-- | src/core/core_timing.cpp | 2 | ||||
| -rw-r--r-- | src/core/hle/kernel/thread.cpp | 6 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/core/core_timing.cpp b/src/core/core_timing.cpp index d3bb6f818..f977d1b32 100644 --- a/src/core/core_timing.cpp +++ b/src/core/core_timing.cpp | |||
| @@ -135,11 +135,9 @@ void ClearPendingEvents() { | |||
| 135 | void ScheduleEvent(s64 cycles_into_future, const EventType* event_type, u64 userdata) { | 135 | void ScheduleEvent(s64 cycles_into_future, const EventType* event_type, u64 userdata) { |
| 136 | ASSERT(event_type != nullptr); | 136 | ASSERT(event_type != nullptr); |
| 137 | s64 timeout = GetTicks() + cycles_into_future; | 137 | s64 timeout = GetTicks() + cycles_into_future; |
| 138 | |||
| 139 | // If this event needs to be scheduled before the next advance(), force one early | 138 | // If this event needs to be scheduled before the next advance(), force one early |
| 140 | if (!is_global_timer_sane) | 139 | if (!is_global_timer_sane) |
| 141 | ForceExceptionCheck(cycles_into_future); | 140 | ForceExceptionCheck(cycles_into_future); |
| 142 | |||
| 143 | event_queue.emplace_back(Event{timeout, event_fifo_id++, userdata, event_type}); | 141 | event_queue.emplace_back(Event{timeout, event_fifo_id++, userdata, event_type}); |
| 144 | std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>()); | 142 | std::push_heap(event_queue.begin(), event_queue.end(), std::greater<>()); |
| 145 | } | 143 | } |
diff --git a/src/core/hle/kernel/thread.cpp b/src/core/hle/kernel/thread.cpp index b9022feae..e308b9c7b 100644 --- a/src/core/hle/kernel/thread.cpp +++ b/src/core/hle/kernel/thread.cpp | |||
| @@ -155,8 +155,10 @@ void Thread::WakeAfterDelay(s64 nanoseconds) { | |||
| 155 | if (nanoseconds == -1) | 155 | if (nanoseconds == -1) |
| 156 | return; | 156 | return; |
| 157 | 157 | ||
| 158 | CoreTiming::ScheduleEvent(CoreTiming::nsToCycles(nanoseconds), ThreadWakeupEventType, | 158 | // This function might be called from any thread so we have to be cautious and use the |
| 159 | callback_handle); | 159 | // thread-safe version of ScheduleEvent. |
| 160 | CoreTiming::ScheduleEventThreadsafe(CoreTiming::nsToCycles(nanoseconds), ThreadWakeupEventType, | ||
| 161 | callback_handle); | ||
| 160 | } | 162 | } |
| 161 | 163 | ||
| 162 | void Thread::CancelWakeupTimer() { | 164 | void Thread::CancelWakeupTimer() { |