mirror of
https://github.com/shadps4-emu/shadPS4.git
synced 2025-08-06 09:22:35 +00:00
c4506da0ae
* libkernel: Cleanup some function places * kernel: Refactor thread functions * kernel: It builds * kernel: Fix a bunch of bugs, kernel thread heap * kernel: File cleanup pt1 * File cleanup pt2 * File cleanup pt3 * File cleanup pt4 * kernel: Add missing funcs * kernel: Add basic exceptions for linux * gnmdriver: Add workload functions * kernel: Fix new pthreads code on macOS. (#1441) * kernel: Downgrade edeadlk to log * gnmdriver: Add sceGnmSubmitCommandBuffersForWorkload * exception: Add context register population for macOS. (#1444) * kernel: Pthread rewrite touchups for Windows * kernel: Multiplatform thread implementation * mutex: Remove spamming log * pthread_spec: Make assert into a log * pthread_spec: Zero initialize array * Attempt to fix non-Windows builds * hotfix: change incorrect NID for scePthreadAttrSetaffinity * scePthreadAttrSetaffinity implementation * Attempt to fix Linux * windows: Address a bunch of address space problems * address_space: Fix unmap of region surrounded by placeholders * libs: Reduce logging * pthread: Implement condvar with waitable atomics and sleepqueue * sleepq: Separate and make faster * time: Remove delay execution * Causes high cpu usage in Tohou Luna Nights * kernel: Cleanup files again * pthread: Add missing include * semaphore: Use binary_semaphore instead of condvar * Seems more reliable * libraries/sysmodule: log module on `sceSysmoduleIsLoaded` * libraries/kernel: implement `scePthreadSetPrio` --------- Co-authored-by: squidbus <175574877+squidbus@users.noreply.github.com> Co-authored-by: Daniel R. <47796739+polybiusproxy@users.noreply.github.com>
128 lines
2.8 KiB
C++
128 lines
2.8 KiB
C++
// SPDX-FileCopyrightText: Copyright 2024 shadPS4 Emulator Project
|
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
|
|
|
#pragma once
|
|
|
|
#include <condition_variable>
|
|
#include <mutex>
|
|
#include <string>
|
|
#include <vector>
|
|
#include <boost/asio/steady_timer.hpp>
|
|
|
|
#include "common/types.h"
|
|
|
|
namespace Core::Loader {
|
|
class SymbolsResolver;
|
|
}
|
|
|
|
namespace Libraries::Kernel {
|
|
|
|
class EqueueInternal;
|
|
struct EqueueEvent;
|
|
|
|
struct SceKernelEvent {
|
|
enum Filter : s16 {
|
|
None = 0,
|
|
Read = -1,
|
|
Write = -2,
|
|
Aio = -3,
|
|
Vnode = -4,
|
|
Proc = -5,
|
|
Signal = -6,
|
|
Timer = -7,
|
|
Fs = -9,
|
|
Lio = -10,
|
|
User = -11,
|
|
Polling = -12,
|
|
VideoOut = -13,
|
|
GraphicsCore = -14,
|
|
HrTimer = -15,
|
|
};
|
|
|
|
enum Flags : u16 {
|
|
Add = 1u,
|
|
Delete = 2u,
|
|
Enable = 4u,
|
|
Disable = 8u,
|
|
OneShot = 0x10u,
|
|
Clear = 0x20u,
|
|
Receipt = 0x40u,
|
|
Dispatch = 0x80u,
|
|
Flag1 = 0x2000u,
|
|
System = 0xf000u,
|
|
};
|
|
|
|
u64 ident = 0; /* identifier for this event */
|
|
Filter filter = Filter::None; /* filter for event */
|
|
u16 flags = 0;
|
|
u32 fflags = 0;
|
|
u64 data = 0;
|
|
void* udata = nullptr; /* opaque user data identifier */
|
|
};
|
|
|
|
struct EqueueEvent {
|
|
SceKernelEvent event;
|
|
void* data = nullptr;
|
|
std::chrono::steady_clock::time_point time_added;
|
|
std::unique_ptr<boost::asio::steady_timer> timer;
|
|
|
|
void Reset() {
|
|
is_triggered = false;
|
|
event.fflags = 0;
|
|
event.data = 0;
|
|
}
|
|
|
|
void Trigger(void* data) {
|
|
is_triggered = true;
|
|
event.fflags++;
|
|
event.data = reinterpret_cast<uintptr_t>(data);
|
|
}
|
|
|
|
bool IsTriggered() const {
|
|
return is_triggered;
|
|
}
|
|
|
|
bool operator==(const EqueueEvent& ev) const {
|
|
return ev.event.ident == event.ident;
|
|
}
|
|
|
|
private:
|
|
bool is_triggered = false;
|
|
};
|
|
|
|
class EqueueInternal {
|
|
public:
|
|
explicit EqueueInternal(std::string_view name) : m_name(name) {}
|
|
|
|
std::string_view GetName() const {
|
|
return m_name;
|
|
}
|
|
|
|
bool AddEvent(EqueueEvent& event);
|
|
bool RemoveEvent(u64 id);
|
|
int WaitForEvents(SceKernelEvent* ev, int num, u32 micros);
|
|
bool TriggerEvent(u64 ident, s16 filter, void* trigger_data);
|
|
int GetTriggeredEvents(SceKernelEvent* ev, int num);
|
|
|
|
bool AddSmallTimer(EqueueEvent& event);
|
|
bool HasSmallTimer() const {
|
|
return small_timer_event.event.data != 0;
|
|
}
|
|
|
|
int WaitForSmallTimer(SceKernelEvent* ev, int num, u32 micros);
|
|
|
|
private:
|
|
std::string m_name;
|
|
std::mutex m_mutex;
|
|
std::vector<EqueueEvent> m_events;
|
|
EqueueEvent small_timer_event{};
|
|
std::condition_variable m_cond;
|
|
};
|
|
|
|
using SceKernelUseconds = u32;
|
|
using SceKernelEqueue = EqueueInternal*;
|
|
|
|
void RegisterEventQueue(Core::Loader::SymbolsResolver* sym);
|
|
|
|
} // namespace Libraries::Kernel
|