Merge pull request #6551 from bunnei/improve-kernel-obj
Improve management of kernel objects
This commit is contained in:
commit
2656020608
@ -517,6 +517,8 @@ add_library(core STATIC
|
|||||||
hle/service/psc/psc.h
|
hle/service/psc/psc.h
|
||||||
hle/service/ptm/psm.cpp
|
hle/service/ptm/psm.cpp
|
||||||
hle/service/ptm/psm.h
|
hle/service/ptm/psm.h
|
||||||
|
hle/service/kernel_helpers.cpp
|
||||||
|
hle/service/kernel_helpers.h
|
||||||
hle/service/service.cpp
|
hle/service/service.cpp
|
||||||
hle/service/service.h
|
hle/service/service.h
|
||||||
hle/service/set/set.cpp
|
hle/service/set/set.cpp
|
||||||
|
@ -58,6 +58,9 @@ bool SessionRequestManager::HasSessionRequestHandler(const HLERequestContext& co
|
|||||||
|
|
||||||
void SessionRequestHandler::ClientConnected(KServerSession* session) {
|
void SessionRequestHandler::ClientConnected(KServerSession* session) {
|
||||||
session->ClientConnected(shared_from_this());
|
session->ClientConnected(shared_from_this());
|
||||||
|
|
||||||
|
// Ensure our server session is tracked globally.
|
||||||
|
kernel.RegisterServerSession(session);
|
||||||
}
|
}
|
||||||
|
|
||||||
void SessionRequestHandler::ClientDisconnected(KServerSession* session) {
|
void SessionRequestHandler::ClientDisconnected(KServerSession* session) {
|
||||||
|
@ -3,6 +3,7 @@
|
|||||||
// Refer to the license.txt file included.
|
// Refer to the license.txt file included.
|
||||||
|
|
||||||
#include "core/hle/kernel/k_auto_object.h"
|
#include "core/hle/kernel/k_auto_object.h"
|
||||||
|
#include "core/hle/kernel/kernel.h"
|
||||||
|
|
||||||
namespace Kernel {
|
namespace Kernel {
|
||||||
|
|
||||||
@ -11,4 +12,12 @@ KAutoObject* KAutoObject::Create(KAutoObject* obj) {
|
|||||||
return obj;
|
return obj;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void KAutoObject::RegisterWithKernel() {
|
||||||
|
kernel.RegisterKernelObject(this);
|
||||||
|
}
|
||||||
|
|
||||||
|
void KAutoObject::UnregisterWithKernel() {
|
||||||
|
kernel.UnregisterKernelObject(this);
|
||||||
|
}
|
||||||
|
|
||||||
} // namespace Kernel
|
} // namespace Kernel
|
||||||
|
@ -85,8 +85,12 @@ private:
|
|||||||
KERNEL_AUTOOBJECT_TRAITS(KAutoObject, KAutoObject);
|
KERNEL_AUTOOBJECT_TRAITS(KAutoObject, KAutoObject);
|
||||||
|
|
||||||
public:
|
public:
|
||||||
explicit KAutoObject(KernelCore& kernel_) : kernel(kernel_) {}
|
explicit KAutoObject(KernelCore& kernel_) : kernel(kernel_) {
|
||||||
virtual ~KAutoObject() = default;
|
RegisterWithKernel();
|
||||||
|
}
|
||||||
|
virtual ~KAutoObject() {
|
||||||
|
UnregisterWithKernel();
|
||||||
|
}
|
||||||
|
|
||||||
static KAutoObject* Create(KAutoObject* ptr);
|
static KAutoObject* Create(KAutoObject* ptr);
|
||||||
|
|
||||||
@ -166,6 +170,10 @@ public:
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private:
|
||||||
|
void RegisterWithKernel();
|
||||||
|
void UnregisterWithKernel();
|
||||||
|
|
||||||
protected:
|
protected:
|
||||||
KernelCore& kernel;
|
KernelCore& kernel;
|
||||||
std::string name;
|
std::string name;
|
||||||
|
@ -10,6 +10,7 @@
|
|||||||
#include "common/alignment.h"
|
#include "common/alignment.h"
|
||||||
#include "common/assert.h"
|
#include "common/assert.h"
|
||||||
#include "common/logging/log.h"
|
#include "common/logging/log.h"
|
||||||
|
#include "common/scope_exit.h"
|
||||||
#include "common/settings.h"
|
#include "common/settings.h"
|
||||||
#include "core/core.h"
|
#include "core/core.h"
|
||||||
#include "core/device_memory.h"
|
#include "core/device_memory.h"
|
||||||
@ -43,6 +44,8 @@ void SetupMainThread(Core::System& system, KProcess& owner_process, u32 priority
|
|||||||
ASSERT(owner_process.GetResourceLimit()->Reserve(LimitableResource::Threads, 1));
|
ASSERT(owner_process.GetResourceLimit()->Reserve(LimitableResource::Threads, 1));
|
||||||
|
|
||||||
KThread* thread = KThread::Create(system.Kernel());
|
KThread* thread = KThread::Create(system.Kernel());
|
||||||
|
SCOPE_EXIT({ thread->Close(); });
|
||||||
|
|
||||||
ASSERT(KThread::InitializeUserThread(system, thread, entry_point, 0, stack_top, priority,
|
ASSERT(KThread::InitializeUserThread(system, thread, entry_point, 0, stack_top, priority,
|
||||||
owner_process.GetIdealCoreId(), &owner_process)
|
owner_process.GetIdealCoreId(), &owner_process)
|
||||||
.IsSuccess());
|
.IsSuccess());
|
||||||
@ -162,7 +165,7 @@ void KProcess::DecrementThreadCount() {
|
|||||||
ASSERT(num_threads > 0);
|
ASSERT(num_threads > 0);
|
||||||
|
|
||||||
if (const auto count = --num_threads; count == 0) {
|
if (const auto count = --num_threads; count == 0) {
|
||||||
UNIMPLEMENTED_MSG("Process termination is not implemented!");
|
LOG_WARNING(Kernel, "Process termination is not fully implemented.");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -406,6 +409,9 @@ void KProcess::Finalize() {
|
|||||||
resource_limit->Close();
|
resource_limit->Close();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Finalize the handle table and close any open handles.
|
||||||
|
handle_table.Finalize();
|
||||||
|
|
||||||
// Perform inherited finalization.
|
// Perform inherited finalization.
|
||||||
KAutoObjectWithSlabHeapAndContainer<KProcess, KSynchronizationObject>::Finalize();
|
KAutoObjectWithSlabHeapAndContainer<KProcess, KSynchronizationObject>::Finalize();
|
||||||
}
|
}
|
||||||
|
@ -28,7 +28,10 @@ namespace Kernel {
|
|||||||
|
|
||||||
KServerSession::KServerSession(KernelCore& kernel_) : KSynchronizationObject{kernel_} {}
|
KServerSession::KServerSession(KernelCore& kernel_) : KSynchronizationObject{kernel_} {}
|
||||||
|
|
||||||
KServerSession::~KServerSession() {}
|
KServerSession::~KServerSession() {
|
||||||
|
// Ensure that the global list tracking server sessions does not hold on to a reference.
|
||||||
|
kernel.UnregisterServerSession(this);
|
||||||
|
}
|
||||||
|
|
||||||
void KServerSession::Initialize(KSession* parent_session_, std::string&& name_,
|
void KServerSession::Initialize(KSession* parent_session_, std::string&& name_,
|
||||||
std::shared_ptr<SessionRequestManager> manager_) {
|
std::shared_ptr<SessionRequestManager> manager_) {
|
||||||
|
@ -61,6 +61,7 @@ struct KernelCore::Impl {
|
|||||||
void Initialize(KernelCore& kernel) {
|
void Initialize(KernelCore& kernel) {
|
||||||
global_scheduler_context = std::make_unique<Kernel::GlobalSchedulerContext>(kernel);
|
global_scheduler_context = std::make_unique<Kernel::GlobalSchedulerContext>(kernel);
|
||||||
global_handle_table = std::make_unique<Kernel::KHandleTable>(kernel);
|
global_handle_table = std::make_unique<Kernel::KHandleTable>(kernel);
|
||||||
|
global_handle_table->Initialize(KHandleTable::MaxTableSize);
|
||||||
|
|
||||||
is_phantom_mode_for_singlecore = false;
|
is_phantom_mode_for_singlecore = false;
|
||||||
|
|
||||||
@ -90,9 +91,39 @@ struct KernelCore::Impl {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void Shutdown() {
|
void Shutdown() {
|
||||||
|
// Shutdown all processes.
|
||||||
|
if (current_process) {
|
||||||
|
current_process->Finalize();
|
||||||
|
current_process->Close();
|
||||||
|
current_process = nullptr;
|
||||||
|
}
|
||||||
process_list.clear();
|
process_list.clear();
|
||||||
|
|
||||||
// Ensures all service threads gracefully shutdown
|
// Close all open server ports.
|
||||||
|
std::unordered_set<KServerPort*> server_ports_;
|
||||||
|
{
|
||||||
|
std::lock_guard lk(server_ports_lock);
|
||||||
|
server_ports_ = server_ports;
|
||||||
|
server_ports.clear();
|
||||||
|
}
|
||||||
|
for (auto* server_port : server_ports_) {
|
||||||
|
server_port->Close();
|
||||||
|
}
|
||||||
|
// Close all open server sessions.
|
||||||
|
std::unordered_set<KServerSession*> server_sessions_;
|
||||||
|
{
|
||||||
|
std::lock_guard lk(server_sessions_lock);
|
||||||
|
server_sessions_ = server_sessions;
|
||||||
|
server_sessions.clear();
|
||||||
|
}
|
||||||
|
for (auto* server_session : server_sessions_) {
|
||||||
|
server_session->Close();
|
||||||
|
}
|
||||||
|
|
||||||
|
// Ensure that the object list container is finalized and properly shutdown.
|
||||||
|
object_list_container.Finalize();
|
||||||
|
|
||||||
|
// Ensures all service threads gracefully shutdown.
|
||||||
service_threads.clear();
|
service_threads.clear();
|
||||||
|
|
||||||
next_object_id = 0;
|
next_object_id = 0;
|
||||||
@ -111,11 +142,7 @@ struct KernelCore::Impl {
|
|||||||
|
|
||||||
cores.clear();
|
cores.clear();
|
||||||
|
|
||||||
if (current_process) {
|
global_handle_table->Finalize();
|
||||||
current_process->Close();
|
|
||||||
current_process = nullptr;
|
|
||||||
}
|
|
||||||
|
|
||||||
global_handle_table.reset();
|
global_handle_table.reset();
|
||||||
|
|
||||||
preemption_event = nullptr;
|
preemption_event = nullptr;
|
||||||
@ -142,6 +169,16 @@ struct KernelCore::Impl {
|
|||||||
|
|
||||||
// Next host thead ID to use, 0-3 IDs represent core threads, >3 represent others
|
// Next host thead ID to use, 0-3 IDs represent core threads, >3 represent others
|
||||||
next_host_thread_id = Core::Hardware::NUM_CPU_CORES;
|
next_host_thread_id = Core::Hardware::NUM_CPU_CORES;
|
||||||
|
|
||||||
|
// Track kernel objects that were not freed on shutdown
|
||||||
|
{
|
||||||
|
std::lock_guard lk(registered_objects_lock);
|
||||||
|
if (registered_objects.size()) {
|
||||||
|
LOG_WARNING(Kernel, "{} kernel objects were dangling on shutdown!",
|
||||||
|
registered_objects.size());
|
||||||
|
registered_objects.clear();
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
void InitializePhysicalCores() {
|
void InitializePhysicalCores() {
|
||||||
@ -630,6 +667,21 @@ struct KernelCore::Impl {
|
|||||||
user_slab_heap_size);
|
user_slab_heap_size);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
KClientPort* CreateNamedServicePort(std::string name) {
|
||||||
|
auto search = service_interface_factory.find(name);
|
||||||
|
if (search == service_interface_factory.end()) {
|
||||||
|
UNIMPLEMENTED();
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
KClientPort* port = &search->second(system.ServiceManager(), system);
|
||||||
|
{
|
||||||
|
std::lock_guard lk(server_ports_lock);
|
||||||
|
server_ports.insert(&port->GetParent()->GetServerPort());
|
||||||
|
}
|
||||||
|
return port;
|
||||||
|
}
|
||||||
|
|
||||||
std::atomic<u32> next_object_id{0};
|
std::atomic<u32> next_object_id{0};
|
||||||
std::atomic<u64> next_kernel_process_id{KProcess::InitialKIPIDMin};
|
std::atomic<u64> next_kernel_process_id{KProcess::InitialKIPIDMin};
|
||||||
std::atomic<u64> next_user_process_id{KProcess::ProcessIDMin};
|
std::atomic<u64> next_user_process_id{KProcess::ProcessIDMin};
|
||||||
@ -656,6 +708,12 @@ struct KernelCore::Impl {
|
|||||||
/// the ConnectToPort SVC.
|
/// the ConnectToPort SVC.
|
||||||
std::unordered_map<std::string, ServiceInterfaceFactory> service_interface_factory;
|
std::unordered_map<std::string, ServiceInterfaceFactory> service_interface_factory;
|
||||||
NamedPortTable named_ports;
|
NamedPortTable named_ports;
|
||||||
|
std::unordered_set<KServerPort*> server_ports;
|
||||||
|
std::unordered_set<KServerSession*> server_sessions;
|
||||||
|
std::unordered_set<KAutoObject*> registered_objects;
|
||||||
|
std::mutex server_ports_lock;
|
||||||
|
std::mutex server_sessions_lock;
|
||||||
|
std::mutex registered_objects_lock;
|
||||||
|
|
||||||
std::unique_ptr<Core::ExclusiveMonitor> exclusive_monitor;
|
std::unique_ptr<Core::ExclusiveMonitor> exclusive_monitor;
|
||||||
std::vector<Kernel::PhysicalCore> cores;
|
std::vector<Kernel::PhysicalCore> cores;
|
||||||
@ -844,12 +902,27 @@ void KernelCore::RegisterNamedService(std::string name, ServiceInterfaceFactory&
|
|||||||
}
|
}
|
||||||
|
|
||||||
KClientPort* KernelCore::CreateNamedServicePort(std::string name) {
|
KClientPort* KernelCore::CreateNamedServicePort(std::string name) {
|
||||||
auto search = impl->service_interface_factory.find(name);
|
return impl->CreateNamedServicePort(std::move(name));
|
||||||
if (search == impl->service_interface_factory.end()) {
|
}
|
||||||
UNIMPLEMENTED();
|
|
||||||
return {};
|
void KernelCore::RegisterServerSession(KServerSession* server_session) {
|
||||||
}
|
std::lock_guard lk(impl->server_sessions_lock);
|
||||||
return &search->second(impl->system.ServiceManager(), impl->system);
|
impl->server_sessions.insert(server_session);
|
||||||
|
}
|
||||||
|
|
||||||
|
void KernelCore::UnregisterServerSession(KServerSession* server_session) {
|
||||||
|
std::lock_guard lk(impl->server_sessions_lock);
|
||||||
|
impl->server_sessions.erase(server_session);
|
||||||
|
}
|
||||||
|
|
||||||
|
void KernelCore::RegisterKernelObject(KAutoObject* object) {
|
||||||
|
std::lock_guard lk(impl->registered_objects_lock);
|
||||||
|
impl->registered_objects.insert(object);
|
||||||
|
}
|
||||||
|
|
||||||
|
void KernelCore::UnregisterKernelObject(KAutoObject* object) {
|
||||||
|
std::lock_guard lk(impl->registered_objects_lock);
|
||||||
|
impl->registered_objects.erase(object);
|
||||||
}
|
}
|
||||||
|
|
||||||
bool KernelCore::IsValidNamedPort(NamedPortTable::const_iterator port) const {
|
bool KernelCore::IsValidNamedPort(NamedPortTable::const_iterator port) const {
|
||||||
|
@ -45,6 +45,7 @@ class KPort;
|
|||||||
class KProcess;
|
class KProcess;
|
||||||
class KResourceLimit;
|
class KResourceLimit;
|
||||||
class KScheduler;
|
class KScheduler;
|
||||||
|
class KServerSession;
|
||||||
class KSession;
|
class KSession;
|
||||||
class KSharedMemory;
|
class KSharedMemory;
|
||||||
class KThread;
|
class KThread;
|
||||||
@ -185,6 +186,22 @@ public:
|
|||||||
/// Opens a port to a service previously registered with RegisterNamedService.
|
/// Opens a port to a service previously registered with RegisterNamedService.
|
||||||
KClientPort* CreateNamedServicePort(std::string name);
|
KClientPort* CreateNamedServicePort(std::string name);
|
||||||
|
|
||||||
|
/// Registers a server session with the gobal emulation state, to be freed on shutdown. This is
|
||||||
|
/// necessary because we do not emulate processes for HLE sessions.
|
||||||
|
void RegisterServerSession(KServerSession* server_session);
|
||||||
|
|
||||||
|
/// Unregisters a server session previously registered with RegisterServerSession when it was
|
||||||
|
/// destroyed during the current emulation session.
|
||||||
|
void UnregisterServerSession(KServerSession* server_session);
|
||||||
|
|
||||||
|
/// Registers all kernel objects with the global emulation state, this is purely for tracking
|
||||||
|
/// leaks after emulation has been shutdown.
|
||||||
|
void RegisterKernelObject(KAutoObject* object);
|
||||||
|
|
||||||
|
/// Unregisters a kernel object previously registered with RegisterKernelObject when it was
|
||||||
|
/// destroyed during the current emulation session.
|
||||||
|
void UnregisterKernelObject(KAutoObject* object);
|
||||||
|
|
||||||
/// Determines whether or not the given port is a valid named port.
|
/// Determines whether or not the given port is a valid named port.
|
||||||
bool IsValidNamedPort(NamedPortTable::const_iterator port) const;
|
bool IsValidNamedPort(NamedPortTable::const_iterator port) const;
|
||||||
|
|
||||||
|
@ -298,6 +298,7 @@ static ResultCode ConnectToNamedPort(Core::System& system, Handle* out, VAddr po
|
|||||||
// Create a session.
|
// Create a session.
|
||||||
KClientSession* session{};
|
KClientSession* session{};
|
||||||
R_TRY(port->CreateSession(std::addressof(session)));
|
R_TRY(port->CreateSession(std::addressof(session)));
|
||||||
|
port->Close();
|
||||||
|
|
||||||
// Register the session in the table, close the extra reference.
|
// Register the session in the table, close the extra reference.
|
||||||
handle_table.Register(*out, session);
|
handle_table.Register(*out, session);
|
||||||
@ -1439,11 +1440,6 @@ static void ExitProcess(Core::System& system) {
|
|||||||
LOG_INFO(Kernel_SVC, "Process {} exiting", current_process->GetProcessID());
|
LOG_INFO(Kernel_SVC, "Process {} exiting", current_process->GetProcessID());
|
||||||
ASSERT_MSG(current_process->GetStatus() == ProcessStatus::Running,
|
ASSERT_MSG(current_process->GetStatus() == ProcessStatus::Running,
|
||||||
"Process has already exited");
|
"Process has already exited");
|
||||||
|
|
||||||
current_process->PrepareForTermination();
|
|
||||||
|
|
||||||
// Kill the current thread
|
|
||||||
system.Kernel().CurrentScheduler()->GetCurrentThread()->Exit();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
static void ExitProcess32(Core::System& system) {
|
static void ExitProcess32(Core::System& system) {
|
||||||
|
@ -18,6 +18,7 @@
|
|||||||
#include "core/hle/kernel/k_writable_event.h"
|
#include "core/hle/kernel/k_writable_event.h"
|
||||||
#include "core/hle/kernel/kernel.h"
|
#include "core/hle/kernel/kernel.h"
|
||||||
#include "core/hle/service/hid/controllers/npad.h"
|
#include "core/hle/service/hid/controllers/npad.h"
|
||||||
|
#include "core/hle/service/kernel_helpers.h"
|
||||||
|
|
||||||
namespace Service::HID {
|
namespace Service::HID {
|
||||||
constexpr s32 HID_JOYSTICK_MAX = 0x7fff;
|
constexpr s32 HID_JOYSTICK_MAX = 0x7fff;
|
||||||
@ -147,7 +148,9 @@ bool Controller_NPad::IsDeviceHandleValid(const DeviceHandle& device_handle) {
|
|||||||
device_handle.device_index < DeviceIndex::MaxDeviceIndex;
|
device_handle.device_index < DeviceIndex::MaxDeviceIndex;
|
||||||
}
|
}
|
||||||
|
|
||||||
Controller_NPad::Controller_NPad(Core::System& system_) : ControllerBase{system_} {
|
Controller_NPad::Controller_NPad(Core::System& system_,
|
||||||
|
KernelHelpers::ServiceContext& service_context_)
|
||||||
|
: ControllerBase{system_}, service_context{service_context_} {
|
||||||
latest_vibration_values.fill({DEFAULT_VIBRATION_VALUE, DEFAULT_VIBRATION_VALUE});
|
latest_vibration_values.fill({DEFAULT_VIBRATION_VALUE, DEFAULT_VIBRATION_VALUE});
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -251,10 +254,9 @@ void Controller_NPad::InitNewlyAddedController(std::size_t controller_idx) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void Controller_NPad::OnInit() {
|
void Controller_NPad::OnInit() {
|
||||||
auto& kernel = system.Kernel();
|
|
||||||
for (std::size_t i = 0; i < styleset_changed_events.size(); ++i) {
|
for (std::size_t i = 0; i < styleset_changed_events.size(); ++i) {
|
||||||
styleset_changed_events[i] = Kernel::KEvent::Create(kernel);
|
styleset_changed_events[i] =
|
||||||
styleset_changed_events[i]->Initialize(fmt::format("npad:NpadStyleSetChanged_{}", i));
|
service_context.CreateEvent(fmt::format("npad:NpadStyleSetChanged_{}", i));
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!IsControllerActivated()) {
|
if (!IsControllerActivated()) {
|
||||||
@ -344,8 +346,7 @@ void Controller_NPad::OnRelease() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for (std::size_t i = 0; i < styleset_changed_events.size(); ++i) {
|
for (std::size_t i = 0; i < styleset_changed_events.size(); ++i) {
|
||||||
styleset_changed_events[i]->Close();
|
service_context.CloseEvent(styleset_changed_events[i]);
|
||||||
styleset_changed_events[i] = nullptr;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -20,6 +20,10 @@ class KEvent;
|
|||||||
class KReadableEvent;
|
class KReadableEvent;
|
||||||
} // namespace Kernel
|
} // namespace Kernel
|
||||||
|
|
||||||
|
namespace Service::KernelHelpers {
|
||||||
|
class ServiceContext;
|
||||||
|
}
|
||||||
|
|
||||||
namespace Service::HID {
|
namespace Service::HID {
|
||||||
|
|
||||||
constexpr u32 NPAD_HANDHELD = 32;
|
constexpr u32 NPAD_HANDHELD = 32;
|
||||||
@ -27,7 +31,8 @@ constexpr u32 NPAD_UNKNOWN = 16; // TODO(ogniK): What is this?
|
|||||||
|
|
||||||
class Controller_NPad final : public ControllerBase {
|
class Controller_NPad final : public ControllerBase {
|
||||||
public:
|
public:
|
||||||
explicit Controller_NPad(Core::System& system_);
|
explicit Controller_NPad(Core::System& system_,
|
||||||
|
KernelHelpers::ServiceContext& service_context_);
|
||||||
~Controller_NPad() override;
|
~Controller_NPad() override;
|
||||||
|
|
||||||
// Called when the controller is initialized
|
// Called when the controller is initialized
|
||||||
@ -566,6 +571,7 @@ private:
|
|||||||
std::array<std::unique_ptr<Input::MotionDevice>, Settings::NativeMotion::NUM_MOTIONS_HID>,
|
std::array<std::unique_ptr<Input::MotionDevice>, Settings::NativeMotion::NUM_MOTIONS_HID>,
|
||||||
10>;
|
10>;
|
||||||
|
|
||||||
|
KernelHelpers::ServiceContext& service_context;
|
||||||
std::mutex mutex;
|
std::mutex mutex;
|
||||||
ButtonArray buttons;
|
ButtonArray buttons;
|
||||||
StickArray sticks;
|
StickArray sticks;
|
||||||
|
@ -46,8 +46,9 @@ constexpr auto pad_update_ns = std::chrono::nanoseconds{1000 * 1000}; //
|
|||||||
constexpr auto motion_update_ns = std::chrono::nanoseconds{15 * 1000 * 1000}; // (15ms, 66.666Hz)
|
constexpr auto motion_update_ns = std::chrono::nanoseconds{15 * 1000 * 1000}; // (15ms, 66.666Hz)
|
||||||
constexpr std::size_t SHARED_MEMORY_SIZE = 0x40000;
|
constexpr std::size_t SHARED_MEMORY_SIZE = 0x40000;
|
||||||
|
|
||||||
IAppletResource::IAppletResource(Core::System& system_)
|
IAppletResource::IAppletResource(Core::System& system_,
|
||||||
: ServiceFramework{system_, "IAppletResource"} {
|
KernelHelpers::ServiceContext& service_context_)
|
||||||
|
: ServiceFramework{system_, "IAppletResource"}, service_context{service_context_} {
|
||||||
static const FunctionInfo functions[] = {
|
static const FunctionInfo functions[] = {
|
||||||
{0, &IAppletResource::GetSharedMemoryHandle, "GetSharedMemoryHandle"},
|
{0, &IAppletResource::GetSharedMemoryHandle, "GetSharedMemoryHandle"},
|
||||||
};
|
};
|
||||||
@ -63,7 +64,7 @@ IAppletResource::IAppletResource(Core::System& system_)
|
|||||||
MakeController<Controller_Stubbed>(HidController::CaptureButton);
|
MakeController<Controller_Stubbed>(HidController::CaptureButton);
|
||||||
MakeController<Controller_Stubbed>(HidController::InputDetector);
|
MakeController<Controller_Stubbed>(HidController::InputDetector);
|
||||||
MakeController<Controller_Stubbed>(HidController::UniquePad);
|
MakeController<Controller_Stubbed>(HidController::UniquePad);
|
||||||
MakeController<Controller_NPad>(HidController::NPad);
|
MakeControllerWithServiceContext<Controller_NPad>(HidController::NPad);
|
||||||
MakeController<Controller_Gesture>(HidController::Gesture);
|
MakeController<Controller_Gesture>(HidController::Gesture);
|
||||||
MakeController<Controller_ConsoleSixAxis>(HidController::ConsoleSixAxisSensor);
|
MakeController<Controller_ConsoleSixAxis>(HidController::ConsoleSixAxisSensor);
|
||||||
|
|
||||||
@ -191,13 +192,14 @@ private:
|
|||||||
|
|
||||||
std::shared_ptr<IAppletResource> Hid::GetAppletResource() {
|
std::shared_ptr<IAppletResource> Hid::GetAppletResource() {
|
||||||
if (applet_resource == nullptr) {
|
if (applet_resource == nullptr) {
|
||||||
applet_resource = std::make_shared<IAppletResource>(system);
|
applet_resource = std::make_shared<IAppletResource>(system, service_context);
|
||||||
}
|
}
|
||||||
|
|
||||||
return applet_resource;
|
return applet_resource;
|
||||||
}
|
}
|
||||||
|
|
||||||
Hid::Hid(Core::System& system_) : ServiceFramework{system_, "hid"} {
|
Hid::Hid(Core::System& system_)
|
||||||
|
: ServiceFramework{system_, "hid"}, service_context{system_, service_name} {
|
||||||
// clang-format off
|
// clang-format off
|
||||||
static const FunctionInfo functions[] = {
|
static const FunctionInfo functions[] = {
|
||||||
{0, &Hid::CreateAppletResource, "CreateAppletResource"},
|
{0, &Hid::CreateAppletResource, "CreateAppletResource"},
|
||||||
@ -347,7 +349,7 @@ void Hid::CreateAppletResource(Kernel::HLERequestContext& ctx) {
|
|||||||
LOG_DEBUG(Service_HID, "called, applet_resource_user_id={}", applet_resource_user_id);
|
LOG_DEBUG(Service_HID, "called, applet_resource_user_id={}", applet_resource_user_id);
|
||||||
|
|
||||||
if (applet_resource == nullptr) {
|
if (applet_resource == nullptr) {
|
||||||
applet_resource = std::make_shared<IAppletResource>(system);
|
applet_resource = std::make_shared<IAppletResource>(system, service_context);
|
||||||
}
|
}
|
||||||
|
|
||||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1};
|
IPC::ResponseBuilder rb{ctx, 2, 0, 1};
|
||||||
|
@ -7,6 +7,7 @@
|
|||||||
#include <chrono>
|
#include <chrono>
|
||||||
|
|
||||||
#include "core/hle/service/hid/controllers/controller_base.h"
|
#include "core/hle/service/hid/controllers/controller_base.h"
|
||||||
|
#include "core/hle/service/kernel_helpers.h"
|
||||||
#include "core/hle/service/service.h"
|
#include "core/hle/service/service.h"
|
||||||
|
|
||||||
namespace Core::Timing {
|
namespace Core::Timing {
|
||||||
@ -39,7 +40,8 @@ enum class HidController : std::size_t {
|
|||||||
|
|
||||||
class IAppletResource final : public ServiceFramework<IAppletResource> {
|
class IAppletResource final : public ServiceFramework<IAppletResource> {
|
||||||
public:
|
public:
|
||||||
explicit IAppletResource(Core::System& system_);
|
explicit IAppletResource(Core::System& system_,
|
||||||
|
KernelHelpers::ServiceContext& service_context_);
|
||||||
~IAppletResource() override;
|
~IAppletResource() override;
|
||||||
|
|
||||||
void ActivateController(HidController controller);
|
void ActivateController(HidController controller);
|
||||||
@ -60,11 +62,18 @@ private:
|
|||||||
void MakeController(HidController controller) {
|
void MakeController(HidController controller) {
|
||||||
controllers[static_cast<std::size_t>(controller)] = std::make_unique<T>(system);
|
controllers[static_cast<std::size_t>(controller)] = std::make_unique<T>(system);
|
||||||
}
|
}
|
||||||
|
template <typename T>
|
||||||
|
void MakeControllerWithServiceContext(HidController controller) {
|
||||||
|
controllers[static_cast<std::size_t>(controller)] =
|
||||||
|
std::make_unique<T>(system, service_context);
|
||||||
|
}
|
||||||
|
|
||||||
void GetSharedMemoryHandle(Kernel::HLERequestContext& ctx);
|
void GetSharedMemoryHandle(Kernel::HLERequestContext& ctx);
|
||||||
void UpdateControllers(std::uintptr_t user_data, std::chrono::nanoseconds ns_late);
|
void UpdateControllers(std::uintptr_t user_data, std::chrono::nanoseconds ns_late);
|
||||||
void UpdateMotion(std::uintptr_t user_data, std::chrono::nanoseconds ns_late);
|
void UpdateMotion(std::uintptr_t user_data, std::chrono::nanoseconds ns_late);
|
||||||
|
|
||||||
|
KernelHelpers::ServiceContext& service_context;
|
||||||
|
|
||||||
std::shared_ptr<Core::Timing::EventType> pad_update_event;
|
std::shared_ptr<Core::Timing::EventType> pad_update_event;
|
||||||
std::shared_ptr<Core::Timing::EventType> motion_update_event;
|
std::shared_ptr<Core::Timing::EventType> motion_update_event;
|
||||||
|
|
||||||
@ -176,6 +185,8 @@ private:
|
|||||||
static_assert(sizeof(VibrationDeviceInfo) == 0x8, "VibrationDeviceInfo has incorrect size.");
|
static_assert(sizeof(VibrationDeviceInfo) == 0x8, "VibrationDeviceInfo has incorrect size.");
|
||||||
|
|
||||||
std::shared_ptr<IAppletResource> applet_resource;
|
std::shared_ptr<IAppletResource> applet_resource;
|
||||||
|
|
||||||
|
KernelHelpers::ServiceContext service_context;
|
||||||
};
|
};
|
||||||
|
|
||||||
/// Reload input devices. Used when input configuration changed
|
/// Reload input devices. Used when input configuration changed
|
||||||
|
62
src/core/hle/service/kernel_helpers.cpp
Normal file
62
src/core/hle/service/kernel_helpers.cpp
Normal file
@ -0,0 +1,62 @@
|
|||||||
|
// Copyright 2021 yuzu emulator team
|
||||||
|
// Licensed under GPLv2 or any later version
|
||||||
|
// Refer to the license.txt file included.
|
||||||
|
|
||||||
|
#include "core/core.h"
|
||||||
|
#include "core/hle/kernel/k_event.h"
|
||||||
|
#include "core/hle/kernel/k_process.h"
|
||||||
|
#include "core/hle/kernel/k_readable_event.h"
|
||||||
|
#include "core/hle/kernel/k_resource_limit.h"
|
||||||
|
#include "core/hle/kernel/k_scoped_resource_reservation.h"
|
||||||
|
#include "core/hle/kernel/k_writable_event.h"
|
||||||
|
#include "core/hle/service/kernel_helpers.h"
|
||||||
|
|
||||||
|
namespace Service::KernelHelpers {
|
||||||
|
|
||||||
|
ServiceContext::ServiceContext(Core::System& system_, std::string name_)
|
||||||
|
: kernel(system_.Kernel()) {
|
||||||
|
process = Kernel::KProcess::Create(kernel);
|
||||||
|
ASSERT(Kernel::KProcess::Initialize(process, system_, std::move(name_),
|
||||||
|
Kernel::KProcess::ProcessType::Userland)
|
||||||
|
.IsSuccess());
|
||||||
|
}
|
||||||
|
|
||||||
|
ServiceContext::~ServiceContext() {
|
||||||
|
process->Close();
|
||||||
|
process = nullptr;
|
||||||
|
}
|
||||||
|
|
||||||
|
Kernel::KEvent* ServiceContext::CreateEvent(std::string&& name) {
|
||||||
|
// Reserve a new event from the process resource limit
|
||||||
|
Kernel::KScopedResourceReservation event_reservation(process,
|
||||||
|
Kernel::LimitableResource::Events);
|
||||||
|
if (!event_reservation.Succeeded()) {
|
||||||
|
LOG_CRITICAL(Service, "Resource limit reached!");
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
// Create a new event.
|
||||||
|
auto* event = Kernel::KEvent::Create(kernel);
|
||||||
|
if (!event) {
|
||||||
|
LOG_CRITICAL(Service, "Unable to create event!");
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
// Initialize the event.
|
||||||
|
event->Initialize(std::move(name));
|
||||||
|
|
||||||
|
// Commit the thread reservation.
|
||||||
|
event_reservation.Commit();
|
||||||
|
|
||||||
|
// Register the event.
|
||||||
|
Kernel::KEvent::Register(kernel, event);
|
||||||
|
|
||||||
|
return event;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ServiceContext::CloseEvent(Kernel::KEvent* event) {
|
||||||
|
event->GetReadableEvent().Close();
|
||||||
|
event->GetWritableEvent().Close();
|
||||||
|
}
|
||||||
|
|
||||||
|
} // namespace Service::KernelHelpers
|
35
src/core/hle/service/kernel_helpers.h
Normal file
35
src/core/hle/service/kernel_helpers.h
Normal file
@ -0,0 +1,35 @@
|
|||||||
|
// Copyright 2021 yuzu emulator team
|
||||||
|
// Licensed under GPLv2 or any later version
|
||||||
|
// Refer to the license.txt file included.
|
||||||
|
|
||||||
|
#pragma once
|
||||||
|
|
||||||
|
#include <string>
|
||||||
|
|
||||||
|
namespace Core {
|
||||||
|
class System;
|
||||||
|
}
|
||||||
|
|
||||||
|
namespace Kernel {
|
||||||
|
class KernelCore;
|
||||||
|
class KEvent;
|
||||||
|
class KProcess;
|
||||||
|
} // namespace Kernel
|
||||||
|
|
||||||
|
namespace Service::KernelHelpers {
|
||||||
|
|
||||||
|
class ServiceContext {
|
||||||
|
public:
|
||||||
|
ServiceContext(Core::System& system_, std::string name_);
|
||||||
|
~ServiceContext();
|
||||||
|
|
||||||
|
Kernel::KEvent* CreateEvent(std::string&& name);
|
||||||
|
|
||||||
|
void CloseEvent(Kernel::KEvent* event);
|
||||||
|
|
||||||
|
private:
|
||||||
|
Kernel::KernelCore& kernel;
|
||||||
|
Kernel::KProcess* process{};
|
||||||
|
};
|
||||||
|
|
||||||
|
} // namespace Service::KernelHelpers
|
@ -39,11 +39,11 @@ void InstallInterfaces(SM::ServiceManager& service_manager, NVFlinger::NVFlinger
|
|||||||
nvflinger.SetNVDrvInstance(module_);
|
nvflinger.SetNVDrvInstance(module_);
|
||||||
}
|
}
|
||||||
|
|
||||||
Module::Module(Core::System& system) : syncpoint_manager{system.GPU()} {
|
Module::Module(Core::System& system)
|
||||||
auto& kernel = system.Kernel();
|
: syncpoint_manager{system.GPU()}, service_context{system, "nvdrv"} {
|
||||||
for (u32 i = 0; i < MaxNvEvents; i++) {
|
for (u32 i = 0; i < MaxNvEvents; i++) {
|
||||||
events_interface.events[i].event = Kernel::KEvent::Create(kernel);
|
events_interface.events[i].event =
|
||||||
events_interface.events[i].event->Initialize(fmt::format("NVDRV::NvEvent_{}", i));
|
service_context.CreateEvent(fmt::format("NVDRV::NvEvent_{}", i));
|
||||||
events_interface.status[i] = EventState::Free;
|
events_interface.status[i] = EventState::Free;
|
||||||
events_interface.registered[i] = false;
|
events_interface.registered[i] = false;
|
||||||
}
|
}
|
||||||
@ -65,8 +65,7 @@ Module::Module(Core::System& system) : syncpoint_manager{system.GPU()} {
|
|||||||
|
|
||||||
Module::~Module() {
|
Module::~Module() {
|
||||||
for (u32 i = 0; i < MaxNvEvents; i++) {
|
for (u32 i = 0; i < MaxNvEvents; i++) {
|
||||||
events_interface.events[i].event->Close();
|
service_context.CloseEvent(events_interface.events[i].event);
|
||||||
events_interface.events[i].event = nullptr;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -9,6 +9,7 @@
|
|||||||
#include <vector>
|
#include <vector>
|
||||||
|
|
||||||
#include "common/common_types.h"
|
#include "common/common_types.h"
|
||||||
|
#include "core/hle/service/kernel_helpers.h"
|
||||||
#include "core/hle/service/nvdrv/nvdata.h"
|
#include "core/hle/service/nvdrv/nvdata.h"
|
||||||
#include "core/hle/service/nvdrv/syncpoint_manager.h"
|
#include "core/hle/service/nvdrv/syncpoint_manager.h"
|
||||||
#include "core/hle/service/service.h"
|
#include "core/hle/service/service.h"
|
||||||
@ -154,6 +155,8 @@ private:
|
|||||||
std::unordered_map<std::string, std::shared_ptr<Devices::nvdevice>> devices;
|
std::unordered_map<std::string, std::shared_ptr<Devices::nvdevice>> devices;
|
||||||
|
|
||||||
EventInterface events_interface;
|
EventInterface events_interface;
|
||||||
|
|
||||||
|
KernelHelpers::ServiceContext service_context;
|
||||||
};
|
};
|
||||||
|
|
||||||
/// Registers all NVDRV services with the specified service manager.
|
/// Registers all NVDRV services with the specified service manager.
|
||||||
|
@ -104,23 +104,22 @@ ServiceFrameworkBase::~ServiceFrameworkBase() {
|
|||||||
void ServiceFrameworkBase::InstallAsService(SM::ServiceManager& service_manager) {
|
void ServiceFrameworkBase::InstallAsService(SM::ServiceManager& service_manager) {
|
||||||
const auto guard = LockService();
|
const auto guard = LockService();
|
||||||
|
|
||||||
ASSERT(!port_installed);
|
ASSERT(!service_registered);
|
||||||
|
|
||||||
auto port = service_manager.RegisterService(service_name, max_sessions).Unwrap();
|
service_manager.RegisterService(service_name, max_sessions, shared_from_this());
|
||||||
port->SetSessionHandler(shared_from_this());
|
service_registered = true;
|
||||||
port_installed = true;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
Kernel::KClientPort& ServiceFrameworkBase::CreatePort() {
|
Kernel::KClientPort& ServiceFrameworkBase::CreatePort() {
|
||||||
const auto guard = LockService();
|
const auto guard = LockService();
|
||||||
|
|
||||||
ASSERT(!port_installed);
|
ASSERT(!service_registered);
|
||||||
|
|
||||||
auto* port = Kernel::KPort::Create(kernel);
|
auto* port = Kernel::KPort::Create(kernel);
|
||||||
port->Initialize(max_sessions, false, service_name);
|
port->Initialize(max_sessions, false, service_name);
|
||||||
port->GetServerPort().SetSessionHandler(shared_from_this());
|
port->GetServerPort().SetSessionHandler(shared_from_this());
|
||||||
|
|
||||||
port_installed = true;
|
service_registered = true;
|
||||||
|
|
||||||
return port->GetClientPort();
|
return port->GetClientPort();
|
||||||
}
|
}
|
||||||
|
@ -96,6 +96,9 @@ protected:
|
|||||||
/// System context that the service operates under.
|
/// System context that the service operates under.
|
||||||
Core::System& system;
|
Core::System& system;
|
||||||
|
|
||||||
|
/// Identifier string used to connect to the service.
|
||||||
|
std::string service_name;
|
||||||
|
|
||||||
private:
|
private:
|
||||||
template <typename T>
|
template <typename T>
|
||||||
friend class ServiceFramework;
|
friend class ServiceFramework;
|
||||||
@ -117,14 +120,12 @@ private:
|
|||||||
void RegisterHandlersBaseTipc(const FunctionInfoBase* functions, std::size_t n);
|
void RegisterHandlersBaseTipc(const FunctionInfoBase* functions, std::size_t n);
|
||||||
void ReportUnimplementedFunction(Kernel::HLERequestContext& ctx, const FunctionInfoBase* info);
|
void ReportUnimplementedFunction(Kernel::HLERequestContext& ctx, const FunctionInfoBase* info);
|
||||||
|
|
||||||
/// Identifier string used to connect to the service.
|
|
||||||
std::string service_name;
|
|
||||||
/// Maximum number of concurrent sessions that this service can handle.
|
/// Maximum number of concurrent sessions that this service can handle.
|
||||||
u32 max_sessions;
|
u32 max_sessions;
|
||||||
|
|
||||||
/// Flag to store if a port was already create/installed to detect multiple install attempts,
|
/// Flag to store if a port was already create/installed to detect multiple install attempts,
|
||||||
/// which is not supported.
|
/// which is not supported.
|
||||||
bool port_installed = false;
|
bool service_registered = false;
|
||||||
|
|
||||||
/// Function used to safely up-cast pointers to the derived class before invoking a handler.
|
/// Function used to safely up-cast pointers to the derived class before invoking a handler.
|
||||||
InvokerFn* handler_invoker;
|
InvokerFn* handler_invoker;
|
||||||
|
@ -4,6 +4,7 @@
|
|||||||
|
|
||||||
#include <tuple>
|
#include <tuple>
|
||||||
#include "common/assert.h"
|
#include "common/assert.h"
|
||||||
|
#include "common/scope_exit.h"
|
||||||
#include "core/core.h"
|
#include "core/core.h"
|
||||||
#include "core/hle/ipc_helpers.h"
|
#include "core/hle/ipc_helpers.h"
|
||||||
#include "core/hle/kernel/k_client_port.h"
|
#include "core/hle/kernel/k_client_port.h"
|
||||||
@ -40,17 +41,13 @@ static ResultCode ValidateServiceName(const std::string& name) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
Kernel::KClientPort& ServiceManager::InterfaceFactory(ServiceManager& self, Core::System& system) {
|
Kernel::KClientPort& ServiceManager::InterfaceFactory(ServiceManager& self, Core::System& system) {
|
||||||
ASSERT(self.sm_interface.expired());
|
self.sm_interface = std::make_shared<SM>(self, system);
|
||||||
|
|
||||||
auto sm = std::make_shared<SM>(self, system);
|
|
||||||
self.sm_interface = sm;
|
|
||||||
self.controller_interface = std::make_unique<Controller>(system);
|
self.controller_interface = std::make_unique<Controller>(system);
|
||||||
|
return self.sm_interface->CreatePort();
|
||||||
return sm->CreatePort();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
ResultVal<Kernel::KServerPort*> ServiceManager::RegisterService(std::string name,
|
ResultCode ServiceManager::RegisterService(std::string name, u32 max_sessions,
|
||||||
u32 max_sessions) {
|
Kernel::SessionRequestHandlerPtr handler) {
|
||||||
|
|
||||||
CASCADE_CODE(ValidateServiceName(name));
|
CASCADE_CODE(ValidateServiceName(name));
|
||||||
|
|
||||||
@ -59,12 +56,9 @@ ResultVal<Kernel::KServerPort*> ServiceManager::RegisterService(std::string name
|
|||||||
return ERR_ALREADY_REGISTERED;
|
return ERR_ALREADY_REGISTERED;
|
||||||
}
|
}
|
||||||
|
|
||||||
auto* port = Kernel::KPort::Create(kernel);
|
registered_services.emplace(std::move(name), handler);
|
||||||
port->Initialize(max_sessions, false, name);
|
|
||||||
|
|
||||||
registered_services.emplace(std::move(name), port);
|
return ResultSuccess;
|
||||||
|
|
||||||
return MakeResult(&port->GetServerPort());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
ResultCode ServiceManager::UnregisterService(const std::string& name) {
|
ResultCode ServiceManager::UnregisterService(const std::string& name) {
|
||||||
@ -76,14 +70,11 @@ ResultCode ServiceManager::UnregisterService(const std::string& name) {
|
|||||||
return ERR_SERVICE_NOT_REGISTERED;
|
return ERR_SERVICE_NOT_REGISTERED;
|
||||||
}
|
}
|
||||||
|
|
||||||
iter->second->Close();
|
|
||||||
|
|
||||||
registered_services.erase(iter);
|
registered_services.erase(iter);
|
||||||
return ResultSuccess;
|
return ResultSuccess;
|
||||||
}
|
}
|
||||||
|
|
||||||
ResultVal<Kernel::KPort*> ServiceManager::GetServicePort(const std::string& name) {
|
ResultVal<Kernel::KPort*> ServiceManager::GetServicePort(const std::string& name) {
|
||||||
|
|
||||||
CASCADE_CODE(ValidateServiceName(name));
|
CASCADE_CODE(ValidateServiceName(name));
|
||||||
auto it = registered_services.find(name);
|
auto it = registered_services.find(name);
|
||||||
if (it == registered_services.end()) {
|
if (it == registered_services.end()) {
|
||||||
@ -91,10 +82,13 @@ ResultVal<Kernel::KPort*> ServiceManager::GetServicePort(const std::string& name
|
|||||||
return ERR_SERVICE_NOT_REGISTERED;
|
return ERR_SERVICE_NOT_REGISTERED;
|
||||||
}
|
}
|
||||||
|
|
||||||
return MakeResult(it->second);
|
auto* port = Kernel::KPort::Create(kernel);
|
||||||
}
|
port->Initialize(ServerSessionCountMax, false, name);
|
||||||
|
auto handler = it->second;
|
||||||
|
port->GetServerPort().SetSessionHandler(std::move(handler));
|
||||||
|
|
||||||
SM::~SM() = default;
|
return MakeResult(port);
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* SM::Initialize service function
|
* SM::Initialize service function
|
||||||
@ -156,11 +150,15 @@ ResultVal<Kernel::KClientSession*> SM::GetServiceImpl(Kernel::HLERequestContext&
|
|||||||
LOG_ERROR(Service_SM, "called service={} -> error 0x{:08X}", name, port_result.Code().raw);
|
LOG_ERROR(Service_SM, "called service={} -> error 0x{:08X}", name, port_result.Code().raw);
|
||||||
return port_result.Code();
|
return port_result.Code();
|
||||||
}
|
}
|
||||||
auto& port = port_result.Unwrap()->GetClientPort();
|
auto& port = port_result.Unwrap();
|
||||||
|
SCOPE_EXIT({ port->GetClientPort().Close(); });
|
||||||
|
|
||||||
|
server_ports.emplace_back(&port->GetServerPort());
|
||||||
|
|
||||||
// Create a new session.
|
// Create a new session.
|
||||||
Kernel::KClientSession* session{};
|
Kernel::KClientSession* session{};
|
||||||
if (const auto result = port.CreateSession(std::addressof(session)); result.IsError()) {
|
if (const auto result = port->GetClientPort().CreateSession(std::addressof(session));
|
||||||
|
result.IsError()) {
|
||||||
LOG_ERROR(Service_SM, "called service={} -> error 0x{:08X}", name, result.raw);
|
LOG_ERROR(Service_SM, "called service={} -> error 0x{:08X}", name, result.raw);
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
@ -180,20 +178,21 @@ void SM::RegisterService(Kernel::HLERequestContext& ctx) {
|
|||||||
LOG_DEBUG(Service_SM, "called with name={}, max_session_count={}, is_light={}", name,
|
LOG_DEBUG(Service_SM, "called with name={}, max_session_count={}, is_light={}", name,
|
||||||
max_session_count, is_light);
|
max_session_count, is_light);
|
||||||
|
|
||||||
auto handle = service_manager.RegisterService(name, max_session_count);
|
if (const auto result = service_manager.RegisterService(name, max_session_count, nullptr);
|
||||||
if (handle.Failed()) {
|
result.IsError()) {
|
||||||
LOG_ERROR(Service_SM, "failed to register service with error_code={:08X}",
|
LOG_ERROR(Service_SM, "failed to register service with error_code={:08X}", result.raw);
|
||||||
handle.Code().raw);
|
|
||||||
IPC::ResponseBuilder rb{ctx, 2};
|
IPC::ResponseBuilder rb{ctx, 2};
|
||||||
rb.Push(handle.Code());
|
rb.Push(result);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
IPC::ResponseBuilder rb{ctx, 2, 0, 1, IPC::ResponseBuilder::Flags::AlwaysMoveHandles};
|
auto* port = Kernel::KPort::Create(kernel);
|
||||||
rb.Push(handle.Code());
|
port->Initialize(ServerSessionCountMax, is_light, name);
|
||||||
|
SCOPE_EXIT({ port->GetClientPort().Close(); });
|
||||||
|
|
||||||
auto server_port = handle.Unwrap();
|
IPC::ResponseBuilder rb{ctx, 2, 0, 1, IPC::ResponseBuilder::Flags::AlwaysMoveHandles};
|
||||||
rb.PushMoveObjects(server_port);
|
rb.Push(ResultSuccess);
|
||||||
|
rb.PushMoveObjects(port->GetServerPort());
|
||||||
}
|
}
|
||||||
|
|
||||||
void SM::UnregisterService(Kernel::HLERequestContext& ctx) {
|
void SM::UnregisterService(Kernel::HLERequestContext& ctx) {
|
||||||
@ -225,4 +224,10 @@ SM::SM(ServiceManager& service_manager_, Core::System& system_)
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
SM::~SM() {
|
||||||
|
for (auto& server_port : server_ports) {
|
||||||
|
server_port->Close();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
} // namespace Service::SM
|
} // namespace Service::SM
|
||||||
|
@ -49,6 +49,7 @@ private:
|
|||||||
ServiceManager& service_manager;
|
ServiceManager& service_manager;
|
||||||
bool is_initialized{};
|
bool is_initialized{};
|
||||||
Kernel::KernelCore& kernel;
|
Kernel::KernelCore& kernel;
|
||||||
|
std::vector<Kernel::KServerPort*> server_ports;
|
||||||
};
|
};
|
||||||
|
|
||||||
class ServiceManager {
|
class ServiceManager {
|
||||||
@ -58,7 +59,8 @@ public:
|
|||||||
explicit ServiceManager(Kernel::KernelCore& kernel_);
|
explicit ServiceManager(Kernel::KernelCore& kernel_);
|
||||||
~ServiceManager();
|
~ServiceManager();
|
||||||
|
|
||||||
ResultVal<Kernel::KServerPort*> RegisterService(std::string name, u32 max_sessions);
|
ResultCode RegisterService(std::string name, u32 max_sessions,
|
||||||
|
Kernel::SessionRequestHandlerPtr handler);
|
||||||
ResultCode UnregisterService(const std::string& name);
|
ResultCode UnregisterService(const std::string& name);
|
||||||
ResultVal<Kernel::KPort*> GetServicePort(const std::string& name);
|
ResultVal<Kernel::KPort*> GetServicePort(const std::string& name);
|
||||||
|
|
||||||
@ -69,21 +71,17 @@ public:
|
|||||||
LOG_DEBUG(Service, "Can't find service: {}", service_name);
|
LOG_DEBUG(Service, "Can't find service: {}", service_name);
|
||||||
return nullptr;
|
return nullptr;
|
||||||
}
|
}
|
||||||
auto* port = service->second;
|
return std::static_pointer_cast<T>(service->second);
|
||||||
if (port == nullptr) {
|
|
||||||
return nullptr;
|
|
||||||
}
|
|
||||||
return std::static_pointer_cast<T>(port->GetServerPort().GetSessionRequestHandler());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
void InvokeControlRequest(Kernel::HLERequestContext& context);
|
void InvokeControlRequest(Kernel::HLERequestContext& context);
|
||||||
|
|
||||||
private:
|
private:
|
||||||
std::weak_ptr<SM> sm_interface;
|
std::shared_ptr<SM> sm_interface;
|
||||||
std::unique_ptr<Controller> controller_interface;
|
std::unique_ptr<Controller> controller_interface;
|
||||||
|
|
||||||
/// Map of registered services, retrieved using GetServicePort.
|
/// Map of registered services, retrieved using GetServicePort.
|
||||||
std::unordered_map<std::string, Kernel::KPort*> registered_services;
|
std::unordered_map<std::string, Kernel::SessionRequestHandlerPtr> registered_services;
|
||||||
|
|
||||||
/// Kernel context
|
/// Kernel context
|
||||||
Kernel::KernelCore& kernel;
|
Kernel::KernelCore& kernel;
|
||||||
|
Loading…
Reference in New Issue
Block a user