mirror of
https://github.com/boykopovar/AnyPS5.git
synced 2026-11-08 13:50:20 +00:00
LeandroLP23andClaude Opus 5.5
cf020e1a06
Neither had a test. The join-self test now checks that a thread equals itself, that the creator's handle of it equals itself and differs from the creating thread, and that the thread continues after scePthreadYield. Co-Authored-By: Claude Opus 5.5 <[email protected]>
62 lines
2.6 KiB
C++
62 lines
2.6 KiB
C++
#include "prx/libkernel/KernelErrors.hpp"
|
|
#include "prx/libkernel/include/Api.hpp"
|
|
#include "SceTypes.hpp"
|
|
#include <atomic>
|
|
#include <chrono>
|
|
#include <cstdint>
|
|
#include <cstdlib>
|
|
#include <thread>
|
|
|
|
static constexpr int SCE_OK = 0;
|
|
static constexpr int GUEST_EDEADLK = 11;
|
|
|
|
static void Require(bool value) { if (!value) std::abort(); }
|
|
|
|
static void* APS5_VABI JoinSelf(void*) {
|
|
Require(scePthreadEqual(scePthreadSelf(), scePthreadSelf()) == 1);
|
|
scePthreadYield();
|
|
void* result = reinterpret_cast<void*>(std::uintptr_t{0x55});
|
|
Require(scePthreadJoin(scePthreadSelf(), &result) == SCE_KERNEL_ERROR_EDEADLK);
|
|
Require(pthread_join_nid_postfix(scePthreadSelf(), &result) == GUEST_EDEADLK);
|
|
Require(result == reinterpret_cast<void*>(std::uintptr_t{0x55}));
|
|
return reinterpret_cast<void*>(std::uintptr_t{0x1234});
|
|
}
|
|
|
|
static std::atomic<int> detachedChecks{0};
|
|
|
|
static void* APS5_VABI DetachThenJoinSelf(void*) {
|
|
void* result = reinterpret_cast<void*>(std::uintptr_t{0x66});
|
|
Require(scePthreadDetach(scePthreadSelf()) == SCE_OK);
|
|
Require(scePthreadJoin(scePthreadSelf(), &result) == SCE_KERNEL_ERROR_EDEADLK);
|
|
Require(pthread_join_nid_postfix(scePthreadSelf(), &result) == GUEST_EDEADLK);
|
|
Require(result == reinterpret_cast<void*>(std::uintptr_t{0x66}));
|
|
detachedChecks.store(1);
|
|
return nullptr;
|
|
}
|
|
|
|
int main() {
|
|
Pthread thread = nullptr;
|
|
void* result = nullptr;
|
|
Require(scePthreadCreate(&thread, nullptr, JoinSelf, nullptr, "join-self") == SCE_OK);
|
|
Require(scePthreadEqual(thread, thread) == 1 && scePthreadEqual(thread, scePthreadSelf()) == 0);
|
|
Require(scePthreadJoin(thread, &result) == SCE_OK);
|
|
Require(result == reinterpret_cast<void*>(std::uintptr_t{0x1234}));
|
|
|
|
PthreadAttr unset = nullptr;
|
|
thread = nullptr;
|
|
result = nullptr;
|
|
Require(scePthreadCreate(&thread, &unset, JoinSelf, nullptr, "unset-attr") == SCE_OK);
|
|
Require(scePthreadJoin(thread, &result) == SCE_OK);
|
|
Require(result == reinterpret_cast<void*>(std::uintptr_t{0x1234}));
|
|
|
|
thread = nullptr;
|
|
Require(scePthreadCreate(&thread, nullptr, DetachThenJoinSelf, nullptr, "detach-join-self") == SCE_OK);
|
|
for (int wait = 0; wait < 5000 && detachedChecks.load() == 0; ++wait) std::this_thread::sleep_for(std::chrono::milliseconds(1));
|
|
Require(detachedChecks.load() == 1);
|
|
|
|
result = reinterpret_cast<void*>(std::uintptr_t{0x77});
|
|
Require(scePthreadJoin(scePthreadSelf(), &result) == SCE_KERNEL_ERROR_EDEADLK);
|
|
Require(pthread_join_nid_postfix(scePthreadSelf(), &result) == GUEST_EDEADLK);
|
|
Require(result == reinterpret_cast<void*>(std::uintptr_t{0x77}));
|
|
}
|