diff options
63 files changed, 737 insertions, 568 deletions
diff --git a/src/common/scope_exit.h b/src/common/scope_exit.h index fa46cb394..35dac3a8f 100644 --- a/src/common/scope_exit.h +++ b/src/common/scope_exit.h | |||
| @@ -49,3 +49,9 @@ ScopeExitHelper<Func> ScopeExit(Func&& func) { | |||
| 49 | * \endcode | 49 | * \endcode |
| 50 | */ | 50 | */ |
| 51 | #define SCOPE_EXIT(body) auto CONCAT2(scope_exit_helper_, __LINE__) = detail::ScopeExit([&]() body) | 51 | #define SCOPE_EXIT(body) auto CONCAT2(scope_exit_helper_, __LINE__) = detail::ScopeExit([&]() body) |
| 52 | |||
| 53 | /** | ||
| 54 | * This macro is similar to SCOPE_EXIT, except the object is caller managed. This is intended to be | ||
| 55 | * used when the caller might want to cancel the ScopeExit. | ||
| 56 | */ | ||
| 57 | #define SCOPE_GUARD(body) detail::ScopeExit([&]() body) | ||
diff --git a/src/core/CMakeLists.txt b/src/core/CMakeLists.txt index 0ee02c81d..386d7bddf 100644 --- a/src/core/CMakeLists.txt +++ b/src/core/CMakeLists.txt | |||
| @@ -160,10 +160,14 @@ add_library(core STATIC | |||
| 160 | hle/kernel/k_affinity_mask.h | 160 | hle/kernel/k_affinity_mask.h |
| 161 | hle/kernel/k_condition_variable.cpp | 161 | hle/kernel/k_condition_variable.cpp |
| 162 | hle/kernel/k_condition_variable.h | 162 | hle/kernel/k_condition_variable.h |
| 163 | hle/kernel/k_event.cpp | ||
| 164 | hle/kernel/k_event.h | ||
| 163 | hle/kernel/k_light_condition_variable.h | 165 | hle/kernel/k_light_condition_variable.h |
| 164 | hle/kernel/k_light_lock.cpp | 166 | hle/kernel/k_light_lock.cpp |
| 165 | hle/kernel/k_light_lock.h | 167 | hle/kernel/k_light_lock.h |
| 166 | hle/kernel/k_priority_queue.h | 168 | hle/kernel/k_priority_queue.h |
| 169 | hle/kernel/k_readable_event.cpp | ||
| 170 | hle/kernel/k_readable_event.h | ||
| 167 | hle/kernel/k_resource_limit.cpp | 171 | hle/kernel/k_resource_limit.cpp |
| 168 | hle/kernel/k_resource_limit.h | 172 | hle/kernel/k_resource_limit.h |
| 169 | hle/kernel/k_scheduler.cpp | 173 | hle/kernel/k_scheduler.cpp |
| @@ -176,6 +180,8 @@ add_library(core STATIC | |||
| 176 | hle/kernel/k_thread.cpp | 180 | hle/kernel/k_thread.cpp |
| 177 | hle/kernel/k_thread.h | 181 | hle/kernel/k_thread.h |
| 178 | hle/kernel/k_thread_queue.h | 182 | hle/kernel/k_thread_queue.h |
| 183 | hle/kernel/k_writable_event.cpp | ||
| 184 | hle/kernel/k_writable_event.h | ||
| 179 | hle/kernel/kernel.cpp | 185 | hle/kernel/kernel.cpp |
| 180 | hle/kernel/kernel.h | 186 | hle/kernel/kernel.h |
| 181 | hle/kernel/memory/address_space_info.cpp | 187 | hle/kernel/memory/address_space_info.cpp |
| @@ -204,8 +210,6 @@ add_library(core STATIC | |||
| 204 | hle/kernel/process.h | 210 | hle/kernel/process.h |
| 205 | hle/kernel/process_capability.cpp | 211 | hle/kernel/process_capability.cpp |
| 206 | hle/kernel/process_capability.h | 212 | hle/kernel/process_capability.h |
| 207 | hle/kernel/readable_event.cpp | ||
| 208 | hle/kernel/readable_event.h | ||
| 209 | hle/kernel/server_port.cpp | 213 | hle/kernel/server_port.cpp |
| 210 | hle/kernel/server_port.h | 214 | hle/kernel/server_port.h |
| 211 | hle/kernel/server_session.cpp | 215 | hle/kernel/server_session.cpp |
| @@ -226,8 +230,6 @@ add_library(core STATIC | |||
| 226 | hle/kernel/time_manager.h | 230 | hle/kernel/time_manager.h |
| 227 | hle/kernel/transfer_memory.cpp | 231 | hle/kernel/transfer_memory.cpp |
| 228 | hle/kernel/transfer_memory.h | 232 | hle/kernel/transfer_memory.h |
| 229 | hle/kernel/writable_event.cpp | ||
| 230 | hle/kernel/writable_event.h | ||
| 231 | hle/lock.cpp | 233 | hle/lock.cpp |
| 232 | hle/lock.h | 234 | hle/lock.h |
| 233 | hle/result.h | 235 | hle/result.h |
diff --git a/src/core/hle/kernel/hle_ipc.cpp b/src/core/hle/kernel/hle_ipc.cpp index c7b10ca7a..7ec62cf18 100644 --- a/src/core/hle/kernel/hle_ipc.cpp +++ b/src/core/hle/kernel/hle_ipc.cpp | |||
| @@ -17,16 +17,16 @@ | |||
| 17 | #include "core/hle/kernel/errors.h" | 17 | #include "core/hle/kernel/errors.h" |
| 18 | #include "core/hle/kernel/handle_table.h" | 18 | #include "core/hle/kernel/handle_table.h" |
| 19 | #include "core/hle/kernel/hle_ipc.h" | 19 | #include "core/hle/kernel/hle_ipc.h" |
| 20 | #include "core/hle/kernel/k_readable_event.h" | ||
| 20 | #include "core/hle/kernel/k_scheduler.h" | 21 | #include "core/hle/kernel/k_scheduler.h" |
| 21 | #include "core/hle/kernel/k_scoped_scheduler_lock_and_sleep.h" | 22 | #include "core/hle/kernel/k_scoped_scheduler_lock_and_sleep.h" |
| 22 | #include "core/hle/kernel/k_thread.h" | 23 | #include "core/hle/kernel/k_thread.h" |
| 24 | #include "core/hle/kernel/k_writable_event.h" | ||
| 23 | #include "core/hle/kernel/kernel.h" | 25 | #include "core/hle/kernel/kernel.h" |
| 24 | #include "core/hle/kernel/object.h" | 26 | #include "core/hle/kernel/object.h" |
| 25 | #include "core/hle/kernel/process.h" | 27 | #include "core/hle/kernel/process.h" |
| 26 | #include "core/hle/kernel/readable_event.h" | ||
| 27 | #include "core/hle/kernel/server_session.h" | 28 | #include "core/hle/kernel/server_session.h" |
| 28 | #include "core/hle/kernel/time_manager.h" | 29 | #include "core/hle/kernel/time_manager.h" |
| 29 | #include "core/hle/kernel/writable_event.h" | ||
| 30 | #include "core/memory.h" | 30 | #include "core/memory.h" |
| 31 | 31 | ||
| 32 | namespace Kernel { | 32 | namespace Kernel { |
diff --git a/src/core/hle/kernel/hle_ipc.h b/src/core/hle/kernel/hle_ipc.h index 9f764c79a..9a769781b 100644 --- a/src/core/hle/kernel/hle_ipc.h +++ b/src/core/hle/kernel/hle_ipc.h | |||
| @@ -41,8 +41,8 @@ class KernelCore; | |||
| 41 | class Process; | 41 | class Process; |
| 42 | class ServerSession; | 42 | class ServerSession; |
| 43 | class KThread; | 43 | class KThread; |
| 44 | class ReadableEvent; | 44 | class KReadableEvent; |
| 45 | class WritableEvent; | 45 | class KWritableEvent; |
| 46 | 46 | ||
| 47 | enum class ThreadWakeupReason; | 47 | enum class ThreadWakeupReason; |
| 48 | 48 | ||
diff --git a/src/core/hle/kernel/k_address_arbiter.cpp b/src/core/hle/kernel/k_address_arbiter.cpp index 1685d25bb..f2f497dc4 100644 --- a/src/core/hle/kernel/k_address_arbiter.cpp +++ b/src/core/hle/kernel/k_address_arbiter.cpp | |||
| @@ -120,7 +120,10 @@ ResultCode KAddressArbiter::SignalAndIncrementIfEqual(VAddr addr, s32 value, s32 | |||
| 120 | s32 user_value{}; | 120 | s32 user_value{}; |
| 121 | R_UNLESS(UpdateIfEqual(system, std::addressof(user_value), addr, value, value + 1), | 121 | R_UNLESS(UpdateIfEqual(system, std::addressof(user_value), addr, value, value + 1), |
| 122 | Svc::ResultInvalidCurrentMemory); | 122 | Svc::ResultInvalidCurrentMemory); |
| 123 | R_UNLESS(user_value == value, Svc::ResultInvalidState); | 123 | |
| 124 | if (user_value != value) { | ||
| 125 | return Svc::ResultInvalidState; | ||
| 126 | } | ||
| 124 | 127 | ||
| 125 | auto it = thread_tree.nfind_light({addr, -1}); | 128 | auto it = thread_tree.nfind_light({addr, -1}); |
| 126 | while ((it != thread_tree.end()) && (count <= 0 || num_waiters < count) && | 129 | while ((it != thread_tree.end()) && (count <= 0 || num_waiters < count) && |
| @@ -211,7 +214,10 @@ ResultCode KAddressArbiter::SignalAndModifyByWaitingCountIfEqual(VAddr addr, s32 | |||
| 211 | } | 214 | } |
| 212 | 215 | ||
| 213 | R_UNLESS(succeeded, Svc::ResultInvalidCurrentMemory); | 216 | R_UNLESS(succeeded, Svc::ResultInvalidCurrentMemory); |
| 214 | R_UNLESS(user_value == value, Svc::ResultInvalidState); | 217 | |
| 218 | if (user_value != value) { | ||
| 219 | return Svc::ResultInvalidState; | ||
| 220 | } | ||
| 215 | 221 | ||
| 216 | while ((it != thread_tree.end()) && (count <= 0 || num_waiters < count) && | 222 | while ((it != thread_tree.end()) && (count <= 0 || num_waiters < count) && |
| 217 | (it->GetAddressArbiterKey() == addr)) { | 223 | (it->GetAddressArbiterKey() == addr)) { |
diff --git a/src/core/hle/kernel/k_event.cpp b/src/core/hle/kernel/k_event.cpp new file mode 100644 index 000000000..bb2fa4ad5 --- /dev/null +++ b/src/core/hle/kernel/k_event.cpp | |||
| @@ -0,0 +1,32 @@ | |||
| 1 | // Copyright 2021 yuzu emulator team | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #include "core/hle/kernel/k_event.h" | ||
| 6 | #include "core/hle/kernel/k_readable_event.h" | ||
| 7 | #include "core/hle/kernel/k_writable_event.h" | ||
| 8 | |||
| 9 | namespace Kernel { | ||
| 10 | |||
| 11 | KEvent::KEvent(KernelCore& kernel, std::string&& name) : Object{kernel, std::move(name)} {} | ||
| 12 | |||
| 13 | KEvent::~KEvent() = default; | ||
| 14 | |||
| 15 | std::shared_ptr<KEvent> KEvent::Create(KernelCore& kernel, std::string&& name) { | ||
| 16 | return std::make_shared<KEvent>(kernel, std::move(name)); | ||
| 17 | } | ||
| 18 | |||
| 19 | void KEvent::Initialize() { | ||
| 20 | // Create our sub events. | ||
| 21 | readable_event = std::make_shared<KReadableEvent>(kernel, GetName() + ":Readable"); | ||
| 22 | writable_event = std::make_shared<KWritableEvent>(kernel, GetName() + ":Writable"); | ||
| 23 | |||
| 24 | // Initialize our sub sessions. | ||
| 25 | readable_event->Initialize(this); | ||
| 26 | writable_event->Initialize(this); | ||
| 27 | |||
| 28 | // Mark initialized. | ||
| 29 | initialized = true; | ||
| 30 | } | ||
| 31 | |||
| 32 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/k_event.h b/src/core/hle/kernel/k_event.h new file mode 100644 index 000000000..2fb887129 --- /dev/null +++ b/src/core/hle/kernel/k_event.h | |||
| @@ -0,0 +1,57 @@ | |||
| 1 | // Copyright 2021 yuzu emulator team | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #pragma once | ||
| 6 | |||
| 7 | #include "core/hle/kernel/object.h" | ||
| 8 | |||
| 9 | namespace Kernel { | ||
| 10 | |||
| 11 | class KernelCore; | ||
| 12 | class KReadableEvent; | ||
| 13 | class KWritableEvent; | ||
| 14 | |||
| 15 | class KEvent final : public Object { | ||
| 16 | public: | ||
| 17 | explicit KEvent(KernelCore& kernel, std::string&& name); | ||
| 18 | ~KEvent() override; | ||
| 19 | |||
| 20 | static std::shared_ptr<KEvent> Create(KernelCore& kernel, std::string&& name); | ||
| 21 | |||
| 22 | void Initialize(); | ||
| 23 | |||
| 24 | void Finalize() override {} | ||
| 25 | |||
| 26 | std::string GetTypeName() const override { | ||
| 27 | return "KEvent"; | ||
| 28 | } | ||
| 29 | |||
| 30 | static constexpr HandleType HANDLE_TYPE = HandleType::Event; | ||
| 31 | HandleType GetHandleType() const override { | ||
| 32 | return HANDLE_TYPE; | ||
| 33 | } | ||
| 34 | |||
| 35 | std::shared_ptr<KReadableEvent>& GetReadableEvent() { | ||
| 36 | return readable_event; | ||
| 37 | } | ||
| 38 | |||
| 39 | std::shared_ptr<KWritableEvent>& GetWritableEvent() { | ||
| 40 | return writable_event; | ||
| 41 | } | ||
| 42 | |||
| 43 | const std::shared_ptr<KReadableEvent>& GetReadableEvent() const { | ||
| 44 | return readable_event; | ||
| 45 | } | ||
| 46 | |||
| 47 | const std::shared_ptr<KWritableEvent>& GetWritableEvent() const { | ||
| 48 | return writable_event; | ||
| 49 | } | ||
| 50 | |||
| 51 | private: | ||
| 52 | std::shared_ptr<KReadableEvent> readable_event; | ||
| 53 | std::shared_ptr<KWritableEvent> writable_event; | ||
| 54 | bool initialized{}; | ||
| 55 | }; | ||
| 56 | |||
| 57 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/k_readable_event.cpp b/src/core/hle/kernel/k_readable_event.cpp new file mode 100644 index 000000000..d8a42dbaf --- /dev/null +++ b/src/core/hle/kernel/k_readable_event.cpp | |||
| @@ -0,0 +1,57 @@ | |||
| 1 | // Copyright 2021 yuzu emulator team | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #include <algorithm> | ||
| 6 | #include "common/assert.h" | ||
| 7 | #include "common/common_funcs.h" | ||
| 8 | #include "common/logging/log.h" | ||
| 9 | #include "core/hle/kernel/errors.h" | ||
| 10 | #include "core/hle/kernel/k_readable_event.h" | ||
| 11 | #include "core/hle/kernel/k_scheduler.h" | ||
| 12 | #include "core/hle/kernel/k_thread.h" | ||
| 13 | #include "core/hle/kernel/kernel.h" | ||
| 14 | #include "core/hle/kernel/object.h" | ||
| 15 | #include "core/hle/kernel/svc_results.h" | ||
| 16 | |||
| 17 | namespace Kernel { | ||
| 18 | |||
| 19 | KReadableEvent::KReadableEvent(KernelCore& kernel, std::string&& name) | ||
| 20 | : KSynchronizationObject{kernel, std::move(name)} {} | ||
| 21 | KReadableEvent::~KReadableEvent() = default; | ||
| 22 | |||
| 23 | bool KReadableEvent::IsSignaled() const { | ||
| 24 | ASSERT(kernel.GlobalSchedulerContext().IsLocked()); | ||
| 25 | |||
| 26 | return is_signaled; | ||
| 27 | } | ||
| 28 | |||
| 29 | ResultCode KReadableEvent::Signal() { | ||
| 30 | KScopedSchedulerLock lk{kernel}; | ||
| 31 | |||
| 32 | if (!is_signaled) { | ||
| 33 | is_signaled = true; | ||
| 34 | NotifyAvailable(); | ||
| 35 | } | ||
| 36 | |||
| 37 | return RESULT_SUCCESS; | ||
| 38 | } | ||
| 39 | |||
| 40 | ResultCode KReadableEvent::Clear() { | ||
| 41 | Reset(); | ||
| 42 | |||
| 43 | return RESULT_SUCCESS; | ||
| 44 | } | ||
| 45 | |||
| 46 | ResultCode KReadableEvent::Reset() { | ||
| 47 | KScopedSchedulerLock lk{kernel}; | ||
| 48 | |||
| 49 | if (!is_signaled) { | ||
| 50 | return Svc::ResultInvalidState; | ||
| 51 | } | ||
| 52 | |||
| 53 | is_signaled = false; | ||
| 54 | return RESULT_SUCCESS; | ||
| 55 | } | ||
| 56 | |||
| 57 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/k_readable_event.h b/src/core/hle/kernel/k_readable_event.h new file mode 100644 index 000000000..e6f0fd900 --- /dev/null +++ b/src/core/hle/kernel/k_readable_event.h | |||
| @@ -0,0 +1,51 @@ | |||
| 1 | // Copyright 2021 yuzu emulator team | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #pragma once | ||
| 6 | |||
| 7 | #include "core/hle/kernel/k_synchronization_object.h" | ||
| 8 | #include "core/hle/kernel/object.h" | ||
| 9 | #include "core/hle/result.h" | ||
| 10 | |||
| 11 | namespace Kernel { | ||
| 12 | |||
| 13 | class KernelCore; | ||
| 14 | class KEvent; | ||
| 15 | |||
| 16 | class KReadableEvent final : public KSynchronizationObject { | ||
| 17 | public: | ||
| 18 | explicit KReadableEvent(KernelCore& kernel, std::string&& name); | ||
| 19 | ~KReadableEvent() override; | ||
| 20 | |||
| 21 | std::string GetTypeName() const override { | ||
| 22 | return "KReadableEvent"; | ||
| 23 | } | ||
| 24 | |||
| 25 | static constexpr HandleType HANDLE_TYPE = HandleType::ReadableEvent; | ||
| 26 | HandleType GetHandleType() const override { | ||
| 27 | return HANDLE_TYPE; | ||
| 28 | } | ||
| 29 | |||
| 30 | KEvent* GetParent() const { | ||
| 31 | return parent; | ||
| 32 | } | ||
| 33 | |||
| 34 | void Initialize(KEvent* parent_) { | ||
| 35 | is_signaled = false; | ||
| 36 | parent = parent_; | ||
| 37 | } | ||
| 38 | |||
| 39 | bool IsSignaled() const override; | ||
| 40 | void Finalize() override {} | ||
| 41 | |||
| 42 | ResultCode Signal(); | ||
| 43 | ResultCode Clear(); | ||
| 44 | ResultCode Reset(); | ||
| 45 | |||
| 46 | private: | ||
| 47 | bool is_signaled{}; | ||
| 48 | KEvent* parent{}; | ||
| 49 | }; | ||
| 50 | |||
| 51 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/k_synchronization_object.cpp b/src/core/hle/kernel/k_synchronization_object.cpp index a3b34f82f..140cc46a7 100644 --- a/src/core/hle/kernel/k_synchronization_object.cpp +++ b/src/core/hle/kernel/k_synchronization_object.cpp | |||
| @@ -132,6 +132,9 @@ ResultCode KSynchronizationObject::Wait(KernelCore& kernel, s32* out_index, | |||
| 132 | 132 | ||
| 133 | KSynchronizationObject::KSynchronizationObject(KernelCore& kernel) : Object{kernel} {} | 133 | KSynchronizationObject::KSynchronizationObject(KernelCore& kernel) : Object{kernel} {} |
| 134 | 134 | ||
| 135 | KSynchronizationObject::KSynchronizationObject(KernelCore& kernel, std::string&& name) | ||
| 136 | : Object{kernel, std::move(name)} {} | ||
| 137 | |||
| 135 | KSynchronizationObject::~KSynchronizationObject() = default; | 138 | KSynchronizationObject::~KSynchronizationObject() = default; |
| 136 | 139 | ||
| 137 | void KSynchronizationObject::NotifyAvailable(ResultCode result) { | 140 | void KSynchronizationObject::NotifyAvailable(ResultCode result) { |
diff --git a/src/core/hle/kernel/k_synchronization_object.h b/src/core/hle/kernel/k_synchronization_object.h index f65c71c28..5803718fd 100644 --- a/src/core/hle/kernel/k_synchronization_object.h +++ b/src/core/hle/kernel/k_synchronization_object.h | |||
| @@ -33,6 +33,7 @@ public: | |||
| 33 | 33 | ||
| 34 | protected: | 34 | protected: |
| 35 | explicit KSynchronizationObject(KernelCore& kernel); | 35 | explicit KSynchronizationObject(KernelCore& kernel); |
| 36 | explicit KSynchronizationObject(KernelCore& kernel, std::string&& name); | ||
| 36 | virtual ~KSynchronizationObject(); | 37 | virtual ~KSynchronizationObject(); |
| 37 | 38 | ||
| 38 | void NotifyAvailable(ResultCode result); | 39 | void NotifyAvailable(ResultCode result); |
diff --git a/src/core/hle/kernel/k_writable_event.cpp b/src/core/hle/kernel/k_writable_event.cpp new file mode 100644 index 000000000..25c52edb2 --- /dev/null +++ b/src/core/hle/kernel/k_writable_event.cpp | |||
| @@ -0,0 +1,27 @@ | |||
| 1 | // Copyright 2021 yuzu emulator team | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #include "core/hle/kernel/k_event.h" | ||
| 6 | #include "core/hle/kernel/k_readable_event.h" | ||
| 7 | #include "core/hle/kernel/k_writable_event.h" | ||
| 8 | |||
| 9 | namespace Kernel { | ||
| 10 | |||
| 11 | KWritableEvent::KWritableEvent(KernelCore& kernel, std::string&& name) | ||
| 12 | : Object{kernel, std::move(name)} {} | ||
| 13 | KWritableEvent::~KWritableEvent() = default; | ||
| 14 | |||
| 15 | void KWritableEvent::Initialize(KEvent* parent_) { | ||
| 16 | parent = parent_; | ||
| 17 | } | ||
| 18 | |||
| 19 | ResultCode KWritableEvent::Signal() { | ||
| 20 | return parent->GetReadableEvent()->Signal(); | ||
| 21 | } | ||
| 22 | |||
| 23 | ResultCode KWritableEvent::Clear() { | ||
| 24 | return parent->GetReadableEvent()->Clear(); | ||
| 25 | } | ||
| 26 | |||
| 27 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/k_writable_event.h b/src/core/hle/kernel/k_writable_event.h new file mode 100644 index 000000000..518f5448d --- /dev/null +++ b/src/core/hle/kernel/k_writable_event.h | |||
| @@ -0,0 +1,44 @@ | |||
| 1 | // Copyright 2021 yuzu Emulator Project | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #pragma once | ||
| 6 | |||
| 7 | #include "core/hle/kernel/object.h" | ||
| 8 | #include "core/hle/result.h" | ||
| 9 | |||
| 10 | namespace Kernel { | ||
| 11 | |||
| 12 | class KernelCore; | ||
| 13 | class KEvent; | ||
| 14 | |||
| 15 | class KWritableEvent final : public Object { | ||
| 16 | public: | ||
| 17 | explicit KWritableEvent(KernelCore& kernel, std::string&& name); | ||
| 18 | ~KWritableEvent() override; | ||
| 19 | |||
| 20 | std::string GetTypeName() const override { | ||
| 21 | return "KWritableEvent"; | ||
| 22 | } | ||
| 23 | |||
| 24 | static constexpr HandleType HANDLE_TYPE = HandleType::WritableEvent; | ||
| 25 | HandleType GetHandleType() const override { | ||
| 26 | return HANDLE_TYPE; | ||
| 27 | } | ||
| 28 | |||
| 29 | void Initialize(KEvent* parent_); | ||
| 30 | |||
| 31 | void Finalize() override {} | ||
| 32 | |||
| 33 | ResultCode Signal(); | ||
| 34 | ResultCode Clear(); | ||
| 35 | |||
| 36 | KEvent* GetParent() const { | ||
| 37 | return parent; | ||
| 38 | } | ||
| 39 | |||
| 40 | private: | ||
| 41 | KEvent* parent{}; | ||
| 42 | }; | ||
| 43 | |||
| 44 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/object.cpp b/src/core/hle/kernel/object.cpp index 2c571792b..d7f40c403 100644 --- a/src/core/hle/kernel/object.cpp +++ b/src/core/hle/kernel/object.cpp | |||
| @@ -8,7 +8,10 @@ | |||
| 8 | 8 | ||
| 9 | namespace Kernel { | 9 | namespace Kernel { |
| 10 | 10 | ||
| 11 | Object::Object(KernelCore& kernel) : kernel{kernel}, object_id{kernel.CreateNewObjectID()} {} | 11 | Object::Object(KernelCore& kernel_) |
| 12 | : kernel{kernel_}, object_id{kernel_.CreateNewObjectID()}, name{"[UNKNOWN KERNEL OBJECT]"} {} | ||
| 13 | Object::Object(KernelCore& kernel_, std::string&& name_) | ||
| 14 | : kernel{kernel_}, object_id{kernel_.CreateNewObjectID()}, name{std::move(name_)} {} | ||
| 12 | Object::~Object() = default; | 15 | Object::~Object() = default; |
| 13 | 16 | ||
| 14 | bool Object::IsWaitable() const { | 17 | bool Object::IsWaitable() const { |
| @@ -21,6 +24,7 @@ bool Object::IsWaitable() const { | |||
| 21 | return true; | 24 | return true; |
| 22 | 25 | ||
| 23 | case HandleType::Unknown: | 26 | case HandleType::Unknown: |
| 27 | case HandleType::Event: | ||
| 24 | case HandleType::WritableEvent: | 28 | case HandleType::WritableEvent: |
| 25 | case HandleType::SharedMemory: | 29 | case HandleType::SharedMemory: |
| 26 | case HandleType::TransferMemory: | 30 | case HandleType::TransferMemory: |
diff --git a/src/core/hle/kernel/object.h b/src/core/hle/kernel/object.h index be7fcb5fb..501e58b33 100644 --- a/src/core/hle/kernel/object.h +++ b/src/core/hle/kernel/object.h | |||
| @@ -18,6 +18,7 @@ using Handle = u32; | |||
| 18 | 18 | ||
| 19 | enum class HandleType : u32 { | 19 | enum class HandleType : u32 { |
| 20 | Unknown, | 20 | Unknown, |
| 21 | Event, | ||
| 21 | WritableEvent, | 22 | WritableEvent, |
| 22 | ReadableEvent, | 23 | ReadableEvent, |
| 23 | SharedMemory, | 24 | SharedMemory, |
| @@ -34,7 +35,8 @@ enum class HandleType : u32 { | |||
| 34 | 35 | ||
| 35 | class Object : NonCopyable, public std::enable_shared_from_this<Object> { | 36 | class Object : NonCopyable, public std::enable_shared_from_this<Object> { |
| 36 | public: | 37 | public: |
| 37 | explicit Object(KernelCore& kernel); | 38 | explicit Object(KernelCore& kernel_); |
| 39 | explicit Object(KernelCore& kernel_, std::string&& name_); | ||
| 38 | virtual ~Object(); | 40 | virtual ~Object(); |
| 39 | 41 | ||
| 40 | /// Returns a unique identifier for the object. For debugging purposes only. | 42 | /// Returns a unique identifier for the object. For debugging purposes only. |
| @@ -46,7 +48,7 @@ public: | |||
| 46 | return "[BAD KERNEL OBJECT TYPE]"; | 48 | return "[BAD KERNEL OBJECT TYPE]"; |
| 47 | } | 49 | } |
| 48 | virtual std::string GetName() const { | 50 | virtual std::string GetName() const { |
| 49 | return "[UNKNOWN KERNEL OBJECT]"; | 51 | return name; |
| 50 | } | 52 | } |
| 51 | virtual HandleType GetHandleType() const = 0; | 53 | virtual HandleType GetHandleType() const = 0; |
| 52 | 54 | ||
| @@ -69,6 +71,7 @@ protected: | |||
| 69 | 71 | ||
| 70 | private: | 72 | private: |
| 71 | std::atomic<u32> object_id{0}; | 73 | std::atomic<u32> object_id{0}; |
| 74 | std::string name; | ||
| 72 | }; | 75 | }; |
| 73 | 76 | ||
| 74 | template <typename T> | 77 | template <typename T> |
diff --git a/src/core/hle/kernel/process.cpp b/src/core/hle/kernel/process.cpp index afdb27c54..2286b292d 100644 --- a/src/core/hle/kernel/process.cpp +++ b/src/core/hle/kernel/process.cpp | |||
| @@ -23,6 +23,7 @@ | |||
| 23 | #include "core/hle/kernel/memory/page_table.h" | 23 | #include "core/hle/kernel/memory/page_table.h" |
| 24 | #include "core/hle/kernel/memory/slab_heap.h" | 24 | #include "core/hle/kernel/memory/slab_heap.h" |
| 25 | #include "core/hle/kernel/process.h" | 25 | #include "core/hle/kernel/process.h" |
| 26 | #include "core/hle/kernel/svc_results.h" | ||
| 26 | #include "core/hle/lock.h" | 27 | #include "core/hle/lock.h" |
| 27 | #include "core/memory.h" | 28 | #include "core/memory.h" |
| 28 | #include "core/settings.h" | 29 | #include "core/settings.h" |
| @@ -241,18 +242,16 @@ void Process::UnregisterThread(const KThread* thread) { | |||
| 241 | thread_list.remove(thread); | 242 | thread_list.remove(thread); |
| 242 | } | 243 | } |
| 243 | 244 | ||
| 244 | ResultCode Process::ClearSignalState() { | 245 | ResultCode Process::Reset() { |
| 245 | KScopedSchedulerLock lock(system.Kernel()); | 246 | // Lock the process and the scheduler. |
| 246 | if (status == ProcessStatus::Exited) { | 247 | KScopedLightLock lk(state_lock); |
| 247 | LOG_ERROR(Kernel, "called on a terminated process instance."); | 248 | KScopedSchedulerLock sl{kernel}; |
| 248 | return ERR_INVALID_STATE; | ||
| 249 | } | ||
| 250 | 249 | ||
| 251 | if (!is_signaled) { | 250 | // Validate that we're in a state that we can reset. |
| 252 | LOG_ERROR(Kernel, "called on a process instance that isn't signaled."); | 251 | R_UNLESS(status != ProcessStatus::Exited, Svc::ResultInvalidState); |
| 253 | return ERR_INVALID_STATE; | 252 | R_UNLESS(is_signaled, Svc::ResultInvalidState); |
| 254 | } | ||
| 255 | 253 | ||
| 254 | // Clear signaled. | ||
| 256 | is_signaled = false; | 255 | is_signaled = false; |
| 257 | return RESULT_SUCCESS; | 256 | return RESULT_SUCCESS; |
| 258 | } | 257 | } |
diff --git a/src/core/hle/kernel/process.h b/src/core/hle/kernel/process.h index c8af76ce8..320b0f347 100644 --- a/src/core/hle/kernel/process.h +++ b/src/core/hle/kernel/process.h | |||
| @@ -312,7 +312,7 @@ public: | |||
| 312 | /// @pre The process must be in a signaled state. If this is called on a | 312 | /// @pre The process must be in a signaled state. If this is called on a |
| 313 | /// process instance that is not signaled, ERR_INVALID_STATE will be | 313 | /// process instance that is not signaled, ERR_INVALID_STATE will be |
| 314 | /// returned. | 314 | /// returned. |
| 315 | ResultCode ClearSignalState(); | 315 | ResultCode Reset(); |
| 316 | 316 | ||
| 317 | /** | 317 | /** |
| 318 | * Loads process-specifics configuration info with metadata provided | 318 | * Loads process-specifics configuration info with metadata provided |
diff --git a/src/core/hle/kernel/readable_event.cpp b/src/core/hle/kernel/readable_event.cpp deleted file mode 100644 index 596d01479..000000000 --- a/src/core/hle/kernel/readable_event.cpp +++ /dev/null | |||
| @@ -1,52 +0,0 @@ | |||
| 1 | // Copyright 2014 Citra Emulator Project | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #include <algorithm> | ||
| 6 | #include "common/assert.h" | ||
| 7 | #include "common/logging/log.h" | ||
| 8 | #include "core/hle/kernel/errors.h" | ||
| 9 | #include "core/hle/kernel/k_scheduler.h" | ||
| 10 | #include "core/hle/kernel/k_thread.h" | ||
| 11 | #include "core/hle/kernel/kernel.h" | ||
| 12 | #include "core/hle/kernel/object.h" | ||
| 13 | #include "core/hle/kernel/readable_event.h" | ||
| 14 | |||
| 15 | namespace Kernel { | ||
| 16 | |||
| 17 | ReadableEvent::ReadableEvent(KernelCore& kernel) : KSynchronizationObject{kernel} {} | ||
| 18 | ReadableEvent::~ReadableEvent() = default; | ||
| 19 | |||
| 20 | void ReadableEvent::Signal() { | ||
| 21 | if (is_signaled) { | ||
| 22 | return; | ||
| 23 | } | ||
| 24 | |||
| 25 | is_signaled = true; | ||
| 26 | NotifyAvailable(); | ||
| 27 | } | ||
| 28 | |||
| 29 | bool ReadableEvent::IsSignaled() const { | ||
| 30 | ASSERT(kernel.GlobalSchedulerContext().IsLocked()); | ||
| 31 | |||
| 32 | return is_signaled; | ||
| 33 | } | ||
| 34 | |||
| 35 | void ReadableEvent::Clear() { | ||
| 36 | is_signaled = false; | ||
| 37 | } | ||
| 38 | |||
| 39 | ResultCode ReadableEvent::Reset() { | ||
| 40 | KScopedSchedulerLock lock(kernel); | ||
| 41 | if (!is_signaled) { | ||
| 42 | LOG_TRACE(Kernel, "Handle is not signaled! object_id={}, object_type={}, object_name={}", | ||
| 43 | GetObjectId(), GetTypeName(), GetName()); | ||
| 44 | return ERR_INVALID_STATE; | ||
| 45 | } | ||
| 46 | |||
| 47 | Clear(); | ||
| 48 | |||
| 49 | return RESULT_SUCCESS; | ||
| 50 | } | ||
| 51 | |||
| 52 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/readable_event.h b/src/core/hle/kernel/readable_event.h deleted file mode 100644 index 2195710c2..000000000 --- a/src/core/hle/kernel/readable_event.h +++ /dev/null | |||
| @@ -1,59 +0,0 @@ | |||
| 1 | // Copyright 2014 Citra Emulator Project | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #pragma once | ||
| 6 | |||
| 7 | #include "core/hle/kernel/k_synchronization_object.h" | ||
| 8 | #include "core/hle/kernel/object.h" | ||
| 9 | |||
| 10 | union ResultCode; | ||
| 11 | |||
| 12 | namespace Kernel { | ||
| 13 | |||
| 14 | class KernelCore; | ||
| 15 | class WritableEvent; | ||
| 16 | |||
| 17 | class ReadableEvent final : public KSynchronizationObject { | ||
| 18 | friend class WritableEvent; | ||
| 19 | |||
| 20 | public: | ||
| 21 | ~ReadableEvent() override; | ||
| 22 | |||
| 23 | std::string GetTypeName() const override { | ||
| 24 | return "ReadableEvent"; | ||
| 25 | } | ||
| 26 | std::string GetName() const override { | ||
| 27 | return name; | ||
| 28 | } | ||
| 29 | |||
| 30 | static constexpr HandleType HANDLE_TYPE = HandleType::ReadableEvent; | ||
| 31 | HandleType GetHandleType() const override { | ||
| 32 | return HANDLE_TYPE; | ||
| 33 | } | ||
| 34 | |||
| 35 | /// Unconditionally clears the readable event's state. | ||
| 36 | void Clear(); | ||
| 37 | |||
| 38 | /// Clears the readable event's state if and only if it | ||
| 39 | /// has already been signaled. | ||
| 40 | /// | ||
| 41 | /// @pre The event must be in a signaled state. If this event | ||
| 42 | /// is in an unsignaled state and this function is called, | ||
| 43 | /// then ERR_INVALID_STATE will be returned. | ||
| 44 | ResultCode Reset(); | ||
| 45 | |||
| 46 | void Signal(); | ||
| 47 | |||
| 48 | bool IsSignaled() const override; | ||
| 49 | |||
| 50 | void Finalize() override {} | ||
| 51 | |||
| 52 | private: | ||
| 53 | explicit ReadableEvent(KernelCore& kernel); | ||
| 54 | |||
| 55 | bool is_signaled{}; | ||
| 56 | std::string name; ///< Name of event (optional) | ||
| 57 | }; | ||
| 58 | |||
| 59 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/svc.cpp b/src/core/hle/kernel/svc.cpp index 74eb90100..edf208eff 100644 --- a/src/core/hle/kernel/svc.cpp +++ b/src/core/hle/kernel/svc.cpp | |||
| @@ -14,6 +14,7 @@ | |||
| 14 | #include "common/fiber.h" | 14 | #include "common/fiber.h" |
| 15 | #include "common/logging/log.h" | 15 | #include "common/logging/log.h" |
| 16 | #include "common/microprofile.h" | 16 | #include "common/microprofile.h" |
| 17 | #include "common/scope_exit.h" | ||
| 17 | #include "common/string_util.h" | 18 | #include "common/string_util.h" |
| 18 | #include "core/arm/exclusive_monitor.h" | 19 | #include "core/arm/exclusive_monitor.h" |
| 19 | #include "core/core.h" | 20 | #include "core/core.h" |
| @@ -26,18 +27,20 @@ | |||
| 26 | #include "core/hle/kernel/handle_table.h" | 27 | #include "core/hle/kernel/handle_table.h" |
| 27 | #include "core/hle/kernel/k_address_arbiter.h" | 28 | #include "core/hle/kernel/k_address_arbiter.h" |
| 28 | #include "core/hle/kernel/k_condition_variable.h" | 29 | #include "core/hle/kernel/k_condition_variable.h" |
| 30 | #include "core/hle/kernel/k_event.h" | ||
| 31 | #include "core/hle/kernel/k_readable_event.h" | ||
| 29 | #include "core/hle/kernel/k_resource_limit.h" | 32 | #include "core/hle/kernel/k_resource_limit.h" |
| 30 | #include "core/hle/kernel/k_scheduler.h" | 33 | #include "core/hle/kernel/k_scheduler.h" |
| 31 | #include "core/hle/kernel/k_scoped_scheduler_lock_and_sleep.h" | 34 | #include "core/hle/kernel/k_scoped_scheduler_lock_and_sleep.h" |
| 32 | #include "core/hle/kernel/k_synchronization_object.h" | 35 | #include "core/hle/kernel/k_synchronization_object.h" |
| 33 | #include "core/hle/kernel/k_thread.h" | 36 | #include "core/hle/kernel/k_thread.h" |
| 37 | #include "core/hle/kernel/k_writable_event.h" | ||
| 34 | #include "core/hle/kernel/kernel.h" | 38 | #include "core/hle/kernel/kernel.h" |
| 35 | #include "core/hle/kernel/memory/memory_block.h" | 39 | #include "core/hle/kernel/memory/memory_block.h" |
| 36 | #include "core/hle/kernel/memory/memory_layout.h" | 40 | #include "core/hle/kernel/memory/memory_layout.h" |
| 37 | #include "core/hle/kernel/memory/page_table.h" | 41 | #include "core/hle/kernel/memory/page_table.h" |
| 38 | #include "core/hle/kernel/physical_core.h" | 42 | #include "core/hle/kernel/physical_core.h" |
| 39 | #include "core/hle/kernel/process.h" | 43 | #include "core/hle/kernel/process.h" |
| 40 | #include "core/hle/kernel/readable_event.h" | ||
| 41 | #include "core/hle/kernel/shared_memory.h" | 44 | #include "core/hle/kernel/shared_memory.h" |
| 42 | #include "core/hle/kernel/svc.h" | 45 | #include "core/hle/kernel/svc.h" |
| 43 | #include "core/hle/kernel/svc_results.h" | 46 | #include "core/hle/kernel/svc_results.h" |
| @@ -45,7 +48,6 @@ | |||
| 45 | #include "core/hle/kernel/svc_wrap.h" | 48 | #include "core/hle/kernel/svc_wrap.h" |
| 46 | #include "core/hle/kernel/time_manager.h" | 49 | #include "core/hle/kernel/time_manager.h" |
| 47 | #include "core/hle/kernel/transfer_memory.h" | 50 | #include "core/hle/kernel/transfer_memory.h" |
| 48 | #include "core/hle/kernel/writable_event.h" | ||
| 49 | #include "core/hle/lock.h" | 51 | #include "core/hle/lock.h" |
| 50 | #include "core/hle/result.h" | 52 | #include "core/hle/result.h" |
| 51 | #include "core/hle/service/service.h" | 53 | #include "core/hle/service/service.h" |
| @@ -1725,20 +1727,28 @@ static ResultCode CloseHandle32(Core::System& system, Handle handle) { | |||
| 1725 | static ResultCode ResetSignal(Core::System& system, Handle handle) { | 1727 | static ResultCode ResetSignal(Core::System& system, Handle handle) { |
| 1726 | LOG_DEBUG(Kernel_SVC, "called handle 0x{:08X}", handle); | 1728 | LOG_DEBUG(Kernel_SVC, "called handle 0x{:08X}", handle); |
| 1727 | 1729 | ||
| 1730 | // Get the current handle table. | ||
| 1728 | const auto& handle_table = system.Kernel().CurrentProcess()->GetHandleTable(); | 1731 | const auto& handle_table = system.Kernel().CurrentProcess()->GetHandleTable(); |
| 1729 | 1732 | ||
| 1730 | auto event = handle_table.Get<ReadableEvent>(handle); | 1733 | // Try to reset as readable event. |
| 1731 | if (event) { | 1734 | { |
| 1732 | return event->Reset(); | 1735 | auto readable_event = handle_table.Get<KReadableEvent>(handle); |
| 1736 | if (readable_event) { | ||
| 1737 | return readable_event->Reset(); | ||
| 1738 | } | ||
| 1733 | } | 1739 | } |
| 1734 | 1740 | ||
| 1735 | auto process = handle_table.Get<Process>(handle); | 1741 | // Try to reset as process. |
| 1736 | if (process) { | 1742 | { |
| 1737 | return process->ClearSignalState(); | 1743 | auto process = handle_table.Get<Process>(handle); |
| 1744 | if (process) { | ||
| 1745 | return process->Reset(); | ||
| 1746 | } | ||
| 1738 | } | 1747 | } |
| 1739 | 1748 | ||
| 1740 | LOG_ERROR(Kernel_SVC, "Invalid handle (0x{:08X})", handle); | 1749 | LOG_ERROR(Kernel_SVC, "invalid handle (0x{:08X})", handle); |
| 1741 | return ERR_INVALID_HANDLE; | 1750 | |
| 1751 | return Svc::ResultInvalidHandle; | ||
| 1742 | } | 1752 | } |
| 1743 | 1753 | ||
| 1744 | static ResultCode ResetSignal32(Core::System& system, Handle handle) { | 1754 | static ResultCode ResetSignal32(Core::System& system, Handle handle) { |
| @@ -1866,80 +1876,92 @@ static ResultCode SetThreadCoreMask32(Core::System& system, Handle thread_handle | |||
| 1866 | return SetThreadCoreMask(system, thread_handle, core_id, affinity_mask); | 1876 | return SetThreadCoreMask(system, thread_handle, core_id, affinity_mask); |
| 1867 | } | 1877 | } |
| 1868 | 1878 | ||
| 1869 | static ResultCode CreateEvent(Core::System& system, Handle* write_handle, Handle* read_handle) { | 1879 | static ResultCode SignalEvent(Core::System& system, Handle event_handle) { |
| 1870 | LOG_DEBUG(Kernel_SVC, "called"); | 1880 | LOG_DEBUG(Kernel_SVC, "called, event_handle=0x{:08X}", event_handle); |
| 1871 | 1881 | ||
| 1872 | auto& kernel = system.Kernel(); | 1882 | // Get the current handle table. |
| 1873 | const auto [readable_event, writable_event] = | 1883 | const HandleTable& handle_table = system.Kernel().CurrentProcess()->GetHandleTable(); |
| 1874 | WritableEvent::CreateEventPair(kernel, "CreateEvent"); | ||
| 1875 | 1884 | ||
| 1876 | HandleTable& handle_table = kernel.CurrentProcess()->GetHandleTable(); | 1885 | // Get the writable event. |
| 1886 | auto writable_event = handle_table.Get<KWritableEvent>(event_handle); | ||
| 1887 | R_UNLESS(writable_event, Svc::ResultInvalidHandle); | ||
| 1877 | 1888 | ||
| 1878 | const auto write_create_result = handle_table.Create(writable_event); | 1889 | return writable_event->Signal(); |
| 1879 | if (write_create_result.Failed()) { | ||
| 1880 | return write_create_result.Code(); | ||
| 1881 | } | ||
| 1882 | *write_handle = *write_create_result; | ||
| 1883 | |||
| 1884 | const auto read_create_result = handle_table.Create(readable_event); | ||
| 1885 | if (read_create_result.Failed()) { | ||
| 1886 | handle_table.Close(*write_create_result); | ||
| 1887 | return read_create_result.Code(); | ||
| 1888 | } | ||
| 1889 | *read_handle = *read_create_result; | ||
| 1890 | |||
| 1891 | LOG_DEBUG(Kernel_SVC, | ||
| 1892 | "successful. Writable event handle=0x{:08X}, Readable event handle=0x{:08X}", | ||
| 1893 | *write_create_result, *read_create_result); | ||
| 1894 | return RESULT_SUCCESS; | ||
| 1895 | } | 1890 | } |
| 1896 | 1891 | ||
| 1897 | static ResultCode CreateEvent32(Core::System& system, Handle* write_handle, Handle* read_handle) { | 1892 | static ResultCode SignalEvent32(Core::System& system, Handle event_handle) { |
| 1898 | return CreateEvent(system, write_handle, read_handle); | 1893 | return SignalEvent(system, event_handle); |
| 1899 | } | 1894 | } |
| 1900 | 1895 | ||
| 1901 | static ResultCode ClearEvent(Core::System& system, Handle handle) { | 1896 | static ResultCode ClearEvent(Core::System& system, Handle event_handle) { |
| 1902 | LOG_TRACE(Kernel_SVC, "called, event=0x{:08X}", handle); | 1897 | LOG_TRACE(Kernel_SVC, "called, event_handle=0x{:08X}", event_handle); |
| 1903 | 1898 | ||
| 1899 | // Get the current handle table. | ||
| 1904 | const auto& handle_table = system.Kernel().CurrentProcess()->GetHandleTable(); | 1900 | const auto& handle_table = system.Kernel().CurrentProcess()->GetHandleTable(); |
| 1905 | 1901 | ||
| 1906 | auto writable_event = handle_table.Get<WritableEvent>(handle); | 1902 | // Try to clear the writable event. |
| 1907 | if (writable_event) { | 1903 | { |
| 1908 | writable_event->Clear(); | 1904 | auto writable_event = handle_table.Get<KWritableEvent>(event_handle); |
| 1909 | return RESULT_SUCCESS; | 1905 | if (writable_event) { |
| 1906 | return writable_event->Clear(); | ||
| 1907 | } | ||
| 1910 | } | 1908 | } |
| 1911 | 1909 | ||
| 1912 | auto readable_event = handle_table.Get<ReadableEvent>(handle); | 1910 | // Try to clear the readable event. |
| 1913 | if (readable_event) { | 1911 | { |
| 1914 | readable_event->Clear(); | 1912 | auto readable_event = handle_table.Get<KReadableEvent>(event_handle); |
| 1915 | return RESULT_SUCCESS; | 1913 | if (readable_event) { |
| 1914 | return readable_event->Clear(); | ||
| 1915 | } | ||
| 1916 | } | 1916 | } |
| 1917 | 1917 | ||
| 1918 | LOG_ERROR(Kernel_SVC, "Event handle does not exist, handle=0x{:08X}", handle); | 1918 | LOG_ERROR(Kernel_SVC, "Event handle does not exist, event_handle=0x{:08X}", event_handle); |
| 1919 | return ERR_INVALID_HANDLE; | 1919 | |
| 1920 | return Svc::ResultInvalidHandle; | ||
| 1920 | } | 1921 | } |
| 1921 | 1922 | ||
| 1922 | static ResultCode ClearEvent32(Core::System& system, Handle handle) { | 1923 | static ResultCode ClearEvent32(Core::System& system, Handle event_handle) { |
| 1923 | return ClearEvent(system, handle); | 1924 | return ClearEvent(system, event_handle); |
| 1924 | } | 1925 | } |
| 1925 | 1926 | ||
| 1926 | static ResultCode SignalEvent(Core::System& system, Handle handle) { | 1927 | static ResultCode CreateEvent(Core::System& system, Handle* out_write, Handle* out_read) { |
| 1927 | LOG_DEBUG(Kernel_SVC, "called. Handle=0x{:08X}", handle); | 1928 | LOG_DEBUG(Kernel_SVC, "called"); |
| 1929 | |||
| 1930 | // Get the kernel reference and handle table. | ||
| 1931 | auto& kernel = system.Kernel(); | ||
| 1932 | HandleTable& handle_table = kernel.CurrentProcess()->GetHandleTable(); | ||
| 1933 | |||
| 1934 | // Create a new event. | ||
| 1935 | const auto event = KEvent::Create(kernel, "CreateEvent"); | ||
| 1936 | R_UNLESS(event != nullptr, Svc::ResultOutOfResource); | ||
| 1928 | 1937 | ||
| 1929 | HandleTable& handle_table = system.Kernel().CurrentProcess()->GetHandleTable(); | 1938 | // Initialize the event. |
| 1930 | auto writable_event = handle_table.Get<WritableEvent>(handle); | 1939 | event->Initialize(); |
| 1931 | 1940 | ||
| 1932 | if (!writable_event) { | 1941 | // Add the writable event to the handle table. |
| 1933 | LOG_ERROR(Kernel_SVC, "Non-existent writable event handle used (0x{:08X})", handle); | 1942 | const auto write_create_result = handle_table.Create(event->GetWritableEvent()); |
| 1934 | return ERR_INVALID_HANDLE; | 1943 | if (write_create_result.Failed()) { |
| 1944 | return write_create_result.Code(); | ||
| 1945 | } | ||
| 1946 | *out_write = *write_create_result; | ||
| 1947 | |||
| 1948 | // Add the writable event to the handle table. | ||
| 1949 | auto handle_guard = SCOPE_GUARD({ handle_table.Close(*write_create_result); }); | ||
| 1950 | |||
| 1951 | // Add the readable event to the handle table. | ||
| 1952 | const auto read_create_result = handle_table.Create(event->GetReadableEvent()); | ||
| 1953 | if (read_create_result.Failed()) { | ||
| 1954 | return read_create_result.Code(); | ||
| 1935 | } | 1955 | } |
| 1956 | *out_read = *read_create_result; | ||
| 1936 | 1957 | ||
| 1937 | writable_event->Signal(); | 1958 | // We succeeded. |
| 1959 | handle_guard.Cancel(); | ||
| 1938 | return RESULT_SUCCESS; | 1960 | return RESULT_SUCCESS; |
| 1939 | } | 1961 | } |
| 1940 | 1962 | ||
| 1941 | static ResultCode SignalEvent32(Core::System& system, Handle handle) { | 1963 | static ResultCode CreateEvent32(Core::System& system, Handle* out_write, Handle* out_read) { |
| 1942 | return SignalEvent(system, handle); | 1964 | return CreateEvent(system, out_write, out_read); |
| 1943 | } | 1965 | } |
| 1944 | 1966 | ||
| 1945 | static ResultCode GetProcessInfo(Core::System& system, u64* out, Handle process_handle, u32 type) { | 1967 | static ResultCode GetProcessInfo(Core::System& system, u64* out, Handle process_handle, u32 type) { |
diff --git a/src/core/hle/kernel/svc_results.h b/src/core/hle/kernel/svc_results.h index 7b897fbce..204cd989d 100644 --- a/src/core/hle/kernel/svc_results.h +++ b/src/core/hle/kernel/svc_results.h | |||
| @@ -11,6 +11,7 @@ namespace Kernel::Svc { | |||
| 11 | constexpr ResultCode ResultNoSynchronizationObject{ErrorModule::Kernel, 57}; | 11 | constexpr ResultCode ResultNoSynchronizationObject{ErrorModule::Kernel, 57}; |
| 12 | constexpr ResultCode ResultTerminationRequested{ErrorModule::Kernel, 59}; | 12 | constexpr ResultCode ResultTerminationRequested{ErrorModule::Kernel, 59}; |
| 13 | constexpr ResultCode ResultInvalidAddress{ErrorModule::Kernel, 102}; | 13 | constexpr ResultCode ResultInvalidAddress{ErrorModule::Kernel, 102}; |
| 14 | constexpr ResultCode ResultOutOfResource{ErrorModule::Kernel, 103}; | ||
| 14 | constexpr ResultCode ResultInvalidCurrentMemory{ErrorModule::Kernel, 106}; | 15 | constexpr ResultCode ResultInvalidCurrentMemory{ErrorModule::Kernel, 106}; |
| 15 | constexpr ResultCode ResultInvalidPriority{ErrorModule::Kernel, 112}; | 16 | constexpr ResultCode ResultInvalidPriority{ErrorModule::Kernel, 112}; |
| 16 | constexpr ResultCode ResultInvalidCoreId{ErrorModule::Kernel, 113}; | 17 | constexpr ResultCode ResultInvalidCoreId{ErrorModule::Kernel, 113}; |
diff --git a/src/core/hle/kernel/writable_event.cpp b/src/core/hle/kernel/writable_event.cpp deleted file mode 100644 index 142212ee4..000000000 --- a/src/core/hle/kernel/writable_event.cpp +++ /dev/null | |||
| @@ -1,41 +0,0 @@ | |||
| 1 | // Copyright 2014 Citra Emulator Project | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #include <algorithm> | ||
| 6 | #include "common/assert.h" | ||
| 7 | #include "core/hle/kernel/k_thread.h" | ||
| 8 | #include "core/hle/kernel/kernel.h" | ||
| 9 | #include "core/hle/kernel/object.h" | ||
| 10 | #include "core/hle/kernel/readable_event.h" | ||
| 11 | #include "core/hle/kernel/writable_event.h" | ||
| 12 | |||
| 13 | namespace Kernel { | ||
| 14 | |||
| 15 | WritableEvent::WritableEvent(KernelCore& kernel) : Object{kernel} {} | ||
| 16 | WritableEvent::~WritableEvent() = default; | ||
| 17 | |||
| 18 | EventPair WritableEvent::CreateEventPair(KernelCore& kernel, std::string name) { | ||
| 19 | std::shared_ptr<WritableEvent> writable_event(new WritableEvent(kernel)); | ||
| 20 | std::shared_ptr<ReadableEvent> readable_event(new ReadableEvent(kernel)); | ||
| 21 | |||
| 22 | writable_event->name = name + ":Writable"; | ||
| 23 | writable_event->readable = readable_event; | ||
| 24 | readable_event->name = name + ":Readable"; | ||
| 25 | |||
| 26 | return {std::move(readable_event), std::move(writable_event)}; | ||
| 27 | } | ||
| 28 | |||
| 29 | std::shared_ptr<ReadableEvent> WritableEvent::GetReadableEvent() const { | ||
| 30 | return readable; | ||
| 31 | } | ||
| 32 | |||
| 33 | void WritableEvent::Signal() { | ||
| 34 | readable->Signal(); | ||
| 35 | } | ||
| 36 | |||
| 37 | void WritableEvent::Clear() { | ||
| 38 | readable->Clear(); | ||
| 39 | } | ||
| 40 | |||
| 41 | } // namespace Kernel | ||
diff --git a/src/core/hle/kernel/writable_event.h b/src/core/hle/kernel/writable_event.h deleted file mode 100644 index 467eb2c21..000000000 --- a/src/core/hle/kernel/writable_event.h +++ /dev/null | |||
| @@ -1,60 +0,0 @@ | |||
| 1 | // Copyright 2014 Citra Emulator Project | ||
| 2 | // Licensed under GPLv2 or any later version | ||
| 3 | // Refer to the license.txt file included. | ||
| 4 | |||
| 5 | #pragma once | ||
| 6 | |||
| 7 | #include <memory> | ||
| 8 | |||
| 9 | #include "core/hle/kernel/object.h" | ||
| 10 | |||
| 11 | namespace Kernel { | ||
| 12 | |||
| 13 | class KernelCore; | ||
| 14 | class ReadableEvent; | ||
| 15 | class WritableEvent; | ||
| 16 | |||
| 17 | struct EventPair { | ||
| 18 | std::shared_ptr<ReadableEvent> readable; | ||
| 19 | std::shared_ptr<WritableEvent> writable; | ||
| 20 | }; | ||
| 21 | |||
| 22 | class WritableEvent final : public Object { | ||
| 23 | public: | ||
| 24 | ~WritableEvent() override; | ||
| 25 | |||
| 26 | /** | ||
| 27 | * Creates an event | ||
| 28 | * @param kernel The kernel instance to create this event under. | ||
| 29 | * @param name Optional name of event | ||
| 30 | */ | ||
| 31 | static EventPair CreateEventPair(KernelCore& kernel, std::string name = "Unknown"); | ||
| 32 | |||
| 33 | std::string GetTypeName() const override { | ||
| 34 | return "WritableEvent"; | ||
| 35 | } | ||
| 36 | std::string GetName() const override { | ||
| 37 | return name; | ||
| 38 | } | ||
| 39 | |||
| 40 | static constexpr HandleType HANDLE_TYPE = HandleType::WritableEvent; | ||
| 41 | HandleType GetHandleType() const override { | ||
| 42 | return HANDLE_TYPE; | ||
| 43 | } | ||
| 44 | |||
| 45 | std::shared_ptr<ReadableEvent> GetReadableEvent() const; | ||
| 46 | |||
| 47 | void Signal(); | ||
| 48 | void Clear(); | ||
| 49 | |||
| 50 | void Finalize() override {} | ||
| 51 | |||
| 52 | private: | ||
| 53 | explicit WritableEvent(KernelCore& kernel); | ||
| 54 | |||
| 55 | std::shared_ptr<ReadableEvent> readable; | ||
| 56 | |||
| 57 | std::string name; ///< Name of event (optional) | ||
| 58 | }; | ||
| 59 | |||
| 60 | } // namespace Kernel | ||
diff --git a/src/core/hle/service/am/am.cpp b/src/core/hle/service/am/am.cpp index 07a755599..bb77c2569 100644 --- a/src/core/hle/service/am/am.cpp +++ b/src/core/hle/service/am/am.cpp | |||
| @@ -13,11 +13,12 @@ | |||
| 13 | #include "core/file_sys/registered_cache.h" | 13 | #include "core/file_sys/registered_cache.h" |
| 14 | #include "core/file_sys/savedata_factory.h" | 14 | #include "core/file_sys/savedata_factory.h" |
| 15 | #include "core/hle/ipc_helpers.h" | 15 | #include "core/hle/ipc_helpers.h" |
| 16 | #include "core/hle/kernel/k_event.h" | ||
| 17 | #include "core/hle/kernel/k_readable_event.h" | ||
| 18 | #include "core/hle/kernel/k_writable_event.h" | ||
| 16 | #include "core/hle/kernel/kernel.h" | 19 | #include "core/hle/kernel/kernel.h" |
| 17 | #include "core/hle/kernel/process.h" | 20 | #include "core/hle/kernel/process.h" |
| 18 | #include "core/hle/kernel/readable_event.h" | ||
| 19 | #include "core/hle/kernel/transfer_memory.h" | 21 | #include "core/hle/kernel/transfer_memory.h" |
| 20 | #include "core/hle/kernel/writable_event.h" | ||
| 21 | #include "core/hle/service/acc/profile_manager.h" | 22 | #include "core/hle/service/acc/profile_manager.h" |
| 22 | #include "core/hle/service/am/am.h" | 23 | #include "core/hle/service/am/am.h" |
| 23 | #include "core/hle/service/am/applet_ae.h" | 24 | #include "core/hle/service/am/applet_ae.h" |
| @@ -303,17 +304,18 @@ ISelfController::ISelfController(Core::System& system_, NVFlinger::NVFlinger& nv | |||
| 303 | RegisterHandlers(functions); | 304 | RegisterHandlers(functions); |
| 304 | 305 | ||
| 305 | auto& kernel = system.Kernel(); | 306 | auto& kernel = system.Kernel(); |
| 306 | launchable_event = | 307 | launchable_event = Kernel::KEvent::Create(kernel, "ISelfController:LaunchableEvent"); |
| 307 | Kernel::WritableEvent::CreateEventPair(kernel, "ISelfController:LaunchableEvent"); | 308 | launchable_event->Initialize(); |
| 308 | 309 | ||
| 309 | // This event is created by AM on the first time GetAccumulatedSuspendedTickChangedEvent() is | 310 | // This event is created by AM on the first time GetAccumulatedSuspendedTickChangedEvent() is |
| 310 | // called. Yuzu can just create it unconditionally, since it doesn't need to support multiple | 311 | // called. Yuzu can just create it unconditionally, since it doesn't need to support multiple |
| 311 | // ISelfControllers. The event is signaled on creation, and on transition from suspended -> not | 312 | // ISelfControllers. The event is signaled on creation, and on transition from suspended -> not |
| 312 | // suspended if the event has previously been created by a call to | 313 | // suspended if the event has previously been created by a call to |
| 313 | // GetAccumulatedSuspendedTickChangedEvent. | 314 | // GetAccumulatedSuspendedTickChangedEvent. |
| 314 | accumulated_suspended_tick_changed_event = Kernel::WritableEvent::CreateEventPair( | 315 | accumulated_suspended_tick_changed_event = |
| 315 | kernel, "ISelfController:AccumulatedSuspendedTickChangedEvent"); | 316 | Kernel::KEvent::Create(kernel, "ISelfController:AccumulatedSuspendedTickChangedEvent"); |
| 316 | accumulated_suspended_tick_changed_event.writable->Signal(); | 317 | accumulated_suspended_tick_changed_event->Initialize(); |
| 318 | accumulated_suspended_tick_changed_event->GetWritableEvent()->Signal(); | ||
| 317 | } | 319 | } |
| 318 | 320 | ||
| 319 | ISelfController::~ISelfController() = default; | 321 | ISelfController::~ISelfController() = default; |
| @@ -372,11 +374,11 @@ void ISelfController::LeaveFatalSection(Kernel::HLERequestContext& ctx) { | |||
| 372 | void ISelfController::GetLibraryAppletLaunchableEvent(Kernel::HLERequestContext& ctx) { | 374 | void ISelfController::GetLibraryAppletLaunchableEvent(Kernel::HLERequestContext& ctx) { |
| 373 | LOG_WARNING(Service_AM, "(STUBBED) called"); | 375 | LOG_WARNING(Service_AM, "(STUBBED) called"); |
| 374 | 376 | ||
| 375 | launchable_event.writable->Signal(); | 377 | launchable_event->GetWritableEvent()->Signal(); |
| 376 | 378 | ||
| 377 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 379 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 378 | rb.Push(RESULT_SUCCESS); | 380 | rb.Push(RESULT_SUCCESS); |
| 379 | rb.PushCopyObjects(launchable_event.readable); | 381 | rb.PushCopyObjects(launchable_event->GetReadableEvent()); |
| 380 | } | 382 | } |
| 381 | 383 | ||
| 382 | void ISelfController::SetScreenShotPermission(Kernel::HLERequestContext& ctx) { | 384 | void ISelfController::SetScreenShotPermission(Kernel::HLERequestContext& ctx) { |
| @@ -555,41 +557,42 @@ void ISelfController::GetAccumulatedSuspendedTickChangedEvent(Kernel::HLERequest | |||
| 555 | 557 | ||
| 556 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 558 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 557 | rb.Push(RESULT_SUCCESS); | 559 | rb.Push(RESULT_SUCCESS); |
| 558 | rb.PushCopyObjects(accumulated_suspended_tick_changed_event.readable); | 560 | rb.PushCopyObjects(accumulated_suspended_tick_changed_event->GetReadableEvent()); |
| 559 | } | 561 | } |
| 560 | 562 | ||
| 561 | AppletMessageQueue::AppletMessageQueue(Kernel::KernelCore& kernel) { | 563 | AppletMessageQueue::AppletMessageQueue(Kernel::KernelCore& kernel) { |
| 562 | on_new_message = | 564 | on_new_message = Kernel::KEvent::Create(kernel, "AMMessageQueue:OnMessageReceived"); |
| 563 | Kernel::WritableEvent::CreateEventPair(kernel, "AMMessageQueue:OnMessageReceived"); | 565 | on_new_message->Initialize(); |
| 564 | on_operation_mode_changed = | 566 | on_operation_mode_changed = |
| 565 | Kernel::WritableEvent::CreateEventPair(kernel, "AMMessageQueue:OperationModeChanged"); | 567 | Kernel::KEvent::Create(kernel, "AMMessageQueue:OperationModeChanged"); |
| 568 | on_operation_mode_changed->Initialize(); | ||
| 566 | } | 569 | } |
| 567 | 570 | ||
| 568 | AppletMessageQueue::~AppletMessageQueue() = default; | 571 | AppletMessageQueue::~AppletMessageQueue() = default; |
| 569 | 572 | ||
| 570 | const std::shared_ptr<Kernel::ReadableEvent>& AppletMessageQueue::GetMessageReceiveEvent() const { | 573 | const std::shared_ptr<Kernel::KReadableEvent>& AppletMessageQueue::GetMessageReceiveEvent() const { |
| 571 | return on_new_message.readable; | 574 | return on_new_message->GetReadableEvent(); |
| 572 | } | 575 | } |
| 573 | 576 | ||
| 574 | const std::shared_ptr<Kernel::ReadableEvent>& AppletMessageQueue::GetOperationModeChangedEvent() | 577 | const std::shared_ptr<Kernel::KReadableEvent>& AppletMessageQueue::GetOperationModeChangedEvent() |
| 575 | const { | 578 | const { |
| 576 | return on_operation_mode_changed.readable; | 579 | return on_operation_mode_changed->GetReadableEvent(); |
| 577 | } | 580 | } |
| 578 | 581 | ||
| 579 | void AppletMessageQueue::PushMessage(AppletMessage msg) { | 582 | void AppletMessageQueue::PushMessage(AppletMessage msg) { |
| 580 | messages.push(msg); | 583 | messages.push(msg); |
| 581 | on_new_message.writable->Signal(); | 584 | on_new_message->GetWritableEvent()->Signal(); |
| 582 | } | 585 | } |
| 583 | 586 | ||
| 584 | AppletMessageQueue::AppletMessage AppletMessageQueue::PopMessage() { | 587 | AppletMessageQueue::AppletMessage AppletMessageQueue::PopMessage() { |
| 585 | if (messages.empty()) { | 588 | if (messages.empty()) { |
| 586 | on_new_message.writable->Clear(); | 589 | on_new_message->GetWritableEvent()->Clear(); |
| 587 | return AppletMessage::NoMessage; | 590 | return AppletMessage::NoMessage; |
| 588 | } | 591 | } |
| 589 | auto msg = messages.front(); | 592 | auto msg = messages.front(); |
| 590 | messages.pop(); | 593 | messages.pop(); |
| 591 | if (messages.empty()) { | 594 | if (messages.empty()) { |
| 592 | on_new_message.writable->Clear(); | 595 | on_new_message->GetWritableEvent()->Clear(); |
| 593 | } | 596 | } |
| 594 | return msg; | 597 | return msg; |
| 595 | } | 598 | } |
| @@ -601,7 +604,7 @@ std::size_t AppletMessageQueue::GetMessageCount() const { | |||
| 601 | void AppletMessageQueue::OperationModeChanged() { | 604 | void AppletMessageQueue::OperationModeChanged() { |
| 602 | PushMessage(AppletMessage::OperationModeChanged); | 605 | PushMessage(AppletMessage::OperationModeChanged); |
| 603 | PushMessage(AppletMessage::PerformanceModeChanged); | 606 | PushMessage(AppletMessage::PerformanceModeChanged); |
| 604 | on_operation_mode_changed.writable->Signal(); | 607 | on_operation_mode_changed->GetWritableEvent()->Signal(); |
| 605 | } | 608 | } |
| 606 | 609 | ||
| 607 | void AppletMessageQueue::RequestExit() { | 610 | void AppletMessageQueue::RequestExit() { |
| @@ -1229,14 +1232,15 @@ IApplicationFunctions::IApplicationFunctions(Core::System& system_) | |||
| 1229 | RegisterHandlers(functions); | 1232 | RegisterHandlers(functions); |
| 1230 | 1233 | ||
| 1231 | auto& kernel = system.Kernel(); | 1234 | auto& kernel = system.Kernel(); |
| 1232 | gpu_error_detected_event = Kernel::WritableEvent::CreateEventPair( | 1235 | gpu_error_detected_event = |
| 1233 | kernel, "IApplicationFunctions:GpuErrorDetectedSystemEvent"); | 1236 | Kernel::KEvent::Create(kernel, "IApplicationFunctions:GpuErrorDetectedSystemEvent"); |
| 1234 | 1237 | gpu_error_detected_event->Initialize(); | |
| 1235 | friend_invitation_storage_channel_event = Kernel::WritableEvent::CreateEventPair( | 1238 | friend_invitation_storage_channel_event = |
| 1236 | kernel, "IApplicationFunctions:FriendInvitationStorageChannelEvent"); | 1239 | Kernel::KEvent::Create(kernel, "IApplicationFunctions:FriendInvitationStorageChannelEvent"); |
| 1237 | 1240 | friend_invitation_storage_channel_event->Initialize(); | |
| 1238 | health_warning_disappeared_system_event = Kernel::WritableEvent::CreateEventPair( | 1241 | health_warning_disappeared_system_event = |
| 1239 | kernel, "IApplicationFunctions:HealthWarningDisappearedSystemEvent"); | 1242 | Kernel::KEvent::Create(kernel, "IApplicationFunctions:HealthWarningDisappearedSystemEvent"); |
| 1243 | health_warning_disappeared_system_event->Initialize(); | ||
| 1240 | } | 1244 | } |
| 1241 | 1245 | ||
| 1242 | IApplicationFunctions::~IApplicationFunctions() = default; | 1246 | IApplicationFunctions::~IApplicationFunctions() = default; |
| @@ -1633,7 +1637,7 @@ void IApplicationFunctions::GetGpuErrorDetectedSystemEvent(Kernel::HLERequestCon | |||
| 1633 | 1637 | ||
| 1634 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 1638 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 1635 | rb.Push(RESULT_SUCCESS); | 1639 | rb.Push(RESULT_SUCCESS); |
| 1636 | rb.PushCopyObjects(gpu_error_detected_event.readable); | 1640 | rb.PushCopyObjects(gpu_error_detected_event->GetReadableEvent()); |
| 1637 | } | 1641 | } |
| 1638 | 1642 | ||
| 1639 | void IApplicationFunctions::GetFriendInvitationStorageChannelEvent(Kernel::HLERequestContext& ctx) { | 1643 | void IApplicationFunctions::GetFriendInvitationStorageChannelEvent(Kernel::HLERequestContext& ctx) { |
| @@ -1641,7 +1645,7 @@ void IApplicationFunctions::GetFriendInvitationStorageChannelEvent(Kernel::HLERe | |||
| 1641 | 1645 | ||
| 1642 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 1646 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 1643 | rb.Push(RESULT_SUCCESS); | 1647 | rb.Push(RESULT_SUCCESS); |
| 1644 | rb.PushCopyObjects(friend_invitation_storage_channel_event.readable); | 1648 | rb.PushCopyObjects(friend_invitation_storage_channel_event->GetReadableEvent()); |
| 1645 | } | 1649 | } |
| 1646 | 1650 | ||
| 1647 | void IApplicationFunctions::TryPopFromFriendInvitationStorageChannel( | 1651 | void IApplicationFunctions::TryPopFromFriendInvitationStorageChannel( |
| @@ -1657,7 +1661,7 @@ void IApplicationFunctions::GetHealthWarningDisappearedSystemEvent(Kernel::HLERe | |||
| 1657 | 1661 | ||
| 1658 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 1662 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 1659 | rb.Push(RESULT_SUCCESS); | 1663 | rb.Push(RESULT_SUCCESS); |
| 1660 | rb.PushCopyObjects(health_warning_disappeared_system_event.readable); | 1664 | rb.PushCopyObjects(health_warning_disappeared_system_event->GetReadableEvent()); |
| 1661 | } | 1665 | } |
| 1662 | 1666 | ||
| 1663 | void InstallInterfaces(SM::ServiceManager& service_manager, NVFlinger::NVFlinger& nvflinger, | 1667 | void InstallInterfaces(SM::ServiceManager& service_manager, NVFlinger::NVFlinger& nvflinger, |
| @@ -1693,8 +1697,9 @@ IHomeMenuFunctions::IHomeMenuFunctions(Core::System& system_) | |||
| 1693 | 1697 | ||
| 1694 | RegisterHandlers(functions); | 1698 | RegisterHandlers(functions); |
| 1695 | 1699 | ||
| 1696 | pop_from_general_channel_event = Kernel::WritableEvent::CreateEventPair( | 1700 | pop_from_general_channel_event = |
| 1697 | system.Kernel(), "IHomeMenuFunctions:PopFromGeneralChannelEvent"); | 1701 | Kernel::KEvent::Create(system.Kernel(), "IHomeMenuFunctions:PopFromGeneralChannelEvent"); |
| 1702 | pop_from_general_channel_event->Initialize(); | ||
| 1698 | } | 1703 | } |
| 1699 | 1704 | ||
| 1700 | IHomeMenuFunctions::~IHomeMenuFunctions() = default; | 1705 | IHomeMenuFunctions::~IHomeMenuFunctions() = default; |
| @@ -1711,7 +1716,7 @@ void IHomeMenuFunctions::GetPopFromGeneralChannelEvent(Kernel::HLERequestContext | |||
| 1711 | 1716 | ||
| 1712 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 1717 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 1713 | rb.Push(RESULT_SUCCESS); | 1718 | rb.Push(RESULT_SUCCESS); |
| 1714 | rb.PushCopyObjects(pop_from_general_channel_event.readable); | 1719 | rb.PushCopyObjects(pop_from_general_channel_event->GetReadableEvent()); |
| 1715 | } | 1720 | } |
| 1716 | 1721 | ||
| 1717 | IGlobalStateController::IGlobalStateController(Core::System& system_) | 1722 | IGlobalStateController::IGlobalStateController(Core::System& system_) |
diff --git a/src/core/hle/service/am/am.h b/src/core/hle/service/am/am.h index 154a48710..6911f0d6e 100644 --- a/src/core/hle/service/am/am.h +++ b/src/core/hle/service/am/am.h | |||
| @@ -7,11 +7,12 @@ | |||
| 7 | #include <chrono> | 7 | #include <chrono> |
| 8 | #include <memory> | 8 | #include <memory> |
| 9 | #include <queue> | 9 | #include <queue> |
| 10 | #include "core/hle/kernel/writable_event.h" | 10 | |
| 11 | #include "core/hle/service/service.h" | 11 | #include "core/hle/service/service.h" |
| 12 | 12 | ||
| 13 | namespace Kernel { | 13 | namespace Kernel { |
| 14 | class KernelCore; | 14 | class KernelCore; |
| 15 | class KEvent; | ||
| 15 | class TransferMemory; | 16 | class TransferMemory; |
| 16 | } // namespace Kernel | 17 | } // namespace Kernel |
| 17 | 18 | ||
| @@ -55,8 +56,8 @@ public: | |||
| 55 | explicit AppletMessageQueue(Kernel::KernelCore& kernel); | 56 | explicit AppletMessageQueue(Kernel::KernelCore& kernel); |
| 56 | ~AppletMessageQueue(); | 57 | ~AppletMessageQueue(); |
| 57 | 58 | ||
| 58 | const std::shared_ptr<Kernel::ReadableEvent>& GetMessageReceiveEvent() const; | 59 | const std::shared_ptr<Kernel::KReadableEvent>& GetMessageReceiveEvent() const; |
| 59 | const std::shared_ptr<Kernel::ReadableEvent>& GetOperationModeChangedEvent() const; | 60 | const std::shared_ptr<Kernel::KReadableEvent>& GetOperationModeChangedEvent() const; |
| 60 | void PushMessage(AppletMessage msg); | 61 | void PushMessage(AppletMessage msg); |
| 61 | AppletMessage PopMessage(); | 62 | AppletMessage PopMessage(); |
| 62 | std::size_t GetMessageCount() const; | 63 | std::size_t GetMessageCount() const; |
| @@ -65,8 +66,8 @@ public: | |||
| 65 | 66 | ||
| 66 | private: | 67 | private: |
| 67 | std::queue<AppletMessage> messages; | 68 | std::queue<AppletMessage> messages; |
| 68 | Kernel::EventPair on_new_message; | 69 | std::shared_ptr<Kernel::KEvent> on_new_message; |
| 69 | Kernel::EventPair on_operation_mode_changed; | 70 | std::shared_ptr<Kernel::KEvent> on_operation_mode_changed; |
| 70 | }; | 71 | }; |
| 71 | 72 | ||
| 72 | class IWindowController final : public ServiceFramework<IWindowController> { | 73 | class IWindowController final : public ServiceFramework<IWindowController> { |
| @@ -153,8 +154,8 @@ private: | |||
| 153 | }; | 154 | }; |
| 154 | 155 | ||
| 155 | NVFlinger::NVFlinger& nvflinger; | 156 | NVFlinger::NVFlinger& nvflinger; |
| 156 | Kernel::EventPair launchable_event; | 157 | std::shared_ptr<Kernel::KEvent> launchable_event; |
| 157 | Kernel::EventPair accumulated_suspended_tick_changed_event; | 158 | std::shared_ptr<Kernel::KEvent> accumulated_suspended_tick_changed_event; |
| 158 | 159 | ||
| 159 | u32 idle_time_detection_extension = 0; | 160 | u32 idle_time_detection_extension = 0; |
| 160 | u64 num_fatal_sections_entered = 0; | 161 | u64 num_fatal_sections_entered = 0; |
| @@ -295,9 +296,9 @@ private: | |||
| 295 | bool launch_popped_application_specific = false; | 296 | bool launch_popped_application_specific = false; |
| 296 | bool launch_popped_account_preselect = false; | 297 | bool launch_popped_account_preselect = false; |
| 297 | s32 previous_program_index{-1}; | 298 | s32 previous_program_index{-1}; |
| 298 | Kernel::EventPair gpu_error_detected_event; | 299 | std::shared_ptr<Kernel::KEvent> gpu_error_detected_event; |
| 299 | Kernel::EventPair friend_invitation_storage_channel_event; | 300 | std::shared_ptr<Kernel::KEvent> friend_invitation_storage_channel_event; |
| 300 | Kernel::EventPair health_warning_disappeared_system_event; | 301 | std::shared_ptr<Kernel::KEvent> health_warning_disappeared_system_event; |
| 301 | }; | 302 | }; |
| 302 | 303 | ||
| 303 | class IHomeMenuFunctions final : public ServiceFramework<IHomeMenuFunctions> { | 304 | class IHomeMenuFunctions final : public ServiceFramework<IHomeMenuFunctions> { |
| @@ -309,7 +310,7 @@ private: | |||
| 309 | void RequestToGetForeground(Kernel::HLERequestContext& ctx); | 310 | void RequestToGetForeground(Kernel::HLERequestContext& ctx); |
| 310 | void GetPopFromGeneralChannelEvent(Kernel::HLERequestContext& ctx); | 311 | void GetPopFromGeneralChannelEvent(Kernel::HLERequestContext& ctx); |
| 311 | 312 | ||
| 312 | Kernel::EventPair pop_from_general_channel_event; | 313 | std::shared_ptr<Kernel::KEvent> pop_from_general_channel_event; |
| 313 | }; | 314 | }; |
| 314 | 315 | ||
| 315 | class IGlobalStateController final : public ServiceFramework<IGlobalStateController> { | 316 | class IGlobalStateController final : public ServiceFramework<IGlobalStateController> { |
diff --git a/src/core/hle/service/am/applets/applets.cpp b/src/core/hle/service/am/applets/applets.cpp index 08676c3fc..e2f3b7563 100644 --- a/src/core/hle/service/am/applets/applets.cpp +++ b/src/core/hle/service/am/applets/applets.cpp | |||
| @@ -3,6 +3,7 @@ | |||
| 3 | // Refer to the license.txt file included. | 3 | // Refer to the license.txt file included. |
| 4 | 4 | ||
| 5 | #include <cstring> | 5 | #include <cstring> |
| 6 | |||
| 6 | #include "common/assert.h" | 7 | #include "common/assert.h" |
| 7 | #include "core/core.h" | 8 | #include "core/core.h" |
| 8 | #include "core/frontend/applets/controller.h" | 9 | #include "core/frontend/applets/controller.h" |
| @@ -11,9 +12,10 @@ | |||
| 11 | #include "core/frontend/applets/profile_select.h" | 12 | #include "core/frontend/applets/profile_select.h" |
| 12 | #include "core/frontend/applets/software_keyboard.h" | 13 | #include "core/frontend/applets/software_keyboard.h" |
| 13 | #include "core/frontend/applets/web_browser.h" | 14 | #include "core/frontend/applets/web_browser.h" |
| 14 | #include "core/hle/kernel/readable_event.h" | 15 | #include "core/hle/kernel/k_event.h" |
| 16 | #include "core/hle/kernel/k_readable_event.h" | ||
| 17 | #include "core/hle/kernel/k_writable_event.h" | ||
| 15 | #include "core/hle/kernel/server_session.h" | 18 | #include "core/hle/kernel/server_session.h" |
| 16 | #include "core/hle/kernel/writable_event.h" | ||
| 17 | #include "core/hle/service/am/am.h" | 19 | #include "core/hle/service/am/am.h" |
| 18 | #include "core/hle/service/am/applets/applets.h" | 20 | #include "core/hle/service/am/applets/applets.h" |
| 19 | #include "core/hle/service/am/applets/controller.h" | 21 | #include "core/hle/service/am/applets/controller.h" |
| @@ -27,11 +29,13 @@ namespace Service::AM::Applets { | |||
| 27 | 29 | ||
| 28 | AppletDataBroker::AppletDataBroker(Kernel::KernelCore& kernel) { | 30 | AppletDataBroker::AppletDataBroker(Kernel::KernelCore& kernel) { |
| 29 | state_changed_event = | 31 | state_changed_event = |
| 30 | Kernel::WritableEvent::CreateEventPair(kernel, "ILibraryAppletAccessor:StateChangedEvent"); | 32 | Kernel::KEvent::Create(kernel, "ILibraryAppletAccessor:StateChangedEvent"); |
| 31 | pop_out_data_event = | 33 | state_changed_event->Initialize(); |
| 32 | Kernel::WritableEvent::CreateEventPair(kernel, "ILibraryAppletAccessor:PopDataOutEvent"); | 34 | pop_out_data_event = Kernel::KEvent::Create(kernel, "ILibraryAppletAccessor:PopDataOutEvent"); |
| 33 | pop_interactive_out_data_event = Kernel::WritableEvent::CreateEventPair( | 35 | pop_out_data_event->Initialize(); |
| 34 | kernel, "ILibraryAppletAccessor:PopInteractiveDataOutEvent"); | 36 | pop_interactive_out_data_event = |
| 37 | Kernel::KEvent::Create(kernel, "ILibraryAppletAccessor:PopInteractiveDataOutEvent"); | ||
| 38 | pop_interactive_out_data_event->Initialize(); | ||
| 35 | } | 39 | } |
| 36 | 40 | ||
| 37 | AppletDataBroker::~AppletDataBroker() = default; | 41 | AppletDataBroker::~AppletDataBroker() = default; |
| @@ -58,7 +62,7 @@ std::shared_ptr<IStorage> AppletDataBroker::PopNormalDataToGame() { | |||
| 58 | 62 | ||
| 59 | auto out = std::move(out_channel.front()); | 63 | auto out = std::move(out_channel.front()); |
| 60 | out_channel.pop_front(); | 64 | out_channel.pop_front(); |
| 61 | pop_out_data_event.writable->Clear(); | 65 | pop_out_data_event->GetWritableEvent()->Clear(); |
| 62 | return out; | 66 | return out; |
| 63 | } | 67 | } |
| 64 | 68 | ||
| @@ -77,7 +81,7 @@ std::shared_ptr<IStorage> AppletDataBroker::PopInteractiveDataToGame() { | |||
| 77 | 81 | ||
| 78 | auto out = std::move(out_interactive_channel.front()); | 82 | auto out = std::move(out_interactive_channel.front()); |
| 79 | out_interactive_channel.pop_front(); | 83 | out_interactive_channel.pop_front(); |
| 80 | pop_interactive_out_data_event.writable->Clear(); | 84 | pop_interactive_out_data_event->GetWritableEvent()->Clear(); |
| 81 | return out; | 85 | return out; |
| 82 | } | 86 | } |
| 83 | 87 | ||
| @@ -96,7 +100,7 @@ void AppletDataBroker::PushNormalDataFromGame(std::shared_ptr<IStorage>&& storag | |||
| 96 | 100 | ||
| 97 | void AppletDataBroker::PushNormalDataFromApplet(std::shared_ptr<IStorage>&& storage) { | 101 | void AppletDataBroker::PushNormalDataFromApplet(std::shared_ptr<IStorage>&& storage) { |
| 98 | out_channel.emplace_back(std::move(storage)); | 102 | out_channel.emplace_back(std::move(storage)); |
| 99 | pop_out_data_event.writable->Signal(); | 103 | pop_out_data_event->GetWritableEvent()->Signal(); |
| 100 | } | 104 | } |
| 101 | 105 | ||
| 102 | void AppletDataBroker::PushInteractiveDataFromGame(std::shared_ptr<IStorage>&& storage) { | 106 | void AppletDataBroker::PushInteractiveDataFromGame(std::shared_ptr<IStorage>&& storage) { |
| @@ -105,23 +109,23 @@ void AppletDataBroker::PushInteractiveDataFromGame(std::shared_ptr<IStorage>&& s | |||
| 105 | 109 | ||
| 106 | void AppletDataBroker::PushInteractiveDataFromApplet(std::shared_ptr<IStorage>&& storage) { | 110 | void AppletDataBroker::PushInteractiveDataFromApplet(std::shared_ptr<IStorage>&& storage) { |
| 107 | out_interactive_channel.emplace_back(std::move(storage)); | 111 | out_interactive_channel.emplace_back(std::move(storage)); |
| 108 | pop_interactive_out_data_event.writable->Signal(); | 112 | pop_interactive_out_data_event->GetWritableEvent()->Signal(); |
| 109 | } | 113 | } |
| 110 | 114 | ||
| 111 | void AppletDataBroker::SignalStateChanged() const { | 115 | void AppletDataBroker::SignalStateChanged() const { |
| 112 | state_changed_event.writable->Signal(); | 116 | state_changed_event->GetWritableEvent()->Signal(); |
| 113 | } | 117 | } |
| 114 | 118 | ||
| 115 | std::shared_ptr<Kernel::ReadableEvent> AppletDataBroker::GetNormalDataEvent() const { | 119 | std::shared_ptr<Kernel::KReadableEvent> AppletDataBroker::GetNormalDataEvent() const { |
| 116 | return pop_out_data_event.readable; | 120 | return pop_out_data_event->GetReadableEvent(); |
| 117 | } | 121 | } |
| 118 | 122 | ||
| 119 | std::shared_ptr<Kernel::ReadableEvent> AppletDataBroker::GetInteractiveDataEvent() const { | 123 | std::shared_ptr<Kernel::KReadableEvent> AppletDataBroker::GetInteractiveDataEvent() const { |
| 120 | return pop_interactive_out_data_event.readable; | 124 | return pop_interactive_out_data_event->GetReadableEvent(); |
| 121 | } | 125 | } |
| 122 | 126 | ||
| 123 | std::shared_ptr<Kernel::ReadableEvent> AppletDataBroker::GetStateChangedEvent() const { | 127 | std::shared_ptr<Kernel::KReadableEvent> AppletDataBroker::GetStateChangedEvent() const { |
| 124 | return state_changed_event.readable; | 128 | return state_changed_event->GetReadableEvent(); |
| 125 | } | 129 | } |
| 126 | 130 | ||
| 127 | Applet::Applet(Kernel::KernelCore& kernel_) : broker{kernel_} {} | 131 | Applet::Applet(Kernel::KernelCore& kernel_) : broker{kernel_} {} |
diff --git a/src/core/hle/service/am/applets/applets.h b/src/core/hle/service/am/applets/applets.h index 4fd792c05..b9a006317 100644 --- a/src/core/hle/service/am/applets/applets.h +++ b/src/core/hle/service/am/applets/applets.h | |||
| @@ -6,9 +6,9 @@ | |||
| 6 | 6 | ||
| 7 | #include <memory> | 7 | #include <memory> |
| 8 | #include <queue> | 8 | #include <queue> |
| 9 | |||
| 9 | #include "common/swap.h" | 10 | #include "common/swap.h" |
| 10 | #include "core/hle/kernel/object.h" | 11 | #include "core/hle/kernel/object.h" |
| 11 | #include "core/hle/kernel/writable_event.h" | ||
| 12 | 12 | ||
| 13 | union ResultCode; | 13 | union ResultCode; |
| 14 | 14 | ||
| @@ -29,7 +29,9 @@ class WebBrowserApplet; | |||
| 29 | 29 | ||
| 30 | namespace Kernel { | 30 | namespace Kernel { |
| 31 | class KernelCore; | 31 | class KernelCore; |
| 32 | } | 32 | class KEvent; |
| 33 | class KReadableEvent; | ||
| 34 | } // namespace Kernel | ||
| 33 | 35 | ||
| 34 | namespace Service::AM { | 36 | namespace Service::AM { |
| 35 | 37 | ||
| @@ -87,9 +89,9 @@ public: | |||
| 87 | 89 | ||
| 88 | void SignalStateChanged() const; | 90 | void SignalStateChanged() const; |
| 89 | 91 | ||
| 90 | std::shared_ptr<Kernel::ReadableEvent> GetNormalDataEvent() const; | 92 | std::shared_ptr<Kernel::KReadableEvent> GetNormalDataEvent() const; |
| 91 | std::shared_ptr<Kernel::ReadableEvent> GetInteractiveDataEvent() const; | 93 | std::shared_ptr<Kernel::KReadableEvent> GetInteractiveDataEvent() const; |
| 92 | std::shared_ptr<Kernel::ReadableEvent> GetStateChangedEvent() const; | 94 | std::shared_ptr<Kernel::KReadableEvent> GetStateChangedEvent() const; |
| 93 | 95 | ||
| 94 | private: | 96 | private: |
| 95 | // Queues are named from applet's perspective | 97 | // Queues are named from applet's perspective |
| @@ -106,13 +108,13 @@ private: | |||
| 106 | // PopInteractiveDataToGame and PushInteractiveDataFromApplet | 108 | // PopInteractiveDataToGame and PushInteractiveDataFromApplet |
| 107 | std::deque<std::shared_ptr<IStorage>> out_interactive_channel; | 109 | std::deque<std::shared_ptr<IStorage>> out_interactive_channel; |
| 108 | 110 | ||
| 109 | Kernel::EventPair state_changed_event; | 111 | std::shared_ptr<Kernel::KEvent> state_changed_event; |
| 110 | 112 | ||
| 111 | // Signaled on PushNormalDataFromApplet | 113 | // Signaled on PushNormalDataFromApplet |
| 112 | Kernel::EventPair pop_out_data_event; | 114 | std::shared_ptr<Kernel::KEvent> pop_out_data_event; |
| 113 | 115 | ||
| 114 | // Signaled on PushInteractiveDataFromApplet | 116 | // Signaled on PushInteractiveDataFromApplet |
| 115 | Kernel::EventPair pop_interactive_out_data_event; | 117 | std::shared_ptr<Kernel::KEvent> pop_interactive_out_data_event; |
| 116 | }; | 118 | }; |
| 117 | 119 | ||
| 118 | class Applet { | 120 | class Applet { |
diff --git a/src/core/hle/service/aoc/aoc_u.cpp b/src/core/hle/service/aoc/aoc_u.cpp index 23e28565b..8d657c0bf 100644 --- a/src/core/hle/service/aoc/aoc_u.cpp +++ b/src/core/hle/service/aoc/aoc_u.cpp | |||
| @@ -5,6 +5,7 @@ | |||
| 5 | #include <algorithm> | 5 | #include <algorithm> |
| 6 | #include <numeric> | 6 | #include <numeric> |
| 7 | #include <vector> | 7 | #include <vector> |
| 8 | |||
| 8 | #include "common/logging/log.h" | 9 | #include "common/logging/log.h" |
| 9 | #include "core/core.h" | 10 | #include "core/core.h" |
| 10 | #include "core/file_sys/common_funcs.h" | 11 | #include "core/file_sys/common_funcs.h" |
| @@ -14,10 +15,10 @@ | |||
| 14 | #include "core/file_sys/patch_manager.h" | 15 | #include "core/file_sys/patch_manager.h" |
| 15 | #include "core/file_sys/registered_cache.h" | 16 | #include "core/file_sys/registered_cache.h" |
| 16 | #include "core/hle/ipc_helpers.h" | 17 | #include "core/hle/ipc_helpers.h" |
| 18 | #include "core/hle/kernel/k_event.h" | ||
| 19 | #include "core/hle/kernel/k_readable_event.h" | ||
| 17 | #include "core/hle/kernel/kernel.h" | 20 | #include "core/hle/kernel/kernel.h" |
| 18 | #include "core/hle/kernel/process.h" | 21 | #include "core/hle/kernel/process.h" |
| 19 | #include "core/hle/kernel/readable_event.h" | ||
| 20 | #include "core/hle/kernel/writable_event.h" | ||
| 21 | #include "core/hle/service/aoc/aoc_u.h" | 22 | #include "core/hle/service/aoc/aoc_u.h" |
| 22 | #include "core/loader/loader.h" | 23 | #include "core/loader/loader.h" |
| 23 | #include "core/settings.h" | 24 | #include "core/settings.h" |
| @@ -62,8 +63,9 @@ public: | |||
| 62 | 63 | ||
| 63 | RegisterHandlers(functions); | 64 | RegisterHandlers(functions); |
| 64 | 65 | ||
| 65 | purchased_event = Kernel::WritableEvent::CreateEventPair( | 66 | purchased_event = |
| 66 | system.Kernel(), "IPurchaseEventManager:PurchasedEvent"); | 67 | Kernel::KEvent::Create(system.Kernel(), "IPurchaseEventManager:PurchasedEvent"); |
| 68 | purchased_event->Initialize(); | ||
| 67 | } | 69 | } |
| 68 | 70 | ||
| 69 | private: | 71 | private: |
| @@ -96,10 +98,10 @@ private: | |||
| 96 | 98 | ||
| 97 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 99 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 98 | rb.Push(RESULT_SUCCESS); | 100 | rb.Push(RESULT_SUCCESS); |
| 99 | rb.PushCopyObjects(purchased_event.readable); | 101 | rb.PushCopyObjects(purchased_event->GetReadableEvent()); |
| 100 | } | 102 | } |
| 101 | 103 | ||
| 102 | Kernel::EventPair purchased_event; | 104 | std::shared_ptr<Kernel::KEvent> purchased_event; |
| 103 | }; | 105 | }; |
| 104 | 106 | ||
| 105 | AOC_U::AOC_U(Core::System& system_) | 107 | AOC_U::AOC_U(Core::System& system_) |
| @@ -124,8 +126,8 @@ AOC_U::AOC_U(Core::System& system_) | |||
| 124 | RegisterHandlers(functions); | 126 | RegisterHandlers(functions); |
| 125 | 127 | ||
| 126 | auto& kernel = system.Kernel(); | 128 | auto& kernel = system.Kernel(); |
| 127 | aoc_change_event = | 129 | aoc_change_event = Kernel::KEvent::Create(kernel, "GetAddOnContentListChanged:Event"); |
| 128 | Kernel::WritableEvent::CreateEventPair(kernel, "GetAddOnContentListChanged:Event"); | 130 | aoc_change_event->Initialize(); |
| 129 | } | 131 | } |
| 130 | 132 | ||
| 131 | AOC_U::~AOC_U() = default; | 133 | AOC_U::~AOC_U() = default; |
| @@ -252,7 +254,7 @@ void AOC_U::GetAddOnContentListChangedEvent(Kernel::HLERequestContext& ctx) { | |||
| 252 | 254 | ||
| 253 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 255 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 254 | rb.Push(RESULT_SUCCESS); | 256 | rb.Push(RESULT_SUCCESS); |
| 255 | rb.PushCopyObjects(aoc_change_event.readable); | 257 | rb.PushCopyObjects(aoc_change_event->GetReadableEvent()); |
| 256 | } | 258 | } |
| 257 | 259 | ||
| 258 | void AOC_U::CreateEcPurchasedEventManager(Kernel::HLERequestContext& ctx) { | 260 | void AOC_U::CreateEcPurchasedEventManager(Kernel::HLERequestContext& ctx) { |
diff --git a/src/core/hle/service/aoc/aoc_u.h b/src/core/hle/service/aoc/aoc_u.h index 26ee51be0..1aa23529e 100644 --- a/src/core/hle/service/aoc/aoc_u.h +++ b/src/core/hle/service/aoc/aoc_u.h | |||
| @@ -11,7 +11,7 @@ class System; | |||
| 11 | } | 11 | } |
| 12 | 12 | ||
| 13 | namespace Kernel { | 13 | namespace Kernel { |
| 14 | class WritableEvent; | 14 | class KEvent; |
| 15 | } | 15 | } |
| 16 | 16 | ||
| 17 | namespace Service::AOC { | 17 | namespace Service::AOC { |
| @@ -31,7 +31,7 @@ private: | |||
| 31 | void CreatePermanentEcPurchasedEventManager(Kernel::HLERequestContext& ctx); | 31 | void CreatePermanentEcPurchasedEventManager(Kernel::HLERequestContext& ctx); |
| 32 | 32 | ||
| 33 | std::vector<u64> add_on_content; | 33 | std::vector<u64> add_on_content; |
| 34 | Kernel::EventPair aoc_change_event; | 34 | std::shared_ptr<Kernel::KEvent> aoc_change_event; |
| 35 | }; | 35 | }; |
| 36 | 36 | ||
| 37 | /// Registers all AOC services with the specified service manager. | 37 | /// Registers all AOC services with the specified service manager. |
diff --git a/src/core/hle/service/audio/audout_u.cpp b/src/core/hle/service/audio/audout_u.cpp index 273a46265..5ed9cb20e 100644 --- a/src/core/hle/service/audio/audout_u.cpp +++ b/src/core/hle/service/audio/audout_u.cpp | |||
| @@ -14,9 +14,10 @@ | |||
| 14 | #include "core/core.h" | 14 | #include "core/core.h" |
| 15 | #include "core/hle/ipc_helpers.h" | 15 | #include "core/hle/ipc_helpers.h" |
| 16 | #include "core/hle/kernel/hle_ipc.h" | 16 | #include "core/hle/kernel/hle_ipc.h" |
| 17 | #include "core/hle/kernel/k_event.h" | ||
| 18 | #include "core/hle/kernel/k_readable_event.h" | ||
| 19 | #include "core/hle/kernel/k_writable_event.h" | ||
| 17 | #include "core/hle/kernel/kernel.h" | 20 | #include "core/hle/kernel/kernel.h" |
| 18 | #include "core/hle/kernel/readable_event.h" | ||
| 19 | #include "core/hle/kernel/writable_event.h" | ||
| 20 | #include "core/hle/service/audio/audout_u.h" | 21 | #include "core/hle/service/audio/audout_u.h" |
| 21 | #include "core/hle/service/audio/errors.h" | 22 | #include "core/hle/service/audio/errors.h" |
| 22 | #include "core/memory.h" | 23 | #include "core/memory.h" |
| @@ -66,13 +67,13 @@ public: | |||
| 66 | RegisterHandlers(functions); | 67 | RegisterHandlers(functions); |
| 67 | 68 | ||
| 68 | // This is the event handle used to check if the audio buffer was released | 69 | // This is the event handle used to check if the audio buffer was released |
| 69 | buffer_event = | 70 | buffer_event = Kernel::KEvent::Create(system.Kernel(), "IAudioOutBufferReleased"); |
| 70 | Kernel::WritableEvent::CreateEventPair(system.Kernel(), "IAudioOutBufferReleased"); | 71 | buffer_event->Initialize(); |
| 71 | 72 | ||
| 72 | stream = audio_core.OpenStream(system.CoreTiming(), audio_params.sample_rate, | 73 | stream = audio_core.OpenStream(system.CoreTiming(), audio_params.sample_rate, |
| 73 | audio_params.channel_count, std::move(unique_name), [this] { | 74 | audio_params.channel_count, std::move(unique_name), [this] { |
| 74 | const auto guard = LockService(); | 75 | const auto guard = LockService(); |
| 75 | buffer_event.writable->Signal(); | 76 | buffer_event->GetWritableEvent()->Signal(); |
| 76 | }); | 77 | }); |
| 77 | } | 78 | } |
| 78 | 79 | ||
| @@ -125,7 +126,7 @@ private: | |||
| 125 | 126 | ||
| 126 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 127 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 127 | rb.Push(RESULT_SUCCESS); | 128 | rb.Push(RESULT_SUCCESS); |
| 128 | rb.PushCopyObjects(buffer_event.readable); | 129 | rb.PushCopyObjects(buffer_event->GetReadableEvent()); |
| 129 | } | 130 | } |
| 130 | 131 | ||
| 131 | void AppendAudioOutBufferImpl(Kernel::HLERequestContext& ctx) { | 132 | void AppendAudioOutBufferImpl(Kernel::HLERequestContext& ctx) { |
| @@ -219,7 +220,7 @@ private: | |||
| 219 | [[maybe_unused]] AudoutParams audio_params{}; | 220 | [[maybe_unused]] AudoutParams audio_params{}; |
| 220 | 221 | ||
| 221 | /// This is the event handle used to check if the audio buffer was released | 222 | /// This is the event handle used to check if the audio buffer was released |
| 222 | Kernel::EventPair buffer_event; | 223 | std::shared_ptr<Kernel::KEvent> buffer_event; |
| 223 | Core::Memory::Memory& main_memory; | 224 | Core::Memory::Memory& main_memory; |
| 224 | }; | 225 | }; |
| 225 | 226 | ||
diff --git a/src/core/hle/service/audio/audren_u.cpp b/src/core/hle/service/audio/audren_u.cpp index c5c22d053..b2b2ffc5a 100644 --- a/src/core/hle/service/audio/audren_u.cpp +++ b/src/core/hle/service/audio/audren_u.cpp | |||
| @@ -16,9 +16,10 @@ | |||
| 16 | #include "core/core.h" | 16 | #include "core/core.h" |
| 17 | #include "core/hle/ipc_helpers.h" | 17 | #include "core/hle/ipc_helpers.h" |
| 18 | #include "core/hle/kernel/hle_ipc.h" | 18 | #include "core/hle/kernel/hle_ipc.h" |
| 19 | #include "core/hle/kernel/k_event.h" | ||
| 20 | #include "core/hle/kernel/k_readable_event.h" | ||
| 21 | #include "core/hle/kernel/k_writable_event.h" | ||
| 19 | #include "core/hle/kernel/kernel.h" | 22 | #include "core/hle/kernel/kernel.h" |
| 20 | #include "core/hle/kernel/readable_event.h" | ||
| 21 | #include "core/hle/kernel/writable_event.h" | ||
| 22 | #include "core/hle/service/audio/audren_u.h" | 23 | #include "core/hle/service/audio/audren_u.h" |
| 23 | #include "core/hle/service/audio/errors.h" | 24 | #include "core/hle/service/audio/errors.h" |
| 24 | 25 | ||
| @@ -47,13 +48,13 @@ public: | |||
| 47 | // clang-format on | 48 | // clang-format on |
| 48 | RegisterHandlers(functions); | 49 | RegisterHandlers(functions); |
| 49 | 50 | ||
| 50 | system_event = | 51 | system_event = Kernel::KEvent::Create(system.Kernel(), "IAudioRenderer:SystemEvent"); |
| 51 | Kernel::WritableEvent::CreateEventPair(system.Kernel(), "IAudioRenderer:SystemEvent"); | 52 | system_event->Initialize(); |
| 52 | renderer = std::make_unique<AudioCore::AudioRenderer>( | 53 | renderer = std::make_unique<AudioCore::AudioRenderer>( |
| 53 | system.CoreTiming(), system.Memory(), audren_params, | 54 | system.CoreTiming(), system.Memory(), audren_params, |
| 54 | [this]() { | 55 | [this]() { |
| 55 | const auto guard = LockService(); | 56 | const auto guard = LockService(); |
| 56 | system_event.writable->Signal(); | 57 | system_event->GetWritableEvent()->Signal(); |
| 57 | }, | 58 | }, |
| 58 | instance_number); | 59 | instance_number); |
| 59 | } | 60 | } |
| @@ -126,7 +127,7 @@ private: | |||
| 126 | 127 | ||
| 127 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 128 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 128 | rb.Push(RESULT_SUCCESS); | 129 | rb.Push(RESULT_SUCCESS); |
| 129 | rb.PushCopyObjects(system_event.readable); | 130 | rb.PushCopyObjects(system_event->GetReadableEvent()); |
| 130 | } | 131 | } |
| 131 | 132 | ||
| 132 | void SetRenderingTimeLimit(Kernel::HLERequestContext& ctx) { | 133 | void SetRenderingTimeLimit(Kernel::HLERequestContext& ctx) { |
| @@ -160,7 +161,7 @@ private: | |||
| 160 | rb.Push(ERR_NOT_SUPPORTED); | 161 | rb.Push(ERR_NOT_SUPPORTED); |
| 161 | } | 162 | } |
| 162 | 163 | ||
| 163 | Kernel::EventPair system_event; | 164 | std::shared_ptr<Kernel::KEvent> system_event; |
| 164 | std::unique_ptr<AudioCore::AudioRenderer> renderer; | 165 | std::unique_ptr<AudioCore::AudioRenderer> renderer; |
| 165 | u32 rendering_time_limit_percent = 100; | 166 | u32 rendering_time_limit_percent = 100; |
| 166 | }; | 167 | }; |
| @@ -187,17 +188,19 @@ public: | |||
| 187 | RegisterHandlers(functions); | 188 | RegisterHandlers(functions); |
| 188 | 189 | ||
| 189 | auto& kernel = system.Kernel(); | 190 | auto& kernel = system.Kernel(); |
| 190 | buffer_event = | 191 | buffer_event = Kernel::KEvent::Create(kernel, "IAudioOutBufferReleasedEvent"); |
| 191 | Kernel::WritableEvent::CreateEventPair(kernel, "IAudioOutBufferReleasedEvent"); | 192 | buffer_event->Initialize(); |
| 192 | 193 | ||
| 193 | // Should be similar to audio_output_device_switch_event | 194 | // Should be similar to audio_output_device_switch_event |
| 194 | audio_input_device_switch_event = Kernel::WritableEvent::CreateEventPair( | 195 | audio_input_device_switch_event = |
| 195 | kernel, "IAudioDevice:AudioInputDeviceSwitchedEvent"); | 196 | Kernel::KEvent::Create(kernel, "IAudioDevice:AudioInputDeviceSwitchedEvent"); |
| 197 | audio_input_device_switch_event->Initialize(); | ||
| 196 | 198 | ||
| 197 | // Should only be signalled when an audio output device has been changed, example: speaker | 199 | // Should only be signalled when an audio output device has been changed, example: speaker |
| 198 | // to headset | 200 | // to headset |
| 199 | audio_output_device_switch_event = Kernel::WritableEvent::CreateEventPair( | 201 | audio_output_device_switch_event = |
| 200 | kernel, "IAudioDevice:AudioOutputDeviceSwitchedEvent"); | 202 | Kernel::KEvent::Create(kernel, "IAudioDevice:AudioOutputDeviceSwitchedEvent"); |
| 203 | audio_output_device_switch_event->Initialize(); | ||
| 201 | } | 204 | } |
| 202 | 205 | ||
| 203 | private: | 206 | private: |
| @@ -286,11 +289,11 @@ private: | |||
| 286 | void QueryAudioDeviceSystemEvent(Kernel::HLERequestContext& ctx) { | 289 | void QueryAudioDeviceSystemEvent(Kernel::HLERequestContext& ctx) { |
| 287 | LOG_WARNING(Service_Audio, "(STUBBED) called"); | 290 | LOG_WARNING(Service_Audio, "(STUBBED) called"); |
| 288 | 291 | ||
| 289 | buffer_event.writable->Signal(); | 292 | buffer_event->GetWritableEvent()->Signal(); |
| 290 | 293 | ||
| 291 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 294 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 292 | rb.Push(RESULT_SUCCESS); | 295 | rb.Push(RESULT_SUCCESS); |
| 293 | rb.PushCopyObjects(buffer_event.readable); | 296 | rb.PushCopyObjects(buffer_event->GetReadableEvent()); |
| 294 | } | 297 | } |
| 295 | 298 | ||
| 296 | void GetActiveChannelCount(Kernel::HLERequestContext& ctx) { | 299 | void GetActiveChannelCount(Kernel::HLERequestContext& ctx) { |
| @@ -307,7 +310,7 @@ private: | |||
| 307 | 310 | ||
| 308 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 311 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 309 | rb.Push(RESULT_SUCCESS); | 312 | rb.Push(RESULT_SUCCESS); |
| 310 | rb.PushCopyObjects(audio_input_device_switch_event.readable); | 313 | rb.PushCopyObjects(audio_input_device_switch_event->GetReadableEvent()); |
| 311 | } | 314 | } |
| 312 | 315 | ||
| 313 | void QueryAudioDeviceOutputEvent(Kernel::HLERequestContext& ctx) { | 316 | void QueryAudioDeviceOutputEvent(Kernel::HLERequestContext& ctx) { |
| @@ -315,13 +318,13 @@ private: | |||
| 315 | 318 | ||
| 316 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 319 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 317 | rb.Push(RESULT_SUCCESS); | 320 | rb.Push(RESULT_SUCCESS); |
| 318 | rb.PushCopyObjects(audio_output_device_switch_event.readable); | 321 | rb.PushCopyObjects(audio_output_device_switch_event->GetReadableEvent()); |
| 319 | } | 322 | } |
| 320 | 323 | ||
| 321 | u32_le revision = 0; | 324 | u32_le revision = 0; |
| 322 | Kernel::EventPair buffer_event; | 325 | std::shared_ptr<Kernel::KEvent> buffer_event; |
| 323 | Kernel::EventPair audio_input_device_switch_event; | 326 | std::shared_ptr<Kernel::KEvent> audio_input_device_switch_event; |
| 324 | Kernel::EventPair audio_output_device_switch_event; | 327 | std::shared_ptr<Kernel::KEvent> audio_output_device_switch_event; |
| 325 | 328 | ||
| 326 | }; // namespace Audio | 329 | }; // namespace Audio |
| 327 | 330 | ||
diff --git a/src/core/hle/service/bcat/backend/backend.cpp b/src/core/hle/service/bcat/backend/backend.cpp index 174388445..92d25dbe4 100644 --- a/src/core/hle/service/bcat/backend/backend.cpp +++ b/src/core/hle/service/bcat/backend/backend.cpp | |||
| @@ -5,6 +5,9 @@ | |||
| 5 | #include "common/hex_util.h" | 5 | #include "common/hex_util.h" |
| 6 | #include "common/logging/log.h" | 6 | #include "common/logging/log.h" |
| 7 | #include "core/core.h" | 7 | #include "core/core.h" |
| 8 | #include "core/hle/kernel/k_event.h" | ||
| 9 | #include "core/hle/kernel/k_readable_event.h" | ||
| 10 | #include "core/hle/kernel/k_writable_event.h" | ||
| 8 | #include "core/hle/lock.h" | 11 | #include "core/hle/lock.h" |
| 9 | #include "core/hle/service/bcat/backend/backend.h" | 12 | #include "core/hle/service/bcat/backend/backend.h" |
| 10 | 13 | ||
| @@ -12,12 +15,13 @@ namespace Service::BCAT { | |||
| 12 | 15 | ||
| 13 | ProgressServiceBackend::ProgressServiceBackend(Kernel::KernelCore& kernel, | 16 | ProgressServiceBackend::ProgressServiceBackend(Kernel::KernelCore& kernel, |
| 14 | std::string_view event_name) { | 17 | std::string_view event_name) { |
| 15 | event = Kernel::WritableEvent::CreateEventPair( | 18 | event = Kernel::KEvent::Create(kernel, |
| 16 | kernel, std::string("ProgressServiceBackend:UpdateEvent:").append(event_name)); | 19 | "ProgressServiceBackend:UpdateEvent:" + std::string(event_name)); |
| 20 | event->Initialize(); | ||
| 17 | } | 21 | } |
| 18 | 22 | ||
| 19 | std::shared_ptr<Kernel::ReadableEvent> ProgressServiceBackend::GetEvent() const { | 23 | std::shared_ptr<Kernel::KReadableEvent> ProgressServiceBackend::GetEvent() const { |
| 20 | return event.readable; | 24 | return event->GetReadableEvent(); |
| 21 | } | 25 | } |
| 22 | 26 | ||
| 23 | DeliveryCacheProgressImpl& ProgressServiceBackend::GetImpl() { | 27 | DeliveryCacheProgressImpl& ProgressServiceBackend::GetImpl() { |
| @@ -85,9 +89,9 @@ void ProgressServiceBackend::FinishDownload(ResultCode result) { | |||
| 85 | void ProgressServiceBackend::SignalUpdate() const { | 89 | void ProgressServiceBackend::SignalUpdate() const { |
| 86 | if (need_hle_lock) { | 90 | if (need_hle_lock) { |
| 87 | std::lock_guard lock(HLE::g_hle_lock); | 91 | std::lock_guard lock(HLE::g_hle_lock); |
| 88 | event.writable->Signal(); | 92 | event->GetWritableEvent()->Signal(); |
| 89 | } else { | 93 | } else { |
| 90 | event.writable->Signal(); | 94 | event->GetWritableEvent()->Signal(); |
| 91 | } | 95 | } |
| 92 | } | 96 | } |
| 93 | 97 | ||
diff --git a/src/core/hle/service/bcat/backend/backend.h b/src/core/hle/service/bcat/backend/backend.h index 48bbbe66f..db585b069 100644 --- a/src/core/hle/service/bcat/backend/backend.h +++ b/src/core/hle/service/bcat/backend/backend.h | |||
| @@ -11,8 +11,6 @@ | |||
| 11 | 11 | ||
| 12 | #include "common/common_types.h" | 12 | #include "common/common_types.h" |
| 13 | #include "core/file_sys/vfs_types.h" | 13 | #include "core/file_sys/vfs_types.h" |
| 14 | #include "core/hle/kernel/readable_event.h" | ||
| 15 | #include "core/hle/kernel/writable_event.h" | ||
| 16 | #include "core/hle/result.h" | 14 | #include "core/hle/result.h" |
| 17 | 15 | ||
| 18 | namespace Core { | 16 | namespace Core { |
| @@ -21,7 +19,9 @@ class System; | |||
| 21 | 19 | ||
| 22 | namespace Kernel { | 20 | namespace Kernel { |
| 23 | class KernelCore; | 21 | class KernelCore; |
| 24 | } | 22 | class KEvent; |
| 23 | class KReadableEvent; | ||
| 24 | } // namespace Kernel | ||
| 25 | 25 | ||
| 26 | namespace Service::BCAT { | 26 | namespace Service::BCAT { |
| 27 | 27 | ||
| @@ -98,13 +98,13 @@ public: | |||
| 98 | private: | 98 | private: |
| 99 | explicit ProgressServiceBackend(Kernel::KernelCore& kernel, std::string_view event_name); | 99 | explicit ProgressServiceBackend(Kernel::KernelCore& kernel, std::string_view event_name); |
| 100 | 100 | ||
| 101 | std::shared_ptr<Kernel::ReadableEvent> GetEvent() const; | 101 | std::shared_ptr<Kernel::KReadableEvent> GetEvent() const; |
| 102 | DeliveryCacheProgressImpl& GetImpl(); | 102 | DeliveryCacheProgressImpl& GetImpl(); |
| 103 | 103 | ||
| 104 | void SignalUpdate() const; | 104 | void SignalUpdate() const; |
| 105 | 105 | ||
| 106 | DeliveryCacheProgressImpl impl{}; | 106 | DeliveryCacheProgressImpl impl{}; |
| 107 | Kernel::EventPair event; | 107 | std::shared_ptr<Kernel::KEvent> event; |
| 108 | bool need_hle_lock = false; | 108 | bool need_hle_lock = false; |
| 109 | }; | 109 | }; |
| 110 | 110 | ||
diff --git a/src/core/hle/service/bcat/module.cpp b/src/core/hle/service/bcat/module.cpp index b8696a395..503109fdd 100644 --- a/src/core/hle/service/bcat/module.cpp +++ b/src/core/hle/service/bcat/module.cpp | |||
| @@ -11,9 +11,9 @@ | |||
| 11 | #include "core/core.h" | 11 | #include "core/core.h" |
| 12 | #include "core/file_sys/vfs.h" | 12 | #include "core/file_sys/vfs.h" |
| 13 | #include "core/hle/ipc_helpers.h" | 13 | #include "core/hle/ipc_helpers.h" |
| 14 | #include "core/hle/kernel/k_readable_event.h" | ||
| 15 | #include "core/hle/kernel/k_writable_event.h" | ||
| 14 | #include "core/hle/kernel/process.h" | 16 | #include "core/hle/kernel/process.h" |
| 15 | #include "core/hle/kernel/readable_event.h" | ||
| 16 | #include "core/hle/kernel/writable_event.h" | ||
| 17 | #include "core/hle/service/bcat/backend/backend.h" | 17 | #include "core/hle/service/bcat/backend/backend.h" |
| 18 | #include "core/hle/service/bcat/bcat.h" | 18 | #include "core/hle/service/bcat/bcat.h" |
| 19 | #include "core/hle/service/bcat/module.h" | 19 | #include "core/hle/service/bcat/module.h" |
| @@ -89,7 +89,7 @@ struct DeliveryCacheDirectoryEntry { | |||
| 89 | class IDeliveryCacheProgressService final : public ServiceFramework<IDeliveryCacheProgressService> { | 89 | class IDeliveryCacheProgressService final : public ServiceFramework<IDeliveryCacheProgressService> { |
| 90 | public: | 90 | public: |
| 91 | explicit IDeliveryCacheProgressService(Core::System& system_, | 91 | explicit IDeliveryCacheProgressService(Core::System& system_, |
| 92 | std::shared_ptr<Kernel::ReadableEvent> event_, | 92 | std::shared_ptr<Kernel::KReadableEvent> event_, |
| 93 | const DeliveryCacheProgressImpl& impl_) | 93 | const DeliveryCacheProgressImpl& impl_) |
| 94 | : ServiceFramework{system_, "IDeliveryCacheProgressService"}, event{std::move(event_)}, | 94 | : ServiceFramework{system_, "IDeliveryCacheProgressService"}, event{std::move(event_)}, |
| 95 | impl{impl_} { | 95 | impl{impl_} { |
| @@ -121,7 +121,7 @@ private: | |||
| 121 | rb.Push(RESULT_SUCCESS); | 121 | rb.Push(RESULT_SUCCESS); |
| 122 | } | 122 | } |
| 123 | 123 | ||
| 124 | std::shared_ptr<Kernel::ReadableEvent> event; | 124 | std::shared_ptr<Kernel::KReadableEvent> event; |
| 125 | const DeliveryCacheProgressImpl& impl; | 125 | const DeliveryCacheProgressImpl& impl; |
| 126 | }; | 126 | }; |
| 127 | 127 | ||
diff --git a/src/core/hle/service/btdrv/btdrv.cpp b/src/core/hle/service/btdrv/btdrv.cpp index 2de86f1f1..17a2ac899 100644 --- a/src/core/hle/service/btdrv/btdrv.cpp +++ b/src/core/hle/service/btdrv/btdrv.cpp | |||
| @@ -6,9 +6,9 @@ | |||
| 6 | #include "core/core.h" | 6 | #include "core/core.h" |
| 7 | #include "core/hle/ipc_helpers.h" | 7 | #include "core/hle/ipc_helpers.h" |
| 8 | #include "core/hle/kernel/hle_ipc.h" | 8 | #include "core/hle/kernel/hle_ipc.h" |
| 9 | #include "core/hle/kernel/k_event.h" | ||
| 10 | #include "core/hle/kernel/k_readable_event.h" | ||
| 9 | #include "core/hle/kernel/kernel.h" | 11 | #include "core/hle/kernel/kernel.h" |
| 10 | #include "core/hle/kernel/readable_event.h" | ||
| 11 | #include "core/hle/kernel/writable_event.h" | ||
| 12 | #include "core/hle/service/btdrv/btdrv.h" | 12 | #include "core/hle/service/btdrv/btdrv.h" |
| 13 | #include "core/hle/service/service.h" | 13 | #include "core/hle/service/service.h" |
| 14 | #include "core/hle/service/sm/sm.h" | 14 | #include "core/hle/service/sm/sm.h" |
| @@ -35,7 +35,8 @@ public: | |||
| 35 | RegisterHandlers(functions); | 35 | RegisterHandlers(functions); |
| 36 | 36 | ||
| 37 | auto& kernel = system.Kernel(); | 37 | auto& kernel = system.Kernel(); |
| 38 | register_event = Kernel::WritableEvent::CreateEventPair(kernel, "BT:RegisterEvent"); | 38 | register_event = Kernel::KEvent::Create(kernel, "BT:RegisterEvent"); |
| 39 | register_event->Initialize(); | ||
| 39 | } | 40 | } |
| 40 | 41 | ||
| 41 | private: | 42 | private: |
| @@ -44,10 +45,10 @@ private: | |||
| 44 | 45 | ||
| 45 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 46 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 46 | rb.Push(RESULT_SUCCESS); | 47 | rb.Push(RESULT_SUCCESS); |
| 47 | rb.PushCopyObjects(register_event.readable); | 48 | rb.PushCopyObjects(register_event->GetReadableEvent()); |
| 48 | } | 49 | } |
| 49 | 50 | ||
| 50 | Kernel::EventPair register_event; | 51 | std::shared_ptr<Kernel::KEvent> register_event; |
| 51 | }; | 52 | }; |
| 52 | 53 | ||
| 53 | class BtDrv final : public ServiceFramework<BtDrv> { | 54 | class BtDrv final : public ServiceFramework<BtDrv> { |
diff --git a/src/core/hle/service/btm/btm.cpp b/src/core/hle/service/btm/btm.cpp index 38b55300e..9cf2ee92a 100644 --- a/src/core/hle/service/btm/btm.cpp +++ b/src/core/hle/service/btm/btm.cpp | |||
| @@ -8,9 +8,9 @@ | |||
| 8 | #include "core/core.h" | 8 | #include "core/core.h" |
| 9 | #include "core/hle/ipc_helpers.h" | 9 | #include "core/hle/ipc_helpers.h" |
| 10 | #include "core/hle/kernel/hle_ipc.h" | 10 | #include "core/hle/kernel/hle_ipc.h" |
| 11 | #include "core/hle/kernel/k_event.h" | ||
| 12 | #include "core/hle/kernel/k_readable_event.h" | ||
| 11 | #include "core/hle/kernel/kernel.h" | 13 | #include "core/hle/kernel/kernel.h" |
| 12 | #include "core/hle/kernel/readable_event.h" | ||
| 13 | #include "core/hle/kernel/writable_event.h" | ||
| 14 | #include "core/hle/service/btm/btm.h" | 14 | #include "core/hle/service/btm/btm.h" |
| 15 | #include "core/hle/service/service.h" | 15 | #include "core/hle/service/service.h" |
| 16 | 16 | ||
| @@ -58,12 +58,14 @@ public: | |||
| 58 | RegisterHandlers(functions); | 58 | RegisterHandlers(functions); |
| 59 | 59 | ||
| 60 | auto& kernel = system.Kernel(); | 60 | auto& kernel = system.Kernel(); |
| 61 | scan_event = Kernel::WritableEvent::CreateEventPair(kernel, "IBtmUserCore:ScanEvent"); | 61 | scan_event = Kernel::KEvent::Create(kernel, "IBtmUserCore:ScanEvent"); |
| 62 | connection_event = | 62 | scan_event->Initialize(); |
| 63 | Kernel::WritableEvent::CreateEventPair(kernel, "IBtmUserCore:ConnectionEvent"); | 63 | connection_event = Kernel::KEvent::Create(kernel, "IBtmUserCore:ConnectionEvent"); |
| 64 | service_discovery = | 64 | connection_event->Initialize(); |
| 65 | Kernel::WritableEvent::CreateEventPair(kernel, "IBtmUserCore:Discovery"); | 65 | service_discovery = Kernel::KEvent::Create(kernel, "IBtmUserCore:Discovery"); |
| 66 | config_event = Kernel::WritableEvent::CreateEventPair(kernel, "IBtmUserCore:ConfigEvent"); | 66 | service_discovery->Initialize(); |
| 67 | config_event = Kernel::KEvent::Create(kernel, "IBtmUserCore:ConfigEvent"); | ||
| 68 | config_event->Initialize(); | ||
| 67 | } | 69 | } |
| 68 | 70 | ||
| 69 | private: | 71 | private: |
| @@ -72,7 +74,7 @@ private: | |||
| 72 | 74 | ||
| 73 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 75 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 74 | rb.Push(RESULT_SUCCESS); | 76 | rb.Push(RESULT_SUCCESS); |
| 75 | rb.PushCopyObjects(scan_event.readable); | 77 | rb.PushCopyObjects(scan_event->GetReadableEvent()); |
| 76 | } | 78 | } |
| 77 | 79 | ||
| 78 | void AcquireBleConnectionEvent(Kernel::HLERequestContext& ctx) { | 80 | void AcquireBleConnectionEvent(Kernel::HLERequestContext& ctx) { |
| @@ -80,7 +82,7 @@ private: | |||
| 80 | 82 | ||
| 81 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 83 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 82 | rb.Push(RESULT_SUCCESS); | 84 | rb.Push(RESULT_SUCCESS); |
| 83 | rb.PushCopyObjects(connection_event.readable); | 85 | rb.PushCopyObjects(connection_event->GetReadableEvent()); |
| 84 | } | 86 | } |
| 85 | 87 | ||
| 86 | void AcquireBleServiceDiscoveryEvent(Kernel::HLERequestContext& ctx) { | 88 | void AcquireBleServiceDiscoveryEvent(Kernel::HLERequestContext& ctx) { |
| @@ -88,7 +90,7 @@ private: | |||
| 88 | 90 | ||
| 89 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 91 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 90 | rb.Push(RESULT_SUCCESS); | 92 | rb.Push(RESULT_SUCCESS); |
| 91 | rb.PushCopyObjects(service_discovery.readable); | 93 | rb.PushCopyObjects(service_discovery->GetReadableEvent()); |
| 92 | } | 94 | } |
| 93 | 95 | ||
| 94 | void AcquireBleMtuConfigEvent(Kernel::HLERequestContext& ctx) { | 96 | void AcquireBleMtuConfigEvent(Kernel::HLERequestContext& ctx) { |
| @@ -96,13 +98,13 @@ private: | |||
| 96 | 98 | ||
| 97 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 99 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 98 | rb.Push(RESULT_SUCCESS); | 100 | rb.Push(RESULT_SUCCESS); |
| 99 | rb.PushCopyObjects(config_event.readable); | 101 | rb.PushCopyObjects(config_event->GetReadableEvent()); |
| 100 | } | 102 | } |
| 101 | 103 | ||
| 102 | Kernel::EventPair scan_event; | 104 | std::shared_ptr<Kernel::KEvent> scan_event; |
| 103 | Kernel::EventPair connection_event; | 105 | std::shared_ptr<Kernel::KEvent> connection_event; |
| 104 | Kernel::EventPair service_discovery; | 106 | std::shared_ptr<Kernel::KEvent> service_discovery; |
| 105 | Kernel::EventPair config_event; | 107 | std::shared_ptr<Kernel::KEvent> config_event; |
| 106 | }; | 108 | }; |
| 107 | 109 | ||
| 108 | class BTM_USR final : public ServiceFramework<BTM_USR> { | 110 | class BTM_USR final : public ServiceFramework<BTM_USR> { |
diff --git a/src/core/hle/service/friend/friend.cpp b/src/core/hle/service/friend/friend.cpp index c5b053c31..72a877d68 100644 --- a/src/core/hle/service/friend/friend.cpp +++ b/src/core/hle/service/friend/friend.cpp | |||
| @@ -7,8 +7,9 @@ | |||
| 7 | #include "common/uuid.h" | 7 | #include "common/uuid.h" |
| 8 | #include "core/core.h" | 8 | #include "core/core.h" |
| 9 | #include "core/hle/ipc_helpers.h" | 9 | #include "core/hle/ipc_helpers.h" |
| 10 | #include "core/hle/kernel/readable_event.h" | 10 | #include "core/hle/kernel/k_event.h" |
| 11 | #include "core/hle/kernel/writable_event.h" | 11 | #include "core/hle/kernel/k_readable_event.h" |
| 12 | #include "core/hle/kernel/k_writable_event.h" | ||
| 12 | #include "core/hle/service/friend/errors.h" | 13 | #include "core/hle/service/friend/errors.h" |
| 13 | #include "core/hle/service/friend/friend.h" | 14 | #include "core/hle/service/friend/friend.h" |
| 14 | #include "core/hle/service/friend/interface.h" | 15 | #include "core/hle/service/friend/interface.h" |
| @@ -183,8 +184,9 @@ public: | |||
| 183 | 184 | ||
| 184 | RegisterHandlers(functions); | 185 | RegisterHandlers(functions); |
| 185 | 186 | ||
| 186 | notification_event = Kernel::WritableEvent::CreateEventPair( | 187 | notification_event = |
| 187 | system.Kernel(), "INotificationService:NotifyEvent"); | 188 | Kernel::KEvent::Create(system.Kernel(), "INotificationService:NotifyEvent"); |
| 189 | notification_event->Initialize(); | ||
| 188 | } | 190 | } |
| 189 | 191 | ||
| 190 | private: | 192 | private: |
| @@ -193,7 +195,7 @@ private: | |||
| 193 | 195 | ||
| 194 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 196 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 195 | rb.Push(RESULT_SUCCESS); | 197 | rb.Push(RESULT_SUCCESS); |
| 196 | rb.PushCopyObjects(notification_event.readable); | 198 | rb.PushCopyObjects(notification_event->GetReadableEvent()); |
| 197 | } | 199 | } |
| 198 | 200 | ||
| 199 | void Clear(Kernel::HLERequestContext& ctx) { | 201 | void Clear(Kernel::HLERequestContext& ctx) { |
| @@ -258,7 +260,7 @@ private: | |||
| 258 | }; | 260 | }; |
| 259 | 261 | ||
| 260 | Common::UUID uuid{Common::INVALID_UUID}; | 262 | Common::UUID uuid{Common::INVALID_UUID}; |
| 261 | Kernel::EventPair notification_event; | 263 | std::shared_ptr<Kernel::KEvent> notification_event; |
| 262 | std::queue<SizedNotificationInfo> notifications; | 264 | std::queue<SizedNotificationInfo> notifications; |
| 263 | States states{}; | 265 | States states{}; |
| 264 | }; | 266 | }; |
diff --git a/src/core/hle/service/hid/controllers/npad.cpp b/src/core/hle/service/hid/controllers/npad.cpp index 0c227b135..5794f417c 100644 --- a/src/core/hle/service/hid/controllers/npad.cpp +++ b/src/core/hle/service/hid/controllers/npad.cpp | |||
| @@ -12,9 +12,10 @@ | |||
| 12 | #include "core/core.h" | 12 | #include "core/core.h" |
| 13 | #include "core/core_timing.h" | 13 | #include "core/core_timing.h" |
| 14 | #include "core/frontend/input.h" | 14 | #include "core/frontend/input.h" |
| 15 | #include "core/hle/kernel/k_event.h" | ||
| 16 | #include "core/hle/kernel/k_readable_event.h" | ||
| 17 | #include "core/hle/kernel/k_writable_event.h" | ||
| 15 | #include "core/hle/kernel/kernel.h" | 18 | #include "core/hle/kernel/kernel.h" |
| 16 | #include "core/hle/kernel/readable_event.h" | ||
| 17 | #include "core/hle/kernel/writable_event.h" | ||
| 18 | #include "core/hle/service/hid/controllers/npad.h" | 19 | #include "core/hle/service/hid/controllers/npad.h" |
| 19 | #include "core/settings.h" | 20 | #include "core/settings.h" |
| 20 | 21 | ||
| @@ -153,7 +154,7 @@ void Controller_NPad::InitNewlyAddedController(std::size_t controller_idx) { | |||
| 153 | const auto controller_type = connected_controllers[controller_idx].type; | 154 | const auto controller_type = connected_controllers[controller_idx].type; |
| 154 | auto& controller = shared_memory_entries[controller_idx]; | 155 | auto& controller = shared_memory_entries[controller_idx]; |
| 155 | if (controller_type == NPadControllerType::None) { | 156 | if (controller_type == NPadControllerType::None) { |
| 156 | styleset_changed_events[controller_idx].writable->Signal(); | 157 | styleset_changed_events[controller_idx]->GetWritableEvent()->Signal(); |
| 157 | return; | 158 | return; |
| 158 | } | 159 | } |
| 159 | controller.joy_styles.raw = 0; // Zero out | 160 | controller.joy_styles.raw = 0; // Zero out |
| @@ -233,8 +234,9 @@ void Controller_NPad::InitNewlyAddedController(std::size_t controller_idx) { | |||
| 233 | void Controller_NPad::OnInit() { | 234 | void Controller_NPad::OnInit() { |
| 234 | auto& kernel = system.Kernel(); | 235 | auto& kernel = system.Kernel(); |
| 235 | for (std::size_t i = 0; i < styleset_changed_events.size(); ++i) { | 236 | for (std::size_t i = 0; i < styleset_changed_events.size(); ++i) { |
| 236 | styleset_changed_events[i] = Kernel::WritableEvent::CreateEventPair( | 237 | styleset_changed_events[i] = |
| 237 | kernel, fmt::format("npad:NpadStyleSetChanged_{}", i)); | 238 | Kernel::KEvent::Create(kernel, fmt::format("npad:NpadStyleSetChanged_{}", i)); |
| 239 | styleset_changed_events[i]->Initialize(); | ||
| 238 | } | 240 | } |
| 239 | 241 | ||
| 240 | if (!IsControllerActivated()) { | 242 | if (!IsControllerActivated()) { |
| @@ -872,13 +874,14 @@ bool Controller_NPad::IsVibrationDeviceMounted(const DeviceHandle& vibration_dev | |||
| 872 | return vibration_devices_mounted[npad_index][device_index]; | 874 | return vibration_devices_mounted[npad_index][device_index]; |
| 873 | } | 875 | } |
| 874 | 876 | ||
| 875 | std::shared_ptr<Kernel::ReadableEvent> Controller_NPad::GetStyleSetChangedEvent(u32 npad_id) const { | 877 | std::shared_ptr<Kernel::KReadableEvent> Controller_NPad::GetStyleSetChangedEvent( |
| 878 | u32 npad_id) const { | ||
| 876 | const auto& styleset_event = styleset_changed_events[NPadIdToIndex(npad_id)]; | 879 | const auto& styleset_event = styleset_changed_events[NPadIdToIndex(npad_id)]; |
| 877 | return styleset_event.readable; | 880 | return styleset_event->GetReadableEvent(); |
| 878 | } | 881 | } |
| 879 | 882 | ||
| 880 | void Controller_NPad::SignalStyleSetChangedEvent(u32 npad_id) const { | 883 | void Controller_NPad::SignalStyleSetChangedEvent(u32 npad_id) const { |
| 881 | styleset_changed_events[NPadIdToIndex(npad_id)].writable->Signal(); | 884 | styleset_changed_events[NPadIdToIndex(npad_id)]->GetWritableEvent()->Signal(); |
| 882 | } | 885 | } |
| 883 | 886 | ||
| 884 | void Controller_NPad::AddNewControllerAt(NPadControllerType controller, std::size_t npad_index) { | 887 | void Controller_NPad::AddNewControllerAt(NPadControllerType controller, std::size_t npad_index) { |
diff --git a/src/core/hle/service/hid/controllers/npad.h b/src/core/hle/service/hid/controllers/npad.h index 2e13922b9..1a65b19f5 100644 --- a/src/core/hle/service/hid/controllers/npad.h +++ b/src/core/hle/service/hid/controllers/npad.h | |||
| @@ -10,10 +10,14 @@ | |||
| 10 | #include "common/common_types.h" | 10 | #include "common/common_types.h" |
| 11 | #include "core/frontend/input.h" | 11 | #include "core/frontend/input.h" |
| 12 | #include "core/hle/kernel/object.h" | 12 | #include "core/hle/kernel/object.h" |
| 13 | #include "core/hle/kernel/writable_event.h" | ||
| 14 | #include "core/hle/service/hid/controllers/controller_base.h" | 13 | #include "core/hle/service/hid/controllers/controller_base.h" |
| 15 | #include "core/settings.h" | 14 | #include "core/settings.h" |
| 16 | 15 | ||
| 16 | namespace Kernel { | ||
| 17 | class KEvent; | ||
| 18 | class KReadableEvent; | ||
| 19 | } // namespace Kernel | ||
| 20 | |||
| 17 | namespace Service::HID { | 21 | namespace Service::HID { |
| 18 | 22 | ||
| 19 | constexpr u32 NPAD_HANDHELD = 32; | 23 | constexpr u32 NPAD_HANDHELD = 32; |
| @@ -187,7 +191,7 @@ public: | |||
| 187 | 191 | ||
| 188 | bool IsVibrationDeviceMounted(const DeviceHandle& vibration_device_handle) const; | 192 | bool IsVibrationDeviceMounted(const DeviceHandle& vibration_device_handle) const; |
| 189 | 193 | ||
| 190 | std::shared_ptr<Kernel::ReadableEvent> GetStyleSetChangedEvent(u32 npad_id) const; | 194 | std::shared_ptr<Kernel::KReadableEvent> GetStyleSetChangedEvent(u32 npad_id) const; |
| 191 | void SignalStyleSetChangedEvent(u32 npad_id) const; | 195 | void SignalStyleSetChangedEvent(u32 npad_id) const; |
| 192 | 196 | ||
| 193 | // Adds a new controller at an index. | 197 | // Adds a new controller at an index. |
| @@ -452,7 +456,7 @@ private: | |||
| 452 | // NpadCommunicationMode is unknown, default value is 1 | 456 | // NpadCommunicationMode is unknown, default value is 1 |
| 453 | NpadCommunicationMode communication_mode{NpadCommunicationMode::Unknown1}; | 457 | NpadCommunicationMode communication_mode{NpadCommunicationMode::Unknown1}; |
| 454 | // Each controller should have their own styleset changed event | 458 | // Each controller should have their own styleset changed event |
| 455 | std::array<Kernel::EventPair, 10> styleset_changed_events; | 459 | std::array<std::shared_ptr<Kernel::KEvent>, 10> styleset_changed_events; |
| 456 | std::array<std::array<std::chrono::steady_clock::time_point, 2>, 10> last_vibration_timepoints; | 460 | std::array<std::array<std::chrono::steady_clock::time_point, 2>, 10> last_vibration_timepoints; |
| 457 | std::array<std::array<VibrationValue, 2>, 10> latest_vibration_values{}; | 461 | std::array<std::array<VibrationValue, 2>, 10> latest_vibration_values{}; |
| 458 | bool permit_vibration_session_enabled{false}; | 462 | bool permit_vibration_session_enabled{false}; |
diff --git a/src/core/hle/service/hid/hid.cpp b/src/core/hle/service/hid/hid.cpp index 4cee4838c..dda33f2b4 100644 --- a/src/core/hle/service/hid/hid.cpp +++ b/src/core/hle/service/hid/hid.cpp | |||
| @@ -14,10 +14,10 @@ | |||
| 14 | #include "core/hle/ipc_helpers.h" | 14 | #include "core/hle/ipc_helpers.h" |
| 15 | #include "core/hle/kernel/client_port.h" | 15 | #include "core/hle/kernel/client_port.h" |
| 16 | #include "core/hle/kernel/client_session.h" | 16 | #include "core/hle/kernel/client_session.h" |
| 17 | #include "core/hle/kernel/k_readable_event.h" | ||
| 18 | #include "core/hle/kernel/k_writable_event.h" | ||
| 17 | #include "core/hle/kernel/kernel.h" | 19 | #include "core/hle/kernel/kernel.h" |
| 18 | #include "core/hle/kernel/readable_event.h" | ||
| 19 | #include "core/hle/kernel/shared_memory.h" | 20 | #include "core/hle/kernel/shared_memory.h" |
| 20 | #include "core/hle/kernel/writable_event.h" | ||
| 21 | #include "core/hle/service/hid/errors.h" | 21 | #include "core/hle/service/hid/errors.h" |
| 22 | #include "core/hle/service/hid/hid.h" | 22 | #include "core/hle/service/hid/hid.h" |
| 23 | #include "core/hle/service/hid/irs.h" | 23 | #include "core/hle/service/hid/irs.h" |
diff --git a/src/core/hle/service/nfp/nfp.cpp b/src/core/hle/service/nfp/nfp.cpp index a515fdc60..5d6d25696 100644 --- a/src/core/hle/service/nfp/nfp.cpp +++ b/src/core/hle/service/nfp/nfp.cpp | |||
| @@ -8,10 +8,11 @@ | |||
| 8 | #include "common/logging/log.h" | 8 | #include "common/logging/log.h" |
| 9 | #include "core/core.h" | 9 | #include "core/core.h" |
| 10 | #include "core/hle/ipc_helpers.h" | 10 | #include "core/hle/ipc_helpers.h" |
| 11 | #include "core/hle/kernel/k_event.h" | ||
| 12 | #include "core/hle/kernel/k_readable_event.h" | ||
| 11 | #include "core/hle/kernel/k_thread.h" | 13 | #include "core/hle/kernel/k_thread.h" |
| 14 | #include "core/hle/kernel/k_writable_event.h" | ||
| 12 | #include "core/hle/kernel/kernel.h" | 15 | #include "core/hle/kernel/kernel.h" |
| 13 | #include "core/hle/kernel/readable_event.h" | ||
| 14 | #include "core/hle/kernel/writable_event.h" | ||
| 15 | #include "core/hle/lock.h" | 16 | #include "core/hle/lock.h" |
| 16 | #include "core/hle/service/nfp/nfp.h" | 17 | #include "core/hle/service/nfp/nfp.h" |
| 17 | #include "core/hle/service/nfp/nfp_user.h" | 18 | #include "core/hle/service/nfp/nfp_user.h" |
| @@ -25,7 +26,8 @@ Module::Interface::Interface(std::shared_ptr<Module> module_, Core::System& syst | |||
| 25 | const char* name) | 26 | const char* name) |
| 26 | : ServiceFramework{system_, name}, module{std::move(module_)} { | 27 | : ServiceFramework{system_, name}, module{std::move(module_)} { |
| 27 | auto& kernel = system.Kernel(); | 28 | auto& kernel = system.Kernel(); |
| 28 | nfc_tag_load = Kernel::WritableEvent::CreateEventPair(kernel, "IUser:NFCTagDetected"); | 29 | nfc_tag_load = Kernel::KEvent::Create(kernel, "IUser:NFCTagDetected"); |
| 30 | nfc_tag_load->Initialize(); | ||
| 29 | } | 31 | } |
| 30 | 32 | ||
| 31 | Module::Interface::~Interface() = default; | 33 | Module::Interface::~Interface() = default; |
| @@ -64,9 +66,10 @@ public: | |||
| 64 | RegisterHandlers(functions); | 66 | RegisterHandlers(functions); |
| 65 | 67 | ||
| 66 | auto& kernel = system.Kernel(); | 68 | auto& kernel = system.Kernel(); |
| 67 | deactivate_event = Kernel::WritableEvent::CreateEventPair(kernel, "IUser:DeactivateEvent"); | 69 | deactivate_event = Kernel::KEvent::Create(kernel, "IUser:DeactivateEvent"); |
| 68 | availability_change_event = | 70 | deactivate_event->Initialize(); |
| 69 | Kernel::WritableEvent::CreateEventPair(kernel, "IUser:AvailabilityChangeEvent"); | 71 | availability_change_event = Kernel::KEvent::Create(kernel, "IUser:AvailabilityChangeEvent"); |
| 72 | availability_change_event->Initialize(); | ||
| 70 | } | 73 | } |
| 71 | 74 | ||
| 72 | private: | 75 | private: |
| @@ -164,7 +167,7 @@ private: | |||
| 164 | 167 | ||
| 165 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 168 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 166 | rb.Push(RESULT_SUCCESS); | 169 | rb.Push(RESULT_SUCCESS); |
| 167 | rb.PushCopyObjects(deactivate_event.readable); | 170 | rb.PushCopyObjects(deactivate_event->GetReadableEvent()); |
| 168 | } | 171 | } |
| 169 | 172 | ||
| 170 | void StopDetection(Kernel::HLERequestContext& ctx) { | 173 | void StopDetection(Kernel::HLERequestContext& ctx) { |
| @@ -173,7 +176,7 @@ private: | |||
| 173 | switch (device_state) { | 176 | switch (device_state) { |
| 174 | case DeviceState::TagFound: | 177 | case DeviceState::TagFound: |
| 175 | case DeviceState::TagNearby: | 178 | case DeviceState::TagNearby: |
| 176 | deactivate_event.writable->Signal(); | 179 | deactivate_event->GetWritableEvent()->Signal(); |
| 177 | device_state = DeviceState::Initialized; | 180 | device_state = DeviceState::Initialized; |
| 178 | break; | 181 | break; |
| 179 | case DeviceState::SearchingForTag: | 182 | case DeviceState::SearchingForTag: |
| @@ -262,7 +265,7 @@ private: | |||
| 262 | 265 | ||
| 263 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 266 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 264 | rb.Push(RESULT_SUCCESS); | 267 | rb.Push(RESULT_SUCCESS); |
| 265 | rb.PushCopyObjects(availability_change_event.readable); | 268 | rb.PushCopyObjects(availability_change_event->GetReadableEvent()); |
| 266 | } | 269 | } |
| 267 | 270 | ||
| 268 | void GetRegisterInfo(Kernel::HLERequestContext& ctx) { | 271 | void GetRegisterInfo(Kernel::HLERequestContext& ctx) { |
| @@ -316,8 +319,8 @@ private: | |||
| 316 | const u32 npad_id{0}; // Player 1 controller | 319 | const u32 npad_id{0}; // Player 1 controller |
| 317 | State state{State::NonInitialized}; | 320 | State state{State::NonInitialized}; |
| 318 | DeviceState device_state{DeviceState::Initialized}; | 321 | DeviceState device_state{DeviceState::Initialized}; |
| 319 | Kernel::EventPair deactivate_event; | 322 | std::shared_ptr<Kernel::KEvent> deactivate_event; |
| 320 | Kernel::EventPair availability_change_event; | 323 | std::shared_ptr<Kernel::KEvent> availability_change_event; |
| 321 | const Module::Interface& nfp_interface; | 324 | const Module::Interface& nfp_interface; |
| 322 | }; | 325 | }; |
| 323 | 326 | ||
| @@ -336,12 +339,12 @@ bool Module::Interface::LoadAmiibo(const std::vector<u8>& buffer) { | |||
| 336 | } | 339 | } |
| 337 | 340 | ||
| 338 | std::memcpy(&amiibo, buffer.data(), sizeof(amiibo)); | 341 | std::memcpy(&amiibo, buffer.data(), sizeof(amiibo)); |
| 339 | nfc_tag_load.writable->Signal(); | 342 | nfc_tag_load->GetWritableEvent()->Signal(); |
| 340 | return true; | 343 | return true; |
| 341 | } | 344 | } |
| 342 | 345 | ||
| 343 | const std::shared_ptr<Kernel::ReadableEvent>& Module::Interface::GetNFCEvent() const { | 346 | const std::shared_ptr<Kernel::KReadableEvent>& Module::Interface::GetNFCEvent() const { |
| 344 | return nfc_tag_load.readable; | 347 | return nfc_tag_load->GetReadableEvent(); |
| 345 | } | 348 | } |
| 346 | 349 | ||
| 347 | const Module::Interface::AmiiboFile& Module::Interface::GetAmiiboBuffer() const { | 350 | const Module::Interface::AmiiboFile& Module::Interface::GetAmiiboBuffer() const { |
diff --git a/src/core/hle/service/nfp/nfp.h b/src/core/hle/service/nfp/nfp.h index 295de535b..c46551760 100644 --- a/src/core/hle/service/nfp/nfp.h +++ b/src/core/hle/service/nfp/nfp.h | |||
| @@ -6,10 +6,13 @@ | |||
| 6 | 6 | ||
| 7 | #include <array> | 7 | #include <array> |
| 8 | #include <vector> | 8 | #include <vector> |
| 9 | #include "core/hle/kernel/readable_event.h" | 9 | |
| 10 | #include "core/hle/kernel/writable_event.h" | ||
| 11 | #include "core/hle/service/service.h" | 10 | #include "core/hle/service/service.h" |
| 12 | 11 | ||
| 12 | namespace Kernel { | ||
| 13 | class KEvent; | ||
| 14 | } | ||
| 15 | |||
| 13 | namespace Service::NFP { | 16 | namespace Service::NFP { |
| 14 | 17 | ||
| 15 | class Module final { | 18 | class Module final { |
| @@ -35,11 +38,11 @@ public: | |||
| 35 | 38 | ||
| 36 | void CreateUserInterface(Kernel::HLERequestContext& ctx); | 39 | void CreateUserInterface(Kernel::HLERequestContext& ctx); |
| 37 | bool LoadAmiibo(const std::vector<u8>& buffer); | 40 | bool LoadAmiibo(const std::vector<u8>& buffer); |
| 38 | const std::shared_ptr<Kernel::ReadableEvent>& GetNFCEvent() const; | 41 | const std::shared_ptr<Kernel::KReadableEvent>& GetNFCEvent() const; |
| 39 | const AmiiboFile& GetAmiiboBuffer() const; | 42 | const AmiiboFile& GetAmiiboBuffer() const; |
| 40 | 43 | ||
| 41 | private: | 44 | private: |
| 42 | Kernel::EventPair nfc_tag_load{}; | 45 | std::shared_ptr<Kernel::KEvent> nfc_tag_load; |
| 43 | AmiiboFile amiibo{}; | 46 | AmiiboFile amiibo{}; |
| 44 | 47 | ||
| 45 | protected: | 48 | protected: |
diff --git a/src/core/hle/service/nifm/nifm.cpp b/src/core/hle/service/nifm/nifm.cpp index 8372e170c..afb3342d6 100644 --- a/src/core/hle/service/nifm/nifm.cpp +++ b/src/core/hle/service/nifm/nifm.cpp | |||
| @@ -4,9 +4,9 @@ | |||
| 4 | 4 | ||
| 5 | #include "core/core.h" | 5 | #include "core/core.h" |
| 6 | #include "core/hle/ipc_helpers.h" | 6 | #include "core/hle/ipc_helpers.h" |
| 7 | #include "core/hle/kernel/k_event.h" | ||
| 8 | #include "core/hle/kernel/k_readable_event.h" | ||
| 7 | #include "core/hle/kernel/kernel.h" | 9 | #include "core/hle/kernel/kernel.h" |
| 8 | #include "core/hle/kernel/readable_event.h" | ||
| 9 | #include "core/hle/kernel/writable_event.h" | ||
| 10 | #include "core/hle/service/nifm/nifm.h" | 10 | #include "core/hle/service/nifm/nifm.h" |
| 11 | #include "core/hle/service/service.h" | 11 | #include "core/hle/service/service.h" |
| 12 | #include "core/network/network.h" | 12 | #include "core/network/network.h" |
| @@ -158,8 +158,11 @@ public: | |||
| 158 | RegisterHandlers(functions); | 158 | RegisterHandlers(functions); |
| 159 | 159 | ||
| 160 | auto& kernel = system.Kernel(); | 160 | auto& kernel = system.Kernel(); |
| 161 | event1 = Kernel::WritableEvent::CreateEventPair(kernel, "IRequest:Event1"); | 161 | |
| 162 | event2 = Kernel::WritableEvent::CreateEventPair(kernel, "IRequest:Event2"); | 162 | event1 = Kernel::KEvent::Create(kernel, "IRequest:Event1"); |
| 163 | event1->Initialize(); | ||
| 164 | event2 = Kernel::KEvent::Create(kernel, "IRequest:Event2"); | ||
| 165 | event2->Initialize(); | ||
| 163 | } | 166 | } |
| 164 | 167 | ||
| 165 | private: | 168 | private: |
| @@ -195,7 +198,7 @@ private: | |||
| 195 | 198 | ||
| 196 | IPC::ResponseBuilder rb{ctx, 2, 2}; | 199 | IPC::ResponseBuilder rb{ctx, 2, 2}; |
| 197 | rb.Push(RESULT_SUCCESS); | 200 | rb.Push(RESULT_SUCCESS); |
| 198 | rb.PushCopyObjects(event1.readable, event2.readable); | 201 | rb.PushCopyObjects(event1->GetReadableEvent(), event2->GetReadableEvent()); |
| 199 | } | 202 | } |
| 200 | 203 | ||
| 201 | void Cancel(Kernel::HLERequestContext& ctx) { | 204 | void Cancel(Kernel::HLERequestContext& ctx) { |
| @@ -226,7 +229,7 @@ private: | |||
| 226 | rb.Push<u32>(0); | 229 | rb.Push<u32>(0); |
| 227 | } | 230 | } |
| 228 | 231 | ||
| 229 | Kernel::EventPair event1, event2; | 232 | std::shared_ptr<Kernel::KEvent> event1, event2; |
| 230 | }; | 233 | }; |
| 231 | 234 | ||
| 232 | class INetworkProfile final : public ServiceFramework<INetworkProfile> { | 235 | class INetworkProfile final : public ServiceFramework<INetworkProfile> { |
diff --git a/src/core/hle/service/nim/nim.cpp b/src/core/hle/service/nim/nim.cpp index d16223064..f3be0b878 100644 --- a/src/core/hle/service/nim/nim.cpp +++ b/src/core/hle/service/nim/nim.cpp | |||
| @@ -6,9 +6,10 @@ | |||
| 6 | #include <ctime> | 6 | #include <ctime> |
| 7 | #include "core/core.h" | 7 | #include "core/core.h" |
| 8 | #include "core/hle/ipc_helpers.h" | 8 | #include "core/hle/ipc_helpers.h" |
| 9 | #include "core/hle/kernel/k_event.h" | ||
| 10 | #include "core/hle/kernel/k_readable_event.h" | ||
| 11 | #include "core/hle/kernel/k_writable_event.h" | ||
| 9 | #include "core/hle/kernel/kernel.h" | 12 | #include "core/hle/kernel/kernel.h" |
| 10 | #include "core/hle/kernel/readable_event.h" | ||
| 11 | #include "core/hle/kernel/writable_event.h" | ||
| 12 | #include "core/hle/service/nim/nim.h" | 13 | #include "core/hle/service/nim/nim.h" |
| 13 | #include "core/hle/service/service.h" | 14 | #include "core/hle/service/service.h" |
| 14 | #include "core/hle/service/sm/sm.h" | 15 | #include "core/hle/service/sm/sm.h" |
| @@ -301,17 +302,18 @@ public: | |||
| 301 | RegisterHandlers(functions); | 302 | RegisterHandlers(functions); |
| 302 | 303 | ||
| 303 | auto& kernel = system.Kernel(); | 304 | auto& kernel = system.Kernel(); |
| 304 | finished_event = Kernel::WritableEvent::CreateEventPair( | 305 | finished_event = |
| 305 | kernel, "IEnsureNetworkClockAvailabilityService:FinishEvent"); | 306 | Kernel::KEvent::Create(kernel, "IEnsureNetworkClockAvailabilityService:FinishEvent"); |
| 307 | finished_event->Initialize(); | ||
| 306 | } | 308 | } |
| 307 | 309 | ||
| 308 | private: | 310 | private: |
| 309 | Kernel::EventPair finished_event; | 311 | std::shared_ptr<Kernel::KEvent> finished_event; |
| 310 | 312 | ||
| 311 | void StartTask(Kernel::HLERequestContext& ctx) { | 313 | void StartTask(Kernel::HLERequestContext& ctx) { |
| 312 | // No need to connect to the internet, just finish the task straight away. | 314 | // No need to connect to the internet, just finish the task straight away. |
| 313 | LOG_DEBUG(Service_NIM, "called"); | 315 | LOG_DEBUG(Service_NIM, "called"); |
| 314 | finished_event.writable->Signal(); | 316 | finished_event->GetWritableEvent()->Signal(); |
| 315 | IPC::ResponseBuilder rb{ctx, 2}; | 317 | IPC::ResponseBuilder rb{ctx, 2}; |
| 316 | rb.Push(RESULT_SUCCESS); | 318 | rb.Push(RESULT_SUCCESS); |
| 317 | } | 319 | } |
| @@ -321,7 +323,7 @@ private: | |||
| 321 | 323 | ||
| 322 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 324 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 323 | rb.Push(RESULT_SUCCESS); | 325 | rb.Push(RESULT_SUCCESS); |
| 324 | rb.PushCopyObjects(finished_event.readable); | 326 | rb.PushCopyObjects(finished_event->GetReadableEvent()); |
| 325 | } | 327 | } |
| 326 | 328 | ||
| 327 | void GetResult(Kernel::HLERequestContext& ctx) { | 329 | void GetResult(Kernel::HLERequestContext& ctx) { |
| @@ -333,7 +335,7 @@ private: | |||
| 333 | 335 | ||
| 334 | void Cancel(Kernel::HLERequestContext& ctx) { | 336 | void Cancel(Kernel::HLERequestContext& ctx) { |
| 335 | LOG_DEBUG(Service_NIM, "called"); | 337 | LOG_DEBUG(Service_NIM, "called"); |
| 336 | finished_event.writable->Clear(); | 338 | finished_event->GetWritableEvent()->Clear(); |
| 337 | IPC::ResponseBuilder rb{ctx, 2}; | 339 | IPC::ResponseBuilder rb{ctx, 2}; |
| 338 | rb.Push(RESULT_SUCCESS); | 340 | rb.Push(RESULT_SUCCESS); |
| 339 | } | 341 | } |
diff --git a/src/core/hle/service/nvdrv/devices/nvhost_ctrl.cpp b/src/core/hle/service/nvdrv/devices/nvhost_ctrl.cpp index 060599bab..f6129ef10 100644 --- a/src/core/hle/service/nvdrv/devices/nvhost_ctrl.cpp +++ b/src/core/hle/service/nvdrv/devices/nvhost_ctrl.cpp | |||
| @@ -8,8 +8,8 @@ | |||
| 8 | #include "common/assert.h" | 8 | #include "common/assert.h" |
| 9 | #include "common/logging/log.h" | 9 | #include "common/logging/log.h" |
| 10 | #include "core/core.h" | 10 | #include "core/core.h" |
| 11 | #include "core/hle/kernel/readable_event.h" | 11 | #include "core/hle/kernel/k_event.h" |
| 12 | #include "core/hle/kernel/writable_event.h" | 12 | #include "core/hle/kernel/k_writable_event.h" |
| 13 | #include "core/hle/service/nvdrv/devices/nvhost_ctrl.h" | 13 | #include "core/hle/service/nvdrv/devices/nvhost_ctrl.h" |
| 14 | #include "video_core/gpu.h" | 14 | #include "video_core/gpu.h" |
| 15 | 15 | ||
| @@ -103,14 +103,14 @@ NvResult nvhost_ctrl::IocCtrlEventWait(const std::vector<u8>& input, std::vector | |||
| 103 | // This is mostly to take into account unimplemented features. As synced | 103 | // This is mostly to take into account unimplemented features. As synced |
| 104 | // gpu is always synced. | 104 | // gpu is always synced. |
| 105 | if (!gpu.IsAsync()) { | 105 | if (!gpu.IsAsync()) { |
| 106 | event.event.writable->Signal(); | 106 | event.event->GetWritableEvent()->Signal(); |
| 107 | return NvResult::Success; | 107 | return NvResult::Success; |
| 108 | } | 108 | } |
| 109 | auto lock = gpu.LockSync(); | 109 | auto lock = gpu.LockSync(); |
| 110 | const u32 current_syncpoint_value = event.fence.value; | 110 | const u32 current_syncpoint_value = event.fence.value; |
| 111 | const s32 diff = current_syncpoint_value - params.threshold; | 111 | const s32 diff = current_syncpoint_value - params.threshold; |
| 112 | if (diff >= 0) { | 112 | if (diff >= 0) { |
| 113 | event.event.writable->Signal(); | 113 | event.event->GetWritableEvent()->Signal(); |
| 114 | params.value = current_syncpoint_value; | 114 | params.value = current_syncpoint_value; |
| 115 | std::memcpy(output.data(), ¶ms, sizeof(params)); | 115 | std::memcpy(output.data(), ¶ms, sizeof(params)); |
| 116 | return NvResult::Success; | 116 | return NvResult::Success; |
| @@ -137,7 +137,7 @@ NvResult nvhost_ctrl::IocCtrlEventWait(const std::vector<u8>& input, std::vector | |||
| 137 | params.value = ((params.syncpt_id & 0xfff) << 16) | 0x10000000; | 137 | params.value = ((params.syncpt_id & 0xfff) << 16) | 0x10000000; |
| 138 | } | 138 | } |
| 139 | params.value |= event_id; | 139 | params.value |= event_id; |
| 140 | event.event.writable->Clear(); | 140 | event.event->GetWritableEvent()->Clear(); |
| 141 | gpu.RegisterSyncptInterrupt(params.syncpt_id, target_value); | 141 | gpu.RegisterSyncptInterrupt(params.syncpt_id, target_value); |
| 142 | std::memcpy(output.data(), ¶ms, sizeof(params)); | 142 | std::memcpy(output.data(), ¶ms, sizeof(params)); |
| 143 | return NvResult::Timeout; | 143 | return NvResult::Timeout; |
diff --git a/src/core/hle/service/nvdrv/interface.cpp b/src/core/hle/service/nvdrv/interface.cpp index 1328b64d0..2e1150867 100644 --- a/src/core/hle/service/nvdrv/interface.cpp +++ b/src/core/hle/service/nvdrv/interface.cpp | |||
| @@ -6,10 +6,10 @@ | |||
| 6 | #include "common/logging/log.h" | 6 | #include "common/logging/log.h" |
| 7 | #include "core/core.h" | 7 | #include "core/core.h" |
| 8 | #include "core/hle/ipc_helpers.h" | 8 | #include "core/hle/ipc_helpers.h" |
| 9 | #include "core/hle/kernel/k_readable_event.h" | ||
| 9 | #include "core/hle/kernel/k_thread.h" | 10 | #include "core/hle/kernel/k_thread.h" |
| 11 | #include "core/hle/kernel/k_writable_event.h" | ||
| 10 | #include "core/hle/kernel/kernel.h" | 12 | #include "core/hle/kernel/kernel.h" |
| 11 | #include "core/hle/kernel/readable_event.h" | ||
| 12 | #include "core/hle/kernel/writable_event.h" | ||
| 13 | #include "core/hle/service/nvdrv/interface.h" | 13 | #include "core/hle/service/nvdrv/interface.h" |
| 14 | #include "core/hle/service/nvdrv/nvdata.h" | 14 | #include "core/hle/service/nvdrv/nvdata.h" |
| 15 | #include "core/hle/service/nvdrv/nvdrv.h" | 15 | #include "core/hle/service/nvdrv/nvdrv.h" |
diff --git a/src/core/hle/service/nvdrv/interface.h b/src/core/hle/service/nvdrv/interface.h index 5c777c59b..0e764c53f 100644 --- a/src/core/hle/service/nvdrv/interface.h +++ b/src/core/hle/service/nvdrv/interface.h | |||
| @@ -9,7 +9,7 @@ | |||
| 9 | #include "core/hle/service/service.h" | 9 | #include "core/hle/service/service.h" |
| 10 | 10 | ||
| 11 | namespace Kernel { | 11 | namespace Kernel { |
| 12 | class WritableEvent; | 12 | class KWritableEvent; |
| 13 | } | 13 | } |
| 14 | 14 | ||
| 15 | namespace Service::Nvidia { | 15 | namespace Service::Nvidia { |
diff --git a/src/core/hle/service/nvdrv/nvdrv.cpp b/src/core/hle/service/nvdrv/nvdrv.cpp index 620c18728..abba80112 100644 --- a/src/core/hle/service/nvdrv/nvdrv.cpp +++ b/src/core/hle/service/nvdrv/nvdrv.cpp | |||
| @@ -7,8 +7,9 @@ | |||
| 7 | #include <fmt/format.h> | 7 | #include <fmt/format.h> |
| 8 | #include "core/core.h" | 8 | #include "core/core.h" |
| 9 | #include "core/hle/ipc_helpers.h" | 9 | #include "core/hle/ipc_helpers.h" |
| 10 | #include "core/hle/kernel/readable_event.h" | 10 | #include "core/hle/kernel/k_event.h" |
| 11 | #include "core/hle/kernel/writable_event.h" | 11 | #include "core/hle/kernel/k_readable_event.h" |
| 12 | #include "core/hle/kernel/k_writable_event.h" | ||
| 12 | #include "core/hle/service/nvdrv/devices/nvdevice.h" | 13 | #include "core/hle/service/nvdrv/devices/nvdevice.h" |
| 13 | #include "core/hle/service/nvdrv/devices/nvdisp_disp0.h" | 14 | #include "core/hle/service/nvdrv/devices/nvdisp_disp0.h" |
| 14 | #include "core/hle/service/nvdrv/devices/nvhost_as_gpu.h" | 15 | #include "core/hle/service/nvdrv/devices/nvhost_as_gpu.h" |
| @@ -42,7 +43,8 @@ Module::Module(Core::System& system) : syncpoint_manager{system.GPU()} { | |||
| 42 | auto& kernel = system.Kernel(); | 43 | auto& kernel = system.Kernel(); |
| 43 | for (u32 i = 0; i < MaxNvEvents; i++) { | 44 | for (u32 i = 0; i < MaxNvEvents; i++) { |
| 44 | std::string event_label = fmt::format("NVDRV::NvEvent_{}", i); | 45 | std::string event_label = fmt::format("NVDRV::NvEvent_{}", i); |
| 45 | events_interface.events[i] = {Kernel::WritableEvent::CreateEventPair(kernel, event_label)}; | 46 | events_interface.events[i] = {Kernel::KEvent::Create(kernel, std::move(event_label))}; |
| 47 | events_interface.events[i].event->Initialize(); | ||
| 46 | events_interface.status[i] = EventState::Free; | 48 | events_interface.status[i] = EventState::Free; |
| 47 | events_interface.registered[i] = false; | 49 | events_interface.registered[i] = false; |
| 48 | } | 50 | } |
| @@ -166,17 +168,17 @@ void Module::SignalSyncpt(const u32 syncpoint_id, const u32 value) { | |||
| 166 | if (events_interface.assigned_syncpt[i] == syncpoint_id && | 168 | if (events_interface.assigned_syncpt[i] == syncpoint_id && |
| 167 | events_interface.assigned_value[i] == value) { | 169 | events_interface.assigned_value[i] == value) { |
| 168 | events_interface.LiberateEvent(i); | 170 | events_interface.LiberateEvent(i); |
| 169 | events_interface.events[i].event.writable->Signal(); | 171 | events_interface.events[i].event->GetWritableEvent()->Signal(); |
| 170 | } | 172 | } |
| 171 | } | 173 | } |
| 172 | } | 174 | } |
| 173 | 175 | ||
| 174 | std::shared_ptr<Kernel::ReadableEvent> Module::GetEvent(const u32 event_id) const { | 176 | std::shared_ptr<Kernel::KReadableEvent> Module::GetEvent(const u32 event_id) const { |
| 175 | return events_interface.events[event_id].event.readable; | 177 | return events_interface.events[event_id].event->GetReadableEvent(); |
| 176 | } | 178 | } |
| 177 | 179 | ||
| 178 | std::shared_ptr<Kernel::WritableEvent> Module::GetEventWriteable(const u32 event_id) const { | 180 | std::shared_ptr<Kernel::KWritableEvent> Module::GetEventWriteable(const u32 event_id) const { |
| 179 | return events_interface.events[event_id].event.writable; | 181 | return events_interface.events[event_id].event->GetWritableEvent(); |
| 180 | } | 182 | } |
| 181 | 183 | ||
| 182 | } // namespace Service::Nvidia | 184 | } // namespace Service::Nvidia |
diff --git a/src/core/hle/service/nvdrv/nvdrv.h b/src/core/hle/service/nvdrv/nvdrv.h index 144e657e5..53719aadd 100644 --- a/src/core/hle/service/nvdrv/nvdrv.h +++ b/src/core/hle/service/nvdrv/nvdrv.h | |||
| @@ -7,8 +7,8 @@ | |||
| 7 | #include <memory> | 7 | #include <memory> |
| 8 | #include <unordered_map> | 8 | #include <unordered_map> |
| 9 | #include <vector> | 9 | #include <vector> |
| 10 | |||
| 10 | #include "common/common_types.h" | 11 | #include "common/common_types.h" |
| 11 | #include "core/hle/kernel/writable_event.h" | ||
| 12 | #include "core/hle/service/nvdrv/nvdata.h" | 12 | #include "core/hle/service/nvdrv/nvdata.h" |
| 13 | #include "core/hle/service/nvdrv/syncpoint_manager.h" | 13 | #include "core/hle/service/nvdrv/syncpoint_manager.h" |
| 14 | #include "core/hle/service/service.h" | 14 | #include "core/hle/service/service.h" |
| @@ -17,6 +17,10 @@ namespace Core { | |||
| 17 | class System; | 17 | class System; |
| 18 | } | 18 | } |
| 19 | 19 | ||
| 20 | namespace Kernel { | ||
| 21 | class KEvent; | ||
| 22 | } | ||
| 23 | |||
| 20 | namespace Service::NVFlinger { | 24 | namespace Service::NVFlinger { |
| 21 | class NVFlinger; | 25 | class NVFlinger; |
| 22 | } | 26 | } |
| @@ -31,7 +35,7 @@ class nvdevice; | |||
| 31 | 35 | ||
| 32 | /// Represents an Nvidia event | 36 | /// Represents an Nvidia event |
| 33 | struct NvEvent { | 37 | struct NvEvent { |
| 34 | Kernel::EventPair event; | 38 | std::shared_ptr<Kernel::KEvent> event; |
| 35 | Fence fence{}; | 39 | Fence fence{}; |
| 36 | }; | 40 | }; |
| 37 | 41 | ||
| @@ -132,9 +136,9 @@ public: | |||
| 132 | 136 | ||
| 133 | void SignalSyncpt(const u32 syncpoint_id, const u32 value); | 137 | void SignalSyncpt(const u32 syncpoint_id, const u32 value); |
| 134 | 138 | ||
| 135 | std::shared_ptr<Kernel::ReadableEvent> GetEvent(u32 event_id) const; | 139 | std::shared_ptr<Kernel::KReadableEvent> GetEvent(u32 event_id) const; |
| 136 | 140 | ||
| 137 | std::shared_ptr<Kernel::WritableEvent> GetEventWriteable(u32 event_id) const; | 141 | std::shared_ptr<Kernel::KWritableEvent> GetEventWriteable(u32 event_id) const; |
| 138 | 142 | ||
| 139 | private: | 143 | private: |
| 140 | /// Manages syncpoints on the host | 144 | /// Manages syncpoints on the host |
diff --git a/src/core/hle/service/nvflinger/buffer_queue.cpp b/src/core/hle/service/nvflinger/buffer_queue.cpp index 5578181a4..7842a82ed 100644 --- a/src/core/hle/service/nvflinger/buffer_queue.cpp +++ b/src/core/hle/service/nvflinger/buffer_queue.cpp | |||
| @@ -7,16 +7,17 @@ | |||
| 7 | #include "common/assert.h" | 7 | #include "common/assert.h" |
| 8 | #include "common/logging/log.h" | 8 | #include "common/logging/log.h" |
| 9 | #include "core/core.h" | 9 | #include "core/core.h" |
| 10 | #include "core/hle/kernel/k_event.h" | ||
| 11 | #include "core/hle/kernel/k_writable_event.h" | ||
| 10 | #include "core/hle/kernel/kernel.h" | 12 | #include "core/hle/kernel/kernel.h" |
| 11 | #include "core/hle/kernel/readable_event.h" | ||
| 12 | #include "core/hle/kernel/writable_event.h" | ||
| 13 | #include "core/hle/service/nvflinger/buffer_queue.h" | 13 | #include "core/hle/service/nvflinger/buffer_queue.h" |
| 14 | 14 | ||
| 15 | namespace Service::NVFlinger { | 15 | namespace Service::NVFlinger { |
| 16 | 16 | ||
| 17 | BufferQueue::BufferQueue(Kernel::KernelCore& kernel, u32 id, u64 layer_id) | 17 | BufferQueue::BufferQueue(Kernel::KernelCore& kernel, u32 id, u64 layer_id) |
| 18 | : id(id), layer_id(layer_id) { | 18 | : id(id), layer_id(layer_id) { |
| 19 | buffer_wait_event = Kernel::WritableEvent::CreateEventPair(kernel, "BufferQueue NativeHandle"); | 19 | buffer_wait_event = Kernel::KEvent::Create(kernel, "BufferQueue:WaitEvent"); |
| 20 | buffer_wait_event->Initialize(); | ||
| 20 | } | 21 | } |
| 21 | 22 | ||
| 22 | BufferQueue::~BufferQueue() = default; | 23 | BufferQueue::~BufferQueue() = default; |
| @@ -41,7 +42,7 @@ void BufferQueue::SetPreallocatedBuffer(u32 slot, const IGBPBuffer& igbp_buffer) | |||
| 41 | .multi_fence = {}, | 42 | .multi_fence = {}, |
| 42 | }; | 43 | }; |
| 43 | 44 | ||
| 44 | buffer_wait_event.writable->Signal(); | 45 | buffer_wait_event->GetWritableEvent()->Signal(); |
| 45 | } | 46 | } |
| 46 | 47 | ||
| 47 | std::optional<std::pair<u32, Service::Nvidia::MultiFence*>> BufferQueue::DequeueBuffer(u32 width, | 48 | std::optional<std::pair<u32, Service::Nvidia::MultiFence*>> BufferQueue::DequeueBuffer(u32 width, |
| @@ -119,7 +120,7 @@ void BufferQueue::CancelBuffer(u32 slot, const Service::Nvidia::MultiFence& mult | |||
| 119 | } | 120 | } |
| 120 | free_buffers_condition.notify_one(); | 121 | free_buffers_condition.notify_one(); |
| 121 | 122 | ||
| 122 | buffer_wait_event.writable->Signal(); | 123 | buffer_wait_event->GetWritableEvent()->Signal(); |
| 123 | } | 124 | } |
| 124 | 125 | ||
| 125 | std::optional<std::reference_wrapper<const BufferQueue::Buffer>> BufferQueue::AcquireBuffer() { | 126 | std::optional<std::reference_wrapper<const BufferQueue::Buffer>> BufferQueue::AcquireBuffer() { |
| @@ -154,7 +155,7 @@ void BufferQueue::ReleaseBuffer(u32 slot) { | |||
| 154 | } | 155 | } |
| 155 | free_buffers_condition.notify_one(); | 156 | free_buffers_condition.notify_one(); |
| 156 | 157 | ||
| 157 | buffer_wait_event.writable->Signal(); | 158 | buffer_wait_event->GetWritableEvent()->Signal(); |
| 158 | } | 159 | } |
| 159 | 160 | ||
| 160 | void BufferQueue::Connect() { | 161 | void BufferQueue::Connect() { |
| @@ -169,7 +170,7 @@ void BufferQueue::Disconnect() { | |||
| 169 | std::unique_lock lock{queue_sequence_mutex}; | 170 | std::unique_lock lock{queue_sequence_mutex}; |
| 170 | queue_sequence.clear(); | 171 | queue_sequence.clear(); |
| 171 | } | 172 | } |
| 172 | buffer_wait_event.writable->Signal(); | 173 | buffer_wait_event->GetWritableEvent()->Signal(); |
| 173 | is_connect = false; | 174 | is_connect = false; |
| 174 | free_buffers_condition.notify_one(); | 175 | free_buffers_condition.notify_one(); |
| 175 | } | 176 | } |
| @@ -188,12 +189,12 @@ u32 BufferQueue::Query(QueryType type) { | |||
| 188 | return 0; | 189 | return 0; |
| 189 | } | 190 | } |
| 190 | 191 | ||
| 191 | std::shared_ptr<Kernel::WritableEvent> BufferQueue::GetWritableBufferWaitEvent() const { | 192 | std::shared_ptr<Kernel::KWritableEvent> BufferQueue::GetWritableBufferWaitEvent() const { |
| 192 | return buffer_wait_event.writable; | 193 | return buffer_wait_event->GetWritableEvent(); |
| 193 | } | 194 | } |
| 194 | 195 | ||
| 195 | std::shared_ptr<Kernel::ReadableEvent> BufferQueue::GetBufferWaitEvent() const { | 196 | std::shared_ptr<Kernel::KReadableEvent> BufferQueue::GetBufferWaitEvent() const { |
| 196 | return buffer_wait_event.readable; | 197 | return buffer_wait_event->GetReadableEvent(); |
| 197 | } | 198 | } |
| 198 | 199 | ||
| 199 | } // namespace Service::NVFlinger | 200 | } // namespace Service::NVFlinger |
diff --git a/src/core/hle/service/nvflinger/buffer_queue.h b/src/core/hle/service/nvflinger/buffer_queue.h index ad7469277..163fa4c54 100644 --- a/src/core/hle/service/nvflinger/buffer_queue.h +++ b/src/core/hle/service/nvflinger/buffer_queue.h | |||
| @@ -14,12 +14,14 @@ | |||
| 14 | #include "common/math_util.h" | 14 | #include "common/math_util.h" |
| 15 | #include "common/swap.h" | 15 | #include "common/swap.h" |
| 16 | #include "core/hle/kernel/object.h" | 16 | #include "core/hle/kernel/object.h" |
| 17 | #include "core/hle/kernel/writable_event.h" | ||
| 18 | #include "core/hle/service/nvdrv/nvdata.h" | 17 | #include "core/hle/service/nvdrv/nvdata.h" |
| 19 | 18 | ||
| 20 | namespace Kernel { | 19 | namespace Kernel { |
| 21 | class KernelCore; | 20 | class KernelCore; |
| 22 | } | 21 | class KEvent; |
| 22 | class KReadableEvent; | ||
| 23 | class KWritableEvent; | ||
| 24 | } // namespace Kernel | ||
| 23 | 25 | ||
| 24 | namespace Service::NVFlinger { | 26 | namespace Service::NVFlinger { |
| 25 | 27 | ||
| @@ -113,9 +115,9 @@ public: | |||
| 113 | return is_connect; | 115 | return is_connect; |
| 114 | } | 116 | } |
| 115 | 117 | ||
| 116 | std::shared_ptr<Kernel::WritableEvent> GetWritableBufferWaitEvent() const; | 118 | std::shared_ptr<Kernel::KWritableEvent> GetWritableBufferWaitEvent() const; |
| 117 | 119 | ||
| 118 | std::shared_ptr<Kernel::ReadableEvent> GetBufferWaitEvent() const; | 120 | std::shared_ptr<Kernel::KReadableEvent> GetBufferWaitEvent() const; |
| 119 | 121 | ||
| 120 | private: | 122 | private: |
| 121 | BufferQueue(const BufferQueue&) = delete; | 123 | BufferQueue(const BufferQueue&) = delete; |
| @@ -127,7 +129,7 @@ private: | |||
| 127 | std::list<u32> free_buffers; | 129 | std::list<u32> free_buffers; |
| 128 | std::array<Buffer, buffer_slots> buffers; | 130 | std::array<Buffer, buffer_slots> buffers; |
| 129 | std::list<u32> queue_sequence; | 131 | std::list<u32> queue_sequence; |
| 130 | Kernel::EventPair buffer_wait_event; | 132 | std::shared_ptr<Kernel::KEvent> buffer_wait_event; |
| 131 | 133 | ||
| 132 | std::mutex free_buffers_mutex; | 134 | std::mutex free_buffers_mutex; |
| 133 | std::condition_variable free_buffers_condition; | 135 | std::condition_variable free_buffers_condition; |
diff --git a/src/core/hle/service/nvflinger/nvflinger.cpp b/src/core/hle/service/nvflinger/nvflinger.cpp index ceaa93d28..ac2906e5b 100644 --- a/src/core/hle/service/nvflinger/nvflinger.cpp +++ b/src/core/hle/service/nvflinger/nvflinger.cpp | |||
| @@ -14,8 +14,8 @@ | |||
| 14 | #include "core/core_timing.h" | 14 | #include "core/core_timing.h" |
| 15 | #include "core/core_timing_util.h" | 15 | #include "core/core_timing_util.h" |
| 16 | #include "core/hardware_properties.h" | 16 | #include "core/hardware_properties.h" |
| 17 | #include "core/hle/kernel/k_readable_event.h" | ||
| 17 | #include "core/hle/kernel/kernel.h" | 18 | #include "core/hle/kernel/kernel.h" |
| 18 | #include "core/hle/kernel/readable_event.h" | ||
| 19 | #include "core/hle/service/nvdrv/devices/nvdisp_disp0.h" | 19 | #include "core/hle/service/nvdrv/devices/nvdisp_disp0.h" |
| 20 | #include "core/hle/service/nvdrv/nvdrv.h" | 20 | #include "core/hle/service/nvdrv/nvdrv.h" |
| 21 | #include "core/hle/service/nvflinger/buffer_queue.h" | 21 | #include "core/hle/service/nvflinger/buffer_queue.h" |
| @@ -165,7 +165,7 @@ std::optional<u32> NVFlinger::FindBufferQueueId(u64 display_id, u64 layer_id) co | |||
| 165 | return layer->GetBufferQueue().GetId(); | 165 | return layer->GetBufferQueue().GetId(); |
| 166 | } | 166 | } |
| 167 | 167 | ||
| 168 | std::shared_ptr<Kernel::ReadableEvent> NVFlinger::FindVsyncEvent(u64 display_id) const { | 168 | std::shared_ptr<Kernel::KReadableEvent> NVFlinger::FindVsyncEvent(u64 display_id) const { |
| 169 | const auto guard = Lock(); | 169 | const auto guard = Lock(); |
| 170 | auto* const display = FindDisplay(display_id); | 170 | auto* const display = FindDisplay(display_id); |
| 171 | 171 | ||
diff --git a/src/core/hle/service/nvflinger/nvflinger.h b/src/core/hle/service/nvflinger/nvflinger.h index c6765259f..6fe2c7f2a 100644 --- a/src/core/hle/service/nvflinger/nvflinger.h +++ b/src/core/hle/service/nvflinger/nvflinger.h | |||
| @@ -26,8 +26,8 @@ struct EventType; | |||
| 26 | } // namespace Core::Timing | 26 | } // namespace Core::Timing |
| 27 | 27 | ||
| 28 | namespace Kernel { | 28 | namespace Kernel { |
| 29 | class ReadableEvent; | 29 | class KReadableEvent; |
| 30 | class WritableEvent; | 30 | class KWritableEvent; |
| 31 | } // namespace Kernel | 31 | } // namespace Kernel |
| 32 | 32 | ||
| 33 | namespace Service::Nvidia { | 33 | namespace Service::Nvidia { |
| @@ -72,7 +72,7 @@ public: | |||
| 72 | /// Gets the vsync event for the specified display. | 72 | /// Gets the vsync event for the specified display. |
| 73 | /// | 73 | /// |
| 74 | /// If an invalid display ID is provided, then nullptr is returned. | 74 | /// If an invalid display ID is provided, then nullptr is returned. |
| 75 | [[nodiscard]] std::shared_ptr<Kernel::ReadableEvent> FindVsyncEvent(u64 display_id) const; | 75 | [[nodiscard]] std::shared_ptr<Kernel::KReadableEvent> FindVsyncEvent(u64 display_id) const; |
| 76 | 76 | ||
| 77 | /// Obtains a buffer queue identified by the ID. | 77 | /// Obtains a buffer queue identified by the ID. |
| 78 | [[nodiscard]] BufferQueue* FindBufferQueue(u32 id); | 78 | [[nodiscard]] BufferQueue* FindBufferQueue(u32 id); |
diff --git a/src/core/hle/service/ptm/psm.cpp b/src/core/hle/service/ptm/psm.cpp index a7cfccda3..26ed52273 100644 --- a/src/core/hle/service/ptm/psm.cpp +++ b/src/core/hle/service/ptm/psm.cpp | |||
| @@ -7,9 +7,10 @@ | |||
| 7 | #include "common/logging/log.h" | 7 | #include "common/logging/log.h" |
| 8 | #include "core/core.h" | 8 | #include "core/core.h" |
| 9 | #include "core/hle/ipc_helpers.h" | 9 | #include "core/hle/ipc_helpers.h" |
| 10 | #include "core/hle/kernel/k_event.h" | ||
| 11 | #include "core/hle/kernel/k_readable_event.h" | ||
| 12 | #include "core/hle/kernel/k_writable_event.h" | ||
| 10 | #include "core/hle/kernel/kernel.h" | 13 | #include "core/hle/kernel/kernel.h" |
| 11 | #include "core/hle/kernel/readable_event.h" | ||
| 12 | #include "core/hle/kernel/writable_event.h" | ||
| 13 | #include "core/hle/service/ptm/psm.h" | 14 | #include "core/hle/service/ptm/psm.h" |
| 14 | #include "core/hle/service/service.h" | 15 | #include "core/hle/service/service.h" |
| 15 | #include "core/hle/service/sm/sm.h" | 16 | #include "core/hle/service/sm/sm.h" |
| @@ -31,27 +32,28 @@ public: | |||
| 31 | 32 | ||
| 32 | RegisterHandlers(functions); | 33 | RegisterHandlers(functions); |
| 33 | 34 | ||
| 34 | state_change_event = Kernel::WritableEvent::CreateEventPair( | 35 | state_change_event = |
| 35 | system_.Kernel(), "IPsmSession::state_change_event"); | 36 | Kernel::KEvent::Create(system_.Kernel(), "IPsmSession::state_change_event"); |
| 37 | state_change_event->Initialize(); | ||
| 36 | } | 38 | } |
| 37 | 39 | ||
| 38 | ~IPsmSession() override = default; | 40 | ~IPsmSession() override = default; |
| 39 | 41 | ||
| 40 | void SignalChargerTypeChanged() { | 42 | void SignalChargerTypeChanged() { |
| 41 | if (should_signal && should_signal_charger_type) { | 43 | if (should_signal && should_signal_charger_type) { |
| 42 | state_change_event.writable->Signal(); | 44 | state_change_event->GetWritableEvent()->Signal(); |
| 43 | } | 45 | } |
| 44 | } | 46 | } |
| 45 | 47 | ||
| 46 | void SignalPowerSupplyChanged() { | 48 | void SignalPowerSupplyChanged() { |
| 47 | if (should_signal && should_signal_power_supply) { | 49 | if (should_signal && should_signal_power_supply) { |
| 48 | state_change_event.writable->Signal(); | 50 | state_change_event->GetWritableEvent()->Signal(); |
| 49 | } | 51 | } |
| 50 | } | 52 | } |
| 51 | 53 | ||
| 52 | void SignalBatteryVoltageStateChanged() { | 54 | void SignalBatteryVoltageStateChanged() { |
| 53 | if (should_signal && should_signal_battery_voltage) { | 55 | if (should_signal && should_signal_battery_voltage) { |
| 54 | state_change_event.writable->Signal(); | 56 | state_change_event->GetWritableEvent()->Signal(); |
| 55 | } | 57 | } |
| 56 | } | 58 | } |
| 57 | 59 | ||
| @@ -63,7 +65,7 @@ private: | |||
| 63 | 65 | ||
| 64 | IPC::ResponseBuilder rb{ctx, 2, 1}; | 66 | IPC::ResponseBuilder rb{ctx, 2, 1}; |
| 65 | rb.Push(RESULT_SUCCESS); | 67 | rb.Push(RESULT_SUCCESS); |
| 66 | rb.PushCopyObjects(state_change_event.readable); | 68 | rb.PushCopyObjects(state_change_event->GetReadableEvent()); |
| 67 | } | 69 | } |
| 68 | 70 | ||
| 69 | void UnbindStateChangeEvent(Kernel::HLERequestContext& ctx) { | 71 | void UnbindStateChangeEvent(Kernel::HLERequestContext& ctx) { |
| @@ -112,7 +114,7 @@ private: | |||
| 112 | bool should_signal_power_supply{}; | 114 | bool should_signal_power_supply{}; |
| 113 | bool should_signal_battery_voltage{}; | 115 | bool should_signal_battery_voltage{}; |
| 114 | bool should_signal{}; | 116 | bool should_signal{}; |
| 115 | Kernel::EventPair state_change_event; | 117 | std::shared_ptr<Kernel::KEvent> state_change_event; |
| 116 | }; | 118 | }; |
| 117 | 119 | ||
| 118 | class PSM final : public ServiceFramework<PSM> { | 120 | class PSM final : public ServiceFramework<PSM> { |
diff --git a/src/core/hle/service/time/standard_user_system_clock_core.cpp b/src/core/hle/service/time/standard_user_system_clock_core.cpp index 8af17091c..b9faa474e 100644 --- a/src/core/hle/service/time/standard_user_system_clock_core.cpp +++ b/src/core/hle/service/time/standard_user_system_clock_core.cpp | |||
| @@ -4,7 +4,7 @@ | |||
| 4 | 4 | ||
| 5 | #include "common/assert.h" | 5 | #include "common/assert.h" |
| 6 | #include "core/core.h" | 6 | #include "core/core.h" |
| 7 | #include "core/hle/kernel/writable_event.h" | 7 | #include "core/hle/kernel/k_event.h" |
| 8 | #include "core/hle/service/time/standard_local_system_clock_core.h" | 8 | #include "core/hle/service/time/standard_local_system_clock_core.h" |
| 9 | #include "core/hle/service/time/standard_network_system_clock_core.h" | 9 | #include "core/hle/service/time/standard_network_system_clock_core.h" |
| 10 | #include "core/hle/service/time/standard_user_system_clock_core.h" | 10 | #include "core/hle/service/time/standard_user_system_clock_core.h" |
| @@ -18,8 +18,10 @@ StandardUserSystemClockCore::StandardUserSystemClockCore( | |||
| 18 | local_system_clock_core{local_system_clock_core}, | 18 | local_system_clock_core{local_system_clock_core}, |
| 19 | network_system_clock_core{network_system_clock_core}, auto_correction_enabled{}, | 19 | network_system_clock_core{network_system_clock_core}, auto_correction_enabled{}, |
| 20 | auto_correction_time{SteadyClockTimePoint::GetRandom()}, | 20 | auto_correction_time{SteadyClockTimePoint::GetRandom()}, |
| 21 | auto_correction_event{Kernel::WritableEvent::CreateEventPair( | 21 | auto_correction_event{Kernel::KEvent::Create( |
| 22 | system.Kernel(), "StandardUserSystemClockCore:AutoCorrectionEvent")} {} | 22 | system.Kernel(), "StandardUserSystemClockCore:AutoCorrectionEvent")} { |
| 23 | auto_correction_event->Initialize(); | ||
| 24 | } | ||
| 23 | 25 | ||
| 24 | ResultCode StandardUserSystemClockCore::SetAutomaticCorrectionEnabled(Core::System& system, | 26 | ResultCode StandardUserSystemClockCore::SetAutomaticCorrectionEnabled(Core::System& system, |
| 25 | bool value) { | 27 | bool value) { |
diff --git a/src/core/hle/service/time/standard_user_system_clock_core.h b/src/core/hle/service/time/standard_user_system_clock_core.h index ef3d468b7..aac44d72f 100644 --- a/src/core/hle/service/time/standard_user_system_clock_core.h +++ b/src/core/hle/service/time/standard_user_system_clock_core.h | |||
| @@ -4,7 +4,6 @@ | |||
| 4 | 4 | ||
| 5 | #pragma once | 5 | #pragma once |
| 6 | 6 | ||
| 7 | #include "core/hle/kernel/writable_event.h" | ||
| 8 | #include "core/hle/service/time/clock_types.h" | 7 | #include "core/hle/service/time/clock_types.h" |
| 9 | #include "core/hle/service/time/system_clock_core.h" | 8 | #include "core/hle/service/time/system_clock_core.h" |
| 10 | 9 | ||
| @@ -12,6 +11,10 @@ namespace Core { | |||
| 12 | class System; | 11 | class System; |
| 13 | } | 12 | } |
| 14 | 13 | ||
| 14 | namespace Kernel { | ||
| 15 | class KEvent; | ||
| 16 | } | ||
| 17 | |||
| 15 | namespace Service::Time::Clock { | 18 | namespace Service::Time::Clock { |
| 16 | 19 | ||
| 17 | class StandardLocalSystemClockCore; | 20 | class StandardLocalSystemClockCore; |
| @@ -51,7 +54,7 @@ private: | |||
| 51 | StandardNetworkSystemClockCore& network_system_clock_core; | 54 | StandardNetworkSystemClockCore& network_system_clock_core; |
| 52 | bool auto_correction_enabled{}; | 55 | bool auto_correction_enabled{}; |
| 53 | SteadyClockTimePoint auto_correction_time; | 56 | SteadyClockTimePoint auto_correction_time; |
| 54 | Kernel::EventPair auto_correction_event; | 57 | std::shared_ptr<Kernel::KEvent> auto_correction_event; |
| 55 | }; | 58 | }; |
| 56 | 59 | ||
| 57 | } // namespace Service::Time::Clock | 60 | } // namespace Service::Time::Clock |
diff --git a/src/core/hle/service/time/system_clock_context_update_callback.cpp b/src/core/hle/service/time/system_clock_context_update_callback.cpp index 5cdb80703..bca7d869e 100644 --- a/src/core/hle/service/time/system_clock_context_update_callback.cpp +++ b/src/core/hle/service/time/system_clock_context_update_callback.cpp | |||
| @@ -2,7 +2,7 @@ | |||
| 2 | // Licensed under GPLv2 or any later version | 2 | // Licensed under GPLv2 or any later version |
| 3 | // Refer to the license.txt file included. | 3 | // Refer to the license.txt file included. |
| 4 | 4 | ||
| 5 | #include "core/hle/kernel/writable_event.h" | 5 | #include "core/hle/kernel/k_writable_event.h" |
| 6 | #include "core/hle/service/time/errors.h" | 6 | #include "core/hle/service/time/errors.h" |
| 7 | #include "core/hle/service/time/system_clock_context_update_callback.h" | 7 | #include "core/hle/service/time/system_clock_context_update_callback.h" |
| 8 | 8 | ||
| @@ -21,7 +21,7 @@ bool SystemClockContextUpdateCallback::NeedUpdate(const SystemClockContext& valu | |||
| 21 | } | 21 | } |
| 22 | 22 | ||
| 23 | void SystemClockContextUpdateCallback::RegisterOperationEvent( | 23 | void SystemClockContextUpdateCallback::RegisterOperationEvent( |
| 24 | std::shared_ptr<Kernel::WritableEvent>&& writable_event) { | 24 | std::shared_ptr<Kernel::KWritableEvent>&& writable_event) { |
| 25 | operation_event_list.emplace_back(std::move(writable_event)); | 25 | operation_event_list.emplace_back(std::move(writable_event)); |
| 26 | } | 26 | } |
| 27 | 27 | ||
diff --git a/src/core/hle/service/time/system_clock_context_update_callback.h b/src/core/hle/service/time/system_clock_context_update_callback.h index 2b0fa7e75..797954958 100644 --- a/src/core/hle/service/time/system_clock_context_update_callback.h +++ b/src/core/hle/service/time/system_clock_context_update_callback.h | |||
| @@ -9,7 +9,7 @@ | |||
| 9 | #include "core/hle/service/time/clock_types.h" | 9 | #include "core/hle/service/time/clock_types.h" |
| 10 | 10 | ||
| 11 | namespace Kernel { | 11 | namespace Kernel { |
| 12 | class WritableEvent; | 12 | class KWritableEvent; |
| 13 | } | 13 | } |
| 14 | 14 | ||
| 15 | namespace Service::Time::Clock { | 15 | namespace Service::Time::Clock { |
| @@ -24,7 +24,7 @@ public: | |||
| 24 | 24 | ||
| 25 | bool NeedUpdate(const SystemClockContext& value) const; | 25 | bool NeedUpdate(const SystemClockContext& value) const; |
| 26 | 26 | ||
| 27 | void RegisterOperationEvent(std::shared_ptr<Kernel::WritableEvent>&& writable_event); | 27 | void RegisterOperationEvent(std::shared_ptr<Kernel::KWritableEvent>&& writable_event); |
| 28 | 28 | ||
| 29 | void BroadcastOperationEvent(); | 29 | void BroadcastOperationEvent(); |
| 30 | 30 | ||
| @@ -37,7 +37,7 @@ protected: | |||
| 37 | 37 | ||
| 38 | private: | 38 | private: |
| 39 | bool has_context{}; | 39 | bool has_context{}; |
| 40 | std::vector<std::shared_ptr<Kernel::WritableEvent>> operation_event_list; | 40 | std::vector<std::shared_ptr<Kernel::KWritableEvent>> operation_event_list; |
| 41 | }; | 41 | }; |
| 42 | 42 | ||
| 43 | } // namespace Service::Time::Clock | 43 | } // namespace Service::Time::Clock |
diff --git a/src/core/hle/service/vi/display/vi_display.cpp b/src/core/hle/service/vi/display/vi_display.cpp index 5a202ac81..7f42aa4a0 100644 --- a/src/core/hle/service/vi/display/vi_display.cpp +++ b/src/core/hle/service/vi/display/vi_display.cpp | |||
| @@ -9,7 +9,9 @@ | |||
| 9 | 9 | ||
| 10 | #include "common/assert.h" | 10 | #include "common/assert.h" |
| 11 | #include "core/core.h" | 11 | #include "core/core.h" |
| 12 | #include "core/hle/kernel/readable_event.h" | 12 | #include "core/hle/kernel/k_event.h" |
| 13 | #include "core/hle/kernel/k_readable_event.h" | ||
| 14 | #include "core/hle/kernel/k_writable_event.h" | ||
| 13 | #include "core/hle/service/vi/display/vi_display.h" | 15 | #include "core/hle/service/vi/display/vi_display.h" |
| 14 | #include "core/hle/service/vi/layer/vi_layer.h" | 16 | #include "core/hle/service/vi/layer/vi_layer.h" |
| 15 | 17 | ||
| @@ -17,8 +19,8 @@ namespace Service::VI { | |||
| 17 | 19 | ||
| 18 | Display::Display(u64 id, std::string name, Core::System& system) : id{id}, name{std::move(name)} { | 20 | Display::Display(u64 id, std::string name, Core::System& system) : id{id}, name{std::move(name)} { |
| 19 | auto& kernel = system.Kernel(); | 21 | auto& kernel = system.Kernel(); |
| 20 | vsync_event = | 22 | vsync_event = Kernel::KEvent::Create(kernel, fmt::format("Display VSync Event {}", id)); |
| 21 | Kernel::WritableEvent::CreateEventPair(kernel, fmt::format("Display VSync Event {}", id)); | 23 | vsync_event->Initialize(); |
| 22 | } | 24 | } |
| 23 | 25 | ||
| 24 | Display::~Display() = default; | 26 | Display::~Display() = default; |
| @@ -31,12 +33,12 @@ const Layer& Display::GetLayer(std::size_t index) const { | |||
| 31 | return *layers.at(index); | 33 | return *layers.at(index); |
| 32 | } | 34 | } |
| 33 | 35 | ||
| 34 | std::shared_ptr<Kernel::ReadableEvent> Display::GetVSyncEvent() const { | 36 | std::shared_ptr<Kernel::KReadableEvent> Display::GetVSyncEvent() const { |
| 35 | return vsync_event.readable; | 37 | return vsync_event->GetReadableEvent(); |
| 36 | } | 38 | } |
| 37 | 39 | ||
| 38 | void Display::SignalVSyncEvent() { | 40 | void Display::SignalVSyncEvent() { |
| 39 | vsync_event.writable->Signal(); | 41 | vsync_event->GetWritableEvent()->Signal(); |
| 40 | } | 42 | } |
| 41 | 43 | ||
| 42 | void Display::CreateLayer(u64 id, NVFlinger::BufferQueue& buffer_queue) { | 44 | void Display::CreateLayer(u64 id, NVFlinger::BufferQueue& buffer_queue) { |
diff --git a/src/core/hle/service/vi/display/vi_display.h b/src/core/hle/service/vi/display/vi_display.h index a3855d8cd..931c898f6 100644 --- a/src/core/hle/service/vi/display/vi_display.h +++ b/src/core/hle/service/vi/display/vi_display.h | |||
| @@ -9,7 +9,10 @@ | |||
| 9 | #include <vector> | 9 | #include <vector> |
| 10 | 10 | ||
| 11 | #include "common/common_types.h" | 11 | #include "common/common_types.h" |
| 12 | #include "core/hle/kernel/writable_event.h" | 12 | |
| 13 | namespace Kernel { | ||
| 14 | class KEvent; | ||
| 15 | } | ||
| 13 | 16 | ||
| 14 | namespace Service::NVFlinger { | 17 | namespace Service::NVFlinger { |
| 15 | class BufferQueue; | 18 | class BufferQueue; |
| @@ -58,7 +61,7 @@ public: | |||
| 58 | const Layer& GetLayer(std::size_t index) const; | 61 | const Layer& GetLayer(std::size_t index) const; |
| 59 | 62 | ||
| 60 | /// Gets the readable vsync event. | 63 | /// Gets the readable vsync event. |
| 61 | std::shared_ptr<Kernel::ReadableEvent> GetVSyncEvent() const; | 64 | std::shared_ptr<Kernel::KReadableEvent> GetVSyncEvent() const; |
| 62 | 65 | ||
| 63 | /// Signals the internal vsync event. | 66 | /// Signals the internal vsync event. |
| 64 | void SignalVSyncEvent(); | 67 | void SignalVSyncEvent(); |
| @@ -99,7 +102,7 @@ private: | |||
| 99 | std::string name; | 102 | std::string name; |
| 100 | 103 | ||
| 101 | std::vector<std::shared_ptr<Layer>> layers; | 104 | std::vector<std::shared_ptr<Layer>> layers; |
| 102 | Kernel::EventPair vsync_event; | 105 | std::shared_ptr<Kernel::KEvent> vsync_event; |
| 103 | }; | 106 | }; |
| 104 | 107 | ||
| 105 | } // namespace Service::VI | 108 | } // namespace Service::VI |
diff --git a/src/core/hle/service/vi/vi.cpp b/src/core/hle/service/vi/vi.cpp index f3de2c428..8661895ae 100644 --- a/src/core/hle/service/vi/vi.cpp +++ b/src/core/hle/service/vi/vi.cpp | |||
| @@ -18,9 +18,9 @@ | |||
| 18 | #include "common/swap.h" | 18 | #include "common/swap.h" |
| 19 | #include "core/core_timing.h" | 19 | #include "core/core_timing.h" |
| 20 | #include "core/hle/ipc_helpers.h" | 20 | #include "core/hle/ipc_helpers.h" |
| 21 | #include "core/hle/kernel/k_readable_event.h" | ||
| 21 | #include "core/hle/kernel/k_thread.h" | 22 | #include "core/hle/kernel/k_thread.h" |
| 22 | #include "core/hle/kernel/readable_event.h" | 23 | #include "core/hle/kernel/k_writable_event.h" |
| 23 | #include "core/hle/kernel/writable_event.h" | ||
| 24 | #include "core/hle/service/nvdrv/nvdata.h" | 24 | #include "core/hle/service/nvdrv/nvdata.h" |
| 25 | #include "core/hle/service/nvdrv/nvdrv.h" | 25 | #include "core/hle/service/nvdrv/nvdrv.h" |
| 26 | #include "core/hle/service/nvflinger/buffer_queue.h" | 26 | #include "core/hle/service/nvflinger/buffer_queue.h" |
diff --git a/src/yuzu/debugger/wait_tree.cpp b/src/yuzu/debugger/wait_tree.cpp index 0e5156dcc..3bca6277b 100644 --- a/src/yuzu/debugger/wait_tree.cpp +++ b/src/yuzu/debugger/wait_tree.cpp | |||
| @@ -13,11 +13,11 @@ | |||
| 13 | #include "core/arm/arm_interface.h" | 13 | #include "core/arm/arm_interface.h" |
| 14 | #include "core/core.h" | 14 | #include "core/core.h" |
| 15 | #include "core/hle/kernel/handle_table.h" | 15 | #include "core/hle/kernel/handle_table.h" |
| 16 | #include "core/hle/kernel/k_readable_event.h" | ||
| 16 | #include "core/hle/kernel/k_scheduler.h" | 17 | #include "core/hle/kernel/k_scheduler.h" |
| 17 | #include "core/hle/kernel/k_synchronization_object.h" | 18 | #include "core/hle/kernel/k_synchronization_object.h" |
| 18 | #include "core/hle/kernel/k_thread.h" | 19 | #include "core/hle/kernel/k_thread.h" |
| 19 | #include "core/hle/kernel/process.h" | 20 | #include "core/hle/kernel/process.h" |
| 20 | #include "core/hle/kernel/readable_event.h" | ||
| 21 | #include "core/hle/kernel/svc_common.h" | 21 | #include "core/hle/kernel/svc_common.h" |
| 22 | #include "core/hle/kernel/svc_types.h" | 22 | #include "core/hle/kernel/svc_types.h" |
| 23 | #include "core/memory.h" | 23 | #include "core/memory.h" |
| @@ -193,7 +193,7 @@ std::unique_ptr<WaitTreeSynchronizationObject> WaitTreeSynchronizationObject::ma | |||
| 193 | const Kernel::KSynchronizationObject& object) { | 193 | const Kernel::KSynchronizationObject& object) { |
| 194 | switch (object.GetHandleType()) { | 194 | switch (object.GetHandleType()) { |
| 195 | case Kernel::HandleType::ReadableEvent: | 195 | case Kernel::HandleType::ReadableEvent: |
| 196 | return std::make_unique<WaitTreeEvent>(static_cast<const Kernel::ReadableEvent&>(object)); | 196 | return std::make_unique<WaitTreeEvent>(static_cast<const Kernel::KReadableEvent&>(object)); |
| 197 | case Kernel::HandleType::Thread: | 197 | case Kernel::HandleType::Thread: |
| 198 | return std::make_unique<WaitTreeThread>(static_cast<const Kernel::KThread&>(object)); | 198 | return std::make_unique<WaitTreeThread>(static_cast<const Kernel::KThread&>(object)); |
| 199 | default: | 199 | default: |
| @@ -373,7 +373,7 @@ std::vector<std::unique_ptr<WaitTreeItem>> WaitTreeThread::GetChildren() const { | |||
| 373 | return list; | 373 | return list; |
| 374 | } | 374 | } |
| 375 | 375 | ||
| 376 | WaitTreeEvent::WaitTreeEvent(const Kernel::ReadableEvent& object) | 376 | WaitTreeEvent::WaitTreeEvent(const Kernel::KReadableEvent& object) |
| 377 | : WaitTreeSynchronizationObject(object) {} | 377 | : WaitTreeSynchronizationObject(object) {} |
| 378 | WaitTreeEvent::~WaitTreeEvent() = default; | 378 | WaitTreeEvent::~WaitTreeEvent() = default; |
| 379 | 379 | ||
diff --git a/src/yuzu/debugger/wait_tree.h b/src/yuzu/debugger/wait_tree.h index b202c5567..3da2fdfd2 100644 --- a/src/yuzu/debugger/wait_tree.h +++ b/src/yuzu/debugger/wait_tree.h | |||
| @@ -18,9 +18,9 @@ class EmuThread; | |||
| 18 | 18 | ||
| 19 | namespace Kernel { | 19 | namespace Kernel { |
| 20 | class HandleTable; | 20 | class HandleTable; |
| 21 | class KReadableEvent; | ||
| 21 | class KSynchronizationObject; | 22 | class KSynchronizationObject; |
| 22 | class KThread; | 23 | class KThread; |
| 23 | class ReadableEvent; | ||
| 24 | } // namespace Kernel | 24 | } // namespace Kernel |
| 25 | 25 | ||
| 26 | class WaitTreeThread; | 26 | class WaitTreeThread; |
| @@ -142,7 +142,7 @@ public: | |||
| 142 | class WaitTreeEvent : public WaitTreeSynchronizationObject { | 142 | class WaitTreeEvent : public WaitTreeSynchronizationObject { |
| 143 | Q_OBJECT | 143 | Q_OBJECT |
| 144 | public: | 144 | public: |
| 145 | explicit WaitTreeEvent(const Kernel::ReadableEvent& object); | 145 | explicit WaitTreeEvent(const Kernel::KReadableEvent& object); |
| 146 | ~WaitTreeEvent() override; | 146 | ~WaitTreeEvent() override; |
| 147 | }; | 147 | }; |
| 148 | 148 | ||