mirror of
https://github.com/Atmosphere-NX/Atmosphere.git
synced 2024-11-27 06:12:15 +00:00
58 lines
1.4 KiB
C++
58 lines
1.4 KiB
C++
#pragma once
|
|
#include <switch.h>
|
|
#include <stratosphere.hpp>
|
|
|
|
class ProcessWaiter final : public IWaitable {
|
|
public:
|
|
std::shared_ptr<Registration::Process> process;
|
|
|
|
ProcessWaiter(std::shared_ptr<Registration::Process> p) : process(p) {
|
|
/* ... */
|
|
}
|
|
|
|
std::shared_ptr<Registration::Process> get_process() {
|
|
return this->process;
|
|
}
|
|
|
|
/* IWaitable */
|
|
Handle get_handle() override {
|
|
return this->process->handle;
|
|
}
|
|
|
|
void handle_deferred() override {
|
|
/* TODO: Panic, because we can never be deferred. */
|
|
}
|
|
|
|
Result handle_signaled(u64 timeout) override {
|
|
return Registration::HandleSignaledProcess(this->get_process());
|
|
}
|
|
};
|
|
|
|
class ProcessList final {
|
|
private:
|
|
HosRecursiveMutex mutex;
|
|
WaitableManager *manager;
|
|
public:
|
|
std::vector<std::shared_ptr<Registration::Process>> processes;
|
|
|
|
void Lock() {
|
|
this->mutex.Lock();
|
|
}
|
|
|
|
void Unlock() {
|
|
this->mutex.Unlock();
|
|
}
|
|
|
|
bool TryLock() {
|
|
return this->mutex.TryLock();
|
|
}
|
|
|
|
void set_manager(WaitableManager *manager) {
|
|
this->manager = manager;
|
|
}
|
|
|
|
WaitableManager *get_manager() {
|
|
return this->manager;
|
|
}
|
|
};
|
|
|